Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.admin

Interface EventProcessorOrBuilder

  • All Superinterfaces:
    com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder
    All Known Implementing Classes:
    EventProcessor, EventProcessor.Builder
    @Generated
public interface EventProcessorOrBuilder
extends com.google.protobuf.MessageOrBuilder

    • Method Detail

      • hasIdentifier

        boolean hasIdentifier()
         the identifier of the event processor
        .io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier identifier = 1;
        Returns:
        Whether the identifier field is set.

      • getIdentifier

        EventProcessorIdentifier getIdentifier()
         the identifier of the event processor
        .io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier identifier = 1;
        Returns:
        The identifier.

      • getIdentifierOrBuilder

        EventProcessorIdentifierOrBuilder getIdentifierOrBuilder()
         the identifier of the event processor
        .io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier identifier = 1;

      • getMode

        String getMode()
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Returns:
        The mode.

      • getModeBytes

        com.google.protobuf.ByteString getModeBytes()
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Returns:
        The bytes for mode.

      • getIsStreaming

        boolean getIsStreaming()
         true if the event processor is streaming, false otherwise
        bool isStreaming = 3;
        Returns:
        The isStreaming.

      • getClientInstanceList

        List<EventProcessorInstance> getClientInstanceList()
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • getClientInstance

        EventProcessorInstance getClientInstance​(int index)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • getClientInstanceCount

        int getClientInstanceCount()
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • getClientInstanceOrBuilderList

        List<? extends EventProcessorInstanceOrBuilder> getClientInstanceOrBuilderList()
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • getClientInstanceOrBuilder

        EventProcessorInstanceOrBuilder getClientInstanceOrBuilder​(int index)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • getLoadBalancingStrategyName

        String getLoadBalancingStrategyName()
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 5;
        Returns:
        The loadBalancingStrategyName.

      • getLoadBalancingStrategyNameBytes

        com.google.protobuf.ByteString getLoadBalancingStrategyNameBytes()
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 5;
        Returns:
        The bytes for loadBalancingStrategyName.