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

Class EventProcessorInfo.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, EventProcessorInfoOrBuilder, Cloneable
    Enclosing class:
    EventProcessorInfo
    public static final class EventProcessorInfo.Builder
extends com.google.protobuf.GeneratedMessage.Builder<EventProcessorInfo.Builder>
implements EventProcessorInfoOrBuilder
     Message containing information about the status of an Event Processor
    Protobuf type io.axoniq.axonserver.grpc.control.EventProcessorInfo

    • Method Detail

      • getDescriptor

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

      • internalGetFieldAccessorTable

        protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()
        Specified by:
        internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInfo.Builder>

      • clear

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

      • getDescriptorForType

        public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()
        Specified by:
        getDescriptorForType in interface com.google.protobuf.Message.Builder
        Specified by:
        getDescriptorForType in interface com.google.protobuf.MessageOrBuilder
        Overrides:
        getDescriptorForType in class com.google.protobuf.GeneratedMessage.Builder<EventProcessorInfo.Builder>

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

        public EventProcessorInfo.Builder mergeFrom​(com.google.protobuf.Message other)
        Specified by:
        mergeFrom in interface com.google.protobuf.Message.Builder
        Overrides:
        mergeFrom in class com.google.protobuf.AbstractMessage.Builder<EventProcessorInfo.Builder>

      • isInitialized

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

      • mergeFrom

        public EventProcessorInfo.Builder mergeFrom​(com.google.protobuf.CodedInputStream input,
                                            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                     throws IOException
        Specified by:
        mergeFrom in interface com.google.protobuf.Message.Builder
        Specified by:
        mergeFrom in interface com.google.protobuf.MessageLite.Builder
        Overrides:
        mergeFrom in class com.google.protobuf.AbstractMessage.Builder<EventProcessorInfo.Builder>
        Throws:
        IOException

      • 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.

      • setProcessorName

        public EventProcessorInfo.Builder setProcessorName​(String value)
         The logical name of this processor.
        string processor_name = 1;
        Parameters:
        value - The processorName to set.
        Returns:
        This builder for chaining.

      • clearProcessorName

        public EventProcessorInfo.Builder clearProcessorName()
         The logical name of this processor.
        string processor_name = 1;
        Returns:
        This builder for chaining.

      • setProcessorNameBytes

        public EventProcessorInfo.Builder setProcessorNameBytes​(com.google.protobuf.ByteString value)
         The logical name of this processor.
        string processor_name = 1;
        Parameters:
        value - The bytes for processorName to set.
        Returns:
        This builder for chaining.

      • 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.

      • setMode

        public EventProcessorInfo.Builder setMode​(String value)
         The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
        string mode = 2;
        Parameters:
        value - The mode to set.
        Returns:
        This builder for chaining.

      • clearMode

        public EventProcessorInfo.Builder clearMode()
         The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
        string mode = 2;
        Returns:
        This builder for chaining.

      • setModeBytes

        public EventProcessorInfo.Builder setModeBytes​(com.google.protobuf.ByteString value)
         The mode in which this processor is reading Events, for example: 'Tracking' or 'Subscribing'
        string mode = 2;
        Parameters:
        value - The bytes for mode to set.
        Returns:
        This builder for chaining.

      • 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.

      • setActiveThreads

        public EventProcessorInfo.Builder setActiveThreads​(int value)
         The number of threads currently actively processing Events
        int32 active_threads = 3;
        Parameters:
        value - The activeThreads to set.
        Returns:
        This builder for chaining.

      • clearActiveThreads

        public EventProcessorInfo.Builder clearActiveThreads()
         The number of threads currently actively processing Events
        int32 active_threads = 3;
        Returns:
        This builder for chaining.

      • getRunning

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

      • setRunning

        public EventProcessorInfo.Builder setRunning​(boolean value)
         Flag indicating whether the processor is running
        bool running = 4;
        Parameters:
        value - The running to set.
        Returns:
        This builder for chaining.

      • clearRunning

        public EventProcessorInfo.Builder clearRunning()
         Flag indicating whether the processor is running
        bool running = 4;
        Returns:
        This builder for chaining.

      • 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.

      • setError

        public EventProcessorInfo.Builder setError​(boolean value)
         Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
        bool error = 5;
        Parameters:
        value - The error to set.
        Returns:
        This builder for chaining.

      • clearError

        public EventProcessorInfo.Builder clearError()
         Flag indicating whether the processor, when stopped, did so because of an irrecoverable Error
        bool error = 5;
        Returns:
        This builder for chaining.

      • 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

      • setSegmentStatus

        public EventProcessorInfo.Builder setSegmentStatus​(int index,
                                                   EventProcessorInfo.SegmentStatus value)
         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;

      • setSegmentStatus

        public EventProcessorInfo.Builder setSegmentStatus​(int index,
                                                   EventProcessorInfo.SegmentStatus.Builder builderForValue)
         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;

      • addSegmentStatus

        public EventProcessorInfo.Builder addSegmentStatus​(EventProcessorInfo.SegmentStatus value)
         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;

      • addSegmentStatus

        public EventProcessorInfo.Builder addSegmentStatus​(int index,
                                                   EventProcessorInfo.SegmentStatus value)
         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;

      • addSegmentStatus

        public EventProcessorInfo.Builder addSegmentStatus​(EventProcessorInfo.SegmentStatus.Builder builderForValue)
         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;

      • addSegmentStatus

        public EventProcessorInfo.Builder addSegmentStatus​(int index,
                                                   EventProcessorInfo.SegmentStatus.Builder builderForValue)
         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;

      • addAllSegmentStatus

        public EventProcessorInfo.Builder addAllSegmentStatus​(Iterable<? extends EventProcessorInfo.SegmentStatus> values)
         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;

      • clearSegmentStatus

        public EventProcessorInfo.Builder clearSegmentStatus()
         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;

      • removeSegmentStatus

        public EventProcessorInfo.Builder removeSegmentStatus​(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;

      • getSegmentStatusBuilder

        public EventProcessorInfo.SegmentStatus.Builder getSegmentStatusBuilder​(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;

      • addSegmentStatusBuilder

        public EventProcessorInfo.SegmentStatus.Builder addSegmentStatusBuilder()
         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;

      • addSegmentStatusBuilder

        public EventProcessorInfo.SegmentStatus.Builder addSegmentStatusBuilder​(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;

      • getSegmentStatusBuilderList

        public List<EventProcessorInfo.SegmentStatus.Builder> getSegmentStatusBuilderList()
         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

        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.

      • setAvailableThreads

        public EventProcessorInfo.Builder setAvailableThreads​(int value)
         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;
        Parameters:
        value - The availableThreads to set.
        Returns:
        This builder for chaining.

      • clearAvailableThreads

        public EventProcessorInfo.Builder clearAvailableThreads()
         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:
        This builder for chaining.

      • 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.

      • setTokenStoreIdentifier

        public EventProcessorInfo.Builder setTokenStoreIdentifier​(String value)
         The Token Store Identifier if available. This is only provided by Streaming Event Processors.
        string token_store_identifier = 8;
        Parameters:
        value - The tokenStoreIdentifier to set.
        Returns:
        This builder for chaining.

      • clearTokenStoreIdentifier

        public EventProcessorInfo.Builder clearTokenStoreIdentifier()
         The Token Store Identifier if available. This is only provided by Streaming Event Processors.
        string token_store_identifier = 8;
        Returns:
        This builder for chaining.

      • setTokenStoreIdentifierBytes

        public EventProcessorInfo.Builder setTokenStoreIdentifierBytes​(com.google.protobuf.ByteString value)
         The Token Store Identifier if available. This is only provided by Streaming Event Processors.
        string token_store_identifier = 8;
        Parameters:
        value - The bytes for tokenStoreIdentifier to set.
        Returns:
        This builder for chaining.

      • 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.

      • setIsStreamingProcessor

        public EventProcessorInfo.Builder setIsStreamingProcessor​(boolean value)
         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;
        Parameters:
        value - The isStreamingProcessor to set.
        Returns:
        This builder for chaining.

      • clearIsStreamingProcessor

        public EventProcessorInfo.Builder clearIsStreamingProcessor()
         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:
        This builder for chaining.

      • 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.

      • setLoadBalancingStrategyName

        public EventProcessorInfo.Builder setLoadBalancingStrategyName​(String value)
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 10;
        Parameters:
        value - The loadBalancingStrategyName to set.
        Returns:
        This builder for chaining.

      • clearLoadBalancingStrategyName

        public EventProcessorInfo.Builder clearLoadBalancingStrategyName()
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 10;
        Returns:
        This builder for chaining.

      • setLoadBalancingStrategyNameBytes

        public EventProcessorInfo.Builder setLoadBalancingStrategyNameBytes​(com.google.protobuf.ByteString value)
         current load balancing strategy name for the event processor
        string load_balancing_strategy_name = 10;
        Parameters:
        value - The bytes for loadBalancingStrategyName to set.
        Returns:
        This builder for chaining.