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

Class StreamStatus.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, StreamStatusOrBuilder, Cloneable
    Enclosing class:
    StreamStatus
    public static final class StreamStatus.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StreamStatus.Builder>
implements StreamStatusOrBuilder
     Contains the current status of a persistent stream
    Protobuf type io.axoniq.axonserver.grpc.streams.StreamStatus

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

      • clear

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • isInitialized

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

      • mergeFrom

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

      • getStreamId

        public String getStreamId()
         the unique identification of the persistent stream
        string stream_id = 1;
        Specified by:
        getStreamId in interface StreamStatusOrBuilder
        Returns:
        The streamId.

      • getStreamIdBytes

        public com.google.protobuf.ByteString getStreamIdBytes()
         the unique identification of the persistent stream
        string stream_id = 1;
        Specified by:
        getStreamIdBytes in interface StreamStatusOrBuilder
        Returns:
        The bytes for streamId.

      • setStreamId

        public StreamStatus.Builder setStreamId​(String value)
         the unique identification of the persistent stream
        string stream_id = 1;
        Parameters:
        value - The streamId to set.
        Returns:
        This builder for chaining.

      • clearStreamId

        public StreamStatus.Builder clearStreamId()
         the unique identification of the persistent stream
        string stream_id = 1;
        Returns:
        This builder for chaining.

      • setStreamIdBytes

        public StreamStatus.Builder setStreamIdBytes​(com.google.protobuf.ByteString value)
         the unique identification of the persistent stream
        string stream_id = 1;
        Parameters:
        value - The bytes for streamId to set.
        Returns:
        This builder for chaining.

      • getStreamNameBytes

        public com.google.protobuf.ByteString getStreamNameBytes()
         a name for the persistent stream
        string stream_name = 2;
        Specified by:
        getStreamNameBytes in interface StreamStatusOrBuilder
        Returns:
        The bytes for streamName.

      • setStreamName

        public StreamStatus.Builder setStreamName​(String value)
         a name for the persistent stream
        string stream_name = 2;
        Parameters:
        value - The streamName to set.
        Returns:
        This builder for chaining.

      • clearStreamName

        public StreamStatus.Builder clearStreamName()
         a name for the persistent stream
        string stream_name = 2;
        Returns:
        This builder for chaining.

      • setStreamNameBytes

        public StreamStatus.Builder setStreamNameBytes​(com.google.protobuf.ByteString value)
         a name for the persistent stream
        string stream_name = 2;
        Parameters:
        value - The bytes for streamName to set.
        Returns:
        This builder for chaining.

      • hasSequencingPolicy

        public boolean hasSequencingPolicy()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;
        Specified by:
        hasSequencingPolicy in interface StreamStatusOrBuilder
        Returns:
        Whether the sequencingPolicy field is set.

      • getSequencingPolicy

        public SequencingPolicy getSequencingPolicy()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;
        Specified by:
        getSequencingPolicy in interface StreamStatusOrBuilder
        Returns:
        The sequencingPolicy.

      • setSequencingPolicy

        public StreamStatus.Builder setSequencingPolicy​(SequencingPolicy value)
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • setSequencingPolicy

        public StreamStatus.Builder setSequencingPolicy​(SequencingPolicy.Builder builderForValue)
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • mergeSequencingPolicy

        public StreamStatus.Builder mergeSequencingPolicy​(SequencingPolicy value)
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • clearSequencingPolicy

        public StreamStatus.Builder clearSequencingPolicy()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • getSequencingPolicyBuilder

        public SequencingPolicy.Builder getSequencingPolicyBuilder()
         the policy used to distribute events across segments.
        .io.axoniq.axonserver.grpc.streams.SequencingPolicy sequencing_policy = 3;

      • getFilter

        public String getFilter()
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Specified by:
        getFilter in interface StreamStatusOrBuilder
        Returns:
        The filter.

      • getFilterBytes

        public com.google.protobuf.ByteString getFilterBytes()
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Specified by:
        getFilterBytes in interface StreamStatusOrBuilder
        Returns:
        The bytes for filter.

      • setFilter

        public StreamStatus.Builder setFilter​(String value)
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Parameters:
        value - The filter to set.
        Returns:
        This builder for chaining.

      • clearFilter

        public StreamStatus.Builder clearFilter()
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Returns:
        This builder for chaining.

      • setFilterBytes

        public StreamStatus.Builder setFilterBytes​(com.google.protobuf.ByteString value)
         an expression to filter events, same syntax as used for ad-hoc queries on the event store
        string filter = 4;
        Parameters:
        value - The bytes for filter to set.
        Returns:
        This builder for chaining.

      • getSegmentsCount

        public int getSegmentsCount()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;
        Specified by:
        getSegmentsCount in interface StreamStatusOrBuilder

      • getSegments

        public SegmentPosition getSegments​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;
        Specified by:
        getSegments in interface StreamStatusOrBuilder

      • setSegments

        public StreamStatus.Builder setSegments​(int index,
                                        SegmentPosition value)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • setSegments

        public StreamStatus.Builder setSegments​(int index,
                                        SegmentPosition.Builder builderForValue)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addSegments

        public StreamStatus.Builder addSegments​(SegmentPosition value)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addSegments

        public StreamStatus.Builder addSegments​(int index,
                                        SegmentPosition value)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addSegments

        public StreamStatus.Builder addSegments​(int index,
                                        SegmentPosition.Builder builderForValue)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addAllSegments

        public StreamStatus.Builder addAllSegments​(Iterable<? extends SegmentPosition> values)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • clearSegments

        public StreamStatus.Builder clearSegments()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • removeSegments

        public StreamStatus.Builder removeSegments​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegmentsBuilder

        public SegmentPosition.Builder getSegmentsBuilder​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addSegmentsBuilder

        public SegmentPosition.Builder addSegmentsBuilder()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • addSegmentsBuilder

        public SegmentPosition.Builder addSegmentsBuilder​(int index)
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;

      • getSegmentsBuilderList

        public List<SegmentPosition.Builder> getSegmentsBuilderList()
         the last confirmed position per segment
        repeated .io.axoniq.axonserver.grpc.streams.SegmentPosition segments = 5;