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

Class EventProcessorInfo

  • All Implemented Interfaces:
    com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, EventProcessorInfoOrBuilder, Serializable
    @Generated
public final class EventProcessorInfo
extends com.google.protobuf.GeneratedMessage
implements EventProcessorInfoOrBuilder
     Message containing information about the status of an Event Processor
    Protobuf type io.axoniq.axonserver.grpc.control.EventProcessorInfo
    See Also:
    Serialized Form

    • Field Detail

      • PROCESSOR_NAME_FIELD_NUMBER

        public static final int PROCESSOR_NAME_FIELD_NUMBER
        See Also:
        Constant Field Values

      • ACTIVE_THREADS_FIELD_NUMBER

        public static final int ACTIVE_THREADS_FIELD_NUMBER
        See Also:
        Constant Field Values

      • SEGMENT_STATUS_FIELD_NUMBER

        public static final int SEGMENT_STATUS_FIELD_NUMBER
        See Also:
        Constant Field Values

      • AVAILABLE_THREADS_FIELD_NUMBER

        public static final int AVAILABLE_THREADS_FIELD_NUMBER
        See Also:
        Constant Field Values

      • TOKEN_STORE_IDENTIFIER_FIELD_NUMBER

        public static final int TOKEN_STORE_IDENTIFIER_FIELD_NUMBER
        See Also:
        Constant Field Values

      • IS_STREAMING_PROCESSOR_FIELD_NUMBER

        public static final int IS_STREAMING_PROCESSOR_FIELD_NUMBER
        See Also:
        Constant Field Values

      • LOAD_BALANCING_STRATEGY_NAME_FIELD_NUMBER

        public static final int LOAD_BALANCING_STRATEGY_NAME_FIELD_NUMBER
        See Also:
        Constant Field Values

    • Method Detail

      • getDescriptor

        public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

      • getDescriptorForType

        public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
        Specified by:
        getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
        Overrides:
        getDescriptorForType in class com.google.protobuf.GeneratedMessage

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage

      • getProcessorNameBytes

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

      • getMode

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

      • getModeBytes

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

      • getActiveThreads

        public int getActiveThreads()
         The number of threads currently actively processing Events
        int32 active_threads = 3;
        Specified by:
        getActiveThreads in interface EventProcessorInfoOrBuilder
        Returns:
        The activeThreads.

      • getRunning

        public boolean getRunning()
         Flag indicating whether the processor is running
        bool running = 4;
        Specified by:
        getRunning in interface EventProcessorInfoOrBuilder
        Returns:
        The running.

      • getError

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

      • getSegmentStatusCount

        public 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;
        Specified by:
        getSegmentStatusCount in interface EventProcessorInfoOrBuilder

      • getSegmentStatus

        public 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;
        Specified by:
        getSegmentStatus in interface EventProcessorInfoOrBuilder

      • getAvailableThreads

        public 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;
        Specified by:
        getAvailableThreads in interface EventProcessorInfoOrBuilder
        Returns:
        The availableThreads.

      • getTokenStoreIdentifier

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

      • getTokenStoreIdentifierBytes

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

      • getIsStreamingProcessor

        public 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;
        Specified by:
        getIsStreamingProcessor in interface EventProcessorInfoOrBuilder
        Returns:
        The isStreamingProcessor.

      • getLoadBalancingStrategyName

        public String getLoadBalancingStrategyName()
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 10;
        Specified by:
        getLoadBalancingStrategyName in interface EventProcessorInfoOrBuilder
        Returns:
        The loadBalancingStrategyName.

      • getLoadBalancingStrategyNameBytes

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

      • isInitialized

        public final boolean isInitialized()
        Specified by:
        isInitialized in interface com.google.protobuf.MessageLiteOrBuilder
        Overrides:
        isInitialized in class com.google.protobuf.GeneratedMessage

      • writeTo

        public void writeTo​(com.google.protobuf.CodedOutputStream output)
             throws IOException
        Specified by:
        writeTo in interface com.google.protobuf.MessageLite
        Overrides:
        writeTo in class com.google.protobuf.GeneratedMessage
        Throws:
        IOException

      • getSerializedSize

        public int getSerializedSize()
        Specified by:
        getSerializedSize in interface com.google.protobuf.MessageLite
        Overrides:
        getSerializedSize in class com.google.protobuf.GeneratedMessage

      • equals

        public boolean equals​(Object obj)
        Specified by:
        equals in interface com.google.protobuf.Message
        Overrides:
        equals in class com.google.protobuf.AbstractMessage

      • hashCode

        public int hashCode()
        Specified by:
        hashCode in interface com.google.protobuf.Message
        Overrides:
        hashCode in class com.google.protobuf.AbstractMessage

      • parseFrom

        public static EventProcessorInfo parseFrom​(ByteBuffer data)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(ByteBuffer data,
                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(com.google.protobuf.ByteString data)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(com.google.protobuf.ByteString data,
                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(byte[] data)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(byte[] data,
                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                    throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException

      • parseFrom

        public static EventProcessorInfo parseFrom​(com.google.protobuf.CodedInputStream input,
                                           com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                    throws IOException
        Throws:
        IOException

      • newBuilderForType

        public EventProcessorInfo.Builder newBuilderForType()
        Specified by:
        newBuilderForType in interface com.google.protobuf.Message
        Specified by:
        newBuilderForType in interface com.google.protobuf.MessageLite

      • toBuilder

        public EventProcessorInfo.Builder toBuilder()
        Specified by:
        toBuilder in interface com.google.protobuf.Message
        Specified by:
        toBuilder in interface com.google.protobuf.MessageLite

      • newBuilderForType

        protected EventProcessorInfo.Builder newBuilderForType​(com.google.protobuf.AbstractMessage.BuilderParent parent)
        Overrides:
        newBuilderForType in class com.google.protobuf.AbstractMessage

      • getParserForType

        public com.google.protobuf.Parser<EventProcessorInfo> getParserForType()
        Specified by:
        getParserForType in interface com.google.protobuf.Message
        Specified by:
        getParserForType in interface com.google.protobuf.MessageLite
        Overrides:
        getParserForType in class com.google.protobuf.GeneratedMessage

      • getDefaultInstanceForType

        public EventProcessorInfo getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder