Module io.axoniq.connector.axonserver
Package io.axoniq.axonserver.grpc.event.dcb

Class StreamEventsRequest.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, StreamEventsRequestOrBuilder, Cloneable
    Enclosing class:
    StreamEventsRequest
    public static final class StreamEventsRequest.Builder
extends com.google.protobuf.GeneratedMessage.Builder<StreamEventsRequest.Builder>
implements StreamEventsRequestOrBuilder
     The request to provide an infinite stream of events from the event store. The client may cancel the stream at any
 time.
    Protobuf type io.axoniq.axonserver.grpc.event.dcb.StreamEventsRequest

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

      • clear

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • isInitialized

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

      • mergeFrom

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

      • getFromSequence

        public long getFromSequence()
         The inclusive sequence to start streaming from.
        int64 from_sequence = 1;
        Specified by:
        getFromSequence in interface StreamEventsRequestOrBuilder
        Returns:
        The fromSequence.

      • setFromSequence

        public StreamEventsRequest.Builder setFromSequence​(long value)
         The inclusive sequence to start streaming from.
        int64 from_sequence = 1;
        Parameters:
        value - The fromSequence to set.
        Returns:
        This builder for chaining.

      • clearFromSequence

        public StreamEventsRequest.Builder clearFromSequence()
         The inclusive sequence to start streaming from.
        int64 from_sequence = 1;
        Returns:
        This builder for chaining.

      • getCriterionList

        public List<Criterion> getCriterionList()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;
        Specified by:
        getCriterionList in interface StreamEventsRequestOrBuilder

      • getCriterionCount

        public int getCriterionCount()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;
        Specified by:
        getCriterionCount in interface StreamEventsRequestOrBuilder

      • getCriterion

        public Criterion getCriterion​(int index)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;
        Specified by:
        getCriterion in interface StreamEventsRequestOrBuilder

      • setCriterion

        public StreamEventsRequest.Builder setCriterion​(int index,
                                                Criterion value)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • setCriterion

        public StreamEventsRequest.Builder setCriterion​(int index,
                                                Criterion.Builder builderForValue)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addCriterion

        public StreamEventsRequest.Builder addCriterion​(Criterion value)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addCriterion

        public StreamEventsRequest.Builder addCriterion​(int index,
                                                Criterion value)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addCriterion

        public StreamEventsRequest.Builder addCriterion​(Criterion.Builder builderForValue)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addCriterion

        public StreamEventsRequest.Builder addCriterion​(int index,
                                                Criterion.Builder builderForValue)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addAllCriterion

        public StreamEventsRequest.Builder addAllCriterion​(Iterable<? extends Criterion> values)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • clearCriterion

        public StreamEventsRequest.Builder clearCriterion()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • removeCriterion

        public StreamEventsRequest.Builder removeCriterion​(int index)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • getCriterionBuilder

        public Criterion.Builder getCriterionBuilder​(int index)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • getCriterionOrBuilder

        public CriterionOrBuilder getCriterionOrBuilder​(int index)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;
        Specified by:
        getCriterionOrBuilder in interface StreamEventsRequestOrBuilder

      • getCriterionOrBuilderList

        public List<? extends CriterionOrBuilder> getCriterionOrBuilderList()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;
        Specified by:
        getCriterionOrBuilderList in interface StreamEventsRequestOrBuilder

      • addCriterionBuilder

        public Criterion.Builder addCriterionBuilder()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • addCriterionBuilder

        public Criterion.Builder addCriterionBuilder​(int index)
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;

      • getCriterionBuilderList

        public List<Criterion.Builder> getCriterionBuilderList()
         The criteria used to filter out events. Represented by a list of criterions. If at least one is met, the whole
 criteria is met.
        repeated .io.axoniq.axonserver.grpc.event.dcb.Criterion criterion = 2;