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

Interface EventProcessorInfoOrBuilder

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

    • Method Detail

      • getProcessorName

        String getProcessorName()
         The logical name of this processor.
        string processor_name = 1;
        Returns:
        The processorName.

      • getProcessorNameBytes

        com.google.protobuf.ByteString getProcessorNameBytes()
         The logical name of this processor.
        string processor_name = 1;
        Returns:
        The bytes for processorName.

      • getMode

        String getMode()
         The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
        string mode = 2;
        Returns:
        The mode.

      • getModeBytes

        com.google.protobuf.ByteString getModeBytes()
         The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
        string mode = 2;
        Returns:
        The bytes for mode.

      • getActiveThreads

        int getActiveThreads()
         The number of threads currently actively processing Events
        int32 active_threads = 3;
        Returns:
        The activeThreads.

      • getRunning

        boolean getRunning()
         Flag indicating whether the processor is running
        bool running = 4;
        Returns:
        The running.

      • getError

        boolean getError()
         Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
        bool error = 5;
        Returns:
        The error.

      • getSegmentStatusList

        List<EventProcessorInfo.SegmentStatus> getSegmentStatusList()
         Status details of each of the Segments for which Events are being processed. This is only provided by Streaming
 Event Processors.
        repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;

      • getSegmentStatus

        EventProcessorInfo.SegmentStatus getSegmentStatus​(int index)
         Status details of each of the Segments for which Events are being processed. This is only provided by Streaming
 Event Processors.
        repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;

      • getSegmentStatusCount

        int getSegmentStatusCount()
         Status details of each of the Segments for which Events are being processed. This is only provided by Streaming
 Event Processors.
        repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;

      • getSegmentStatusOrBuilderList

        List<? extends EventProcessorInfo.SegmentStatusOrBuilder> getSegmentStatusOrBuilderList()
         Status details of each of the Segments for which Events are being processed. This is only provided by Streaming
 Event Processors.
        repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;

      • getSegmentStatusOrBuilder

        EventProcessorInfo.SegmentStatusOrBuilder getSegmentStatusOrBuilder​(int index)
         Status details of each of the Segments for which Events are being processed. This is only provided by Streaming
 Event Processors.
        repeated .io.axoniq.axonserver.grpc.control.EventProcessorInfo.SegmentStatus segment_status = 6;

      • getAvailableThreads

        int getAvailableThreads()
         The number of threads the processor has available to assign to Segments.
 Will report 0 if all threads are assigned a Segment.
        int32 available_threads = 7;
        Returns:
        The availableThreads.

      • getTokenStoreIdentifier

        String getTokenStoreIdentifier()
         The Token Store Identifier if available. This is only provided by Streaming Event Processors.
        string token_store_identifier = 8;
        Returns:
        The tokenStoreIdentifier.

      • getTokenStoreIdentifierBytes

        com.google.protobuf.ByteString getTokenStoreIdentifierBytes()
         The Token Store Identifier if available. This is only provided by Streaming Event Processors.
        string token_store_identifier = 8;
        Returns:
        The bytes for tokenStoreIdentifier.

      • getIsStreamingProcessor

        boolean getIsStreamingProcessor()
         Flag indicating whether the processor is a Streaming Event Processor.
 This dictates whether streaming operations, like split and merge, are supported by this processor.
        bool is_streaming_processor = 9;
        Returns:
        The isStreamingProcessor.

      • getLoadBalancingStrategyName

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

      • getLoadBalancingStrategyNameBytes

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