Class StreamEventsRequest

  • All Implemented Interfaces:
    com.google.protobuf.Message, com.google.protobuf.MessageLite, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, StreamEventsRequestOrBuilder, Serializable

    @Generated
    public final class StreamEventsRequest
    extends com.google.protobuf.GeneratedMessage
    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
    See Also:
    Serialized Form
    • Field Detail

      • FROM_SEQUENCE_FIELD_NUMBER

        public static final int FROM_SEQUENCE_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
      • getFromSequence

        public long getFromSequence()
         The inclusive sequence to start streaming from. 
         
        int64 from_sequence = 1;
        Specified by:
        getFromSequence in interface StreamEventsRequestOrBuilder
        Returns:
        The fromSequence.
      • 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
      • 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
      • 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
      • 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
      • 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 StreamEventsRequest parseFrom​(ByteBuffer data)
                                             throws com.google.protobuf.InvalidProtocolBufferException
        Throws:
        com.google.protobuf.InvalidProtocolBufferException
      • parseFrom

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

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

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

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

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

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

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

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

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

        public com.google.protobuf.Parser<StreamEventsRequest> 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 StreamEventsRequest getDefaultInstanceForType()
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder
        Specified by:
        getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder