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

Class EventProcessor.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, EventProcessorOrBuilder, Cloneable
    Enclosing class:
    EventProcessor
    public static final class EventProcessor.Builder
extends com.google.protobuf.GeneratedMessage.Builder<EventProcessor.Builder>
implements EventProcessorOrBuilder
    Protobuf type io.axoniq.axonserver.grpc.admin.EventProcessor

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

      • clear

        public EventProcessor.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<EventProcessor.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<EventProcessor.Builder>

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

        public EventProcessor.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<EventProcessor.Builder>

      • isInitialized

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

      • mergeFrom

        public EventProcessor.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<EventProcessor.Builder>
        Throws:
        IOException

      • hasIdentifier

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

      • clearIdentifier

        public EventProcessor.Builder clearIdentifier()
         the identifier of the event processor
        .io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier identifier = 1;

      • getIdentifierBuilder

        public EventProcessorIdentifier.Builder getIdentifierBuilder()
         the identifier of the event processor
        .io.axoniq.axonserver.grpc.admin.EventProcessorIdentifier identifier = 1;

      • getMode

        public String getMode()
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Specified by:
        getMode in interface EventProcessorOrBuilder
        Returns:
        The mode.

      • getModeBytes

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

      • setMode

        public EventProcessor.Builder setMode​(String value)
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Parameters:
        value - The mode to set.
        Returns:
        This builder for chaining.

      • clearMode

        public EventProcessor.Builder clearMode()
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Returns:
        This builder for chaining.

      • setModeBytes

        public EventProcessor.Builder setModeBytes​(com.google.protobuf.ByteString value)
         the event processor mode (subscribing, tracking, pooled)
        string mode = 2;
        Parameters:
        value - The bytes for mode to set.
        Returns:
        This builder for chaining.

      • getIsStreaming

        public boolean getIsStreaming()
         true if the event processor is streaming, false otherwise
        bool isStreaming = 3;
        Specified by:
        getIsStreaming in interface EventProcessorOrBuilder
        Returns:
        The isStreaming.

      • setIsStreaming

        public EventProcessor.Builder setIsStreaming​(boolean value)
         true if the event processor is streaming, false otherwise
        bool isStreaming = 3;
        Parameters:
        value - The isStreaming to set.
        Returns:
        This builder for chaining.

      • clearIsStreaming

        public EventProcessor.Builder clearIsStreaming()
         true if the event processor is streaming, false otherwise
        bool isStreaming = 3;
        Returns:
        This builder for chaining.

      • getClientInstanceCount

        public int getClientInstanceCount()
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;
        Specified by:
        getClientInstanceCount in interface EventProcessorOrBuilder

      • setClientInstance

        public EventProcessor.Builder setClientInstance​(int index,
                                                EventProcessorInstance value)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • setClientInstance

        public EventProcessor.Builder setClientInstance​(int index,
                                                EventProcessorInstance.Builder builderForValue)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • addClientInstance

        public EventProcessor.Builder addClientInstance​(EventProcessorInstance value)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • addClientInstance

        public EventProcessor.Builder addClientInstance​(int index,
                                                EventProcessorInstance value)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • addClientInstance

        public EventProcessor.Builder addClientInstance​(EventProcessorInstance.Builder builderForValue)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • addClientInstance

        public EventProcessor.Builder addClientInstance​(int index,
                                                EventProcessorInstance.Builder builderForValue)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • addAllClientInstance

        public EventProcessor.Builder addAllClientInstance​(Iterable<? extends EventProcessorInstance> values)
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • clearClientInstance

        public EventProcessor.Builder clearClientInstance()
         client instances that subscribed the event processor
        repeated .io.axoniq.axonserver.grpc.admin.EventProcessorInstance client_instance = 4;

      • removeClientInstance

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

      • getClientInstanceBuilder

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

      • addClientInstanceBuilder

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

      • addClientInstanceBuilder

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

      • getClientInstanceBuilderList

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

      • getLoadBalancingStrategyName

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

      • getLoadBalancingStrategyNameBytes

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

      • setLoadBalancingStrategyName

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

      • clearLoadBalancingStrategyName

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

      • setLoadBalancingStrategyNameBytes

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