Package s2.v1alpha

Class ReadSessionRequest.Builder

  • All Implemented Interfaces:
    com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, java.lang.Cloneable, ReadSessionRequestOrBuilder
    Enclosing class:
    ReadSessionRequest
    public static final class ReadSessionRequest.Builder
extends com.google.protobuf.GeneratedMessage.Builder<ReadSessionRequest.Builder>
implements ReadSessionRequestOrBuilder
     Read session request.
    Protobuf type s2.v1alpha.ReadSessionRequest

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

      • clear

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

      • getDefaultInstanceForType

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

      • build

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

      • buildPartial

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

      • mergeFrom

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

      • isInitialized

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

      • mergeFrom

        public ReadSessionRequest.Builder mergeFrom​(com.google.protobuf.CodedInputStream input,
                                            com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                     throws java.io.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<ReadSessionRequest.Builder>
        Throws:
        java.io.IOException

      • getStreamBytes

        public com.google.protobuf.ByteString getStreamBytes()
         Stream name.
        string stream = 1;
        Specified by:
        getStreamBytes in interface ReadSessionRequestOrBuilder
        Returns:
        The bytes for stream.

      • setStream

        public ReadSessionRequest.Builder setStream​(java.lang.String value)
         Stream name.
        string stream = 1;
        Parameters:
        value - The stream to set.
        Returns:
        This builder for chaining.

      • clearStream

        public ReadSessionRequest.Builder clearStream()
         Stream name.
        string stream = 1;
        Returns:
        This builder for chaining.

      • setStreamBytes

        public ReadSessionRequest.Builder setStreamBytes​(com.google.protobuf.ByteString value)
         Stream name.
        string stream = 1;
        Parameters:
        value - The bytes for stream to set.
        Returns:
        This builder for chaining.

      • hasSeqNum

        public boolean hasSeqNum()
         Sequence number.
        uint64 seq_num = 2;
        Specified by:
        hasSeqNum in interface ReadSessionRequestOrBuilder
        Returns:
        Whether the seqNum field is set.

      • setSeqNum

        public ReadSessionRequest.Builder setSeqNum​(long value)
         Sequence number.
        uint64 seq_num = 2;
        Parameters:
        value - The seqNum to set.
        Returns:
        This builder for chaining.

      • clearSeqNum

        public ReadSessionRequest.Builder clearSeqNum()
         Sequence number.
        uint64 seq_num = 2;
        Returns:
        This builder for chaining.

      • setTimestamp

        public ReadSessionRequest.Builder setTimestamp​(long value)
         Timestamp.
        uint64 timestamp = 5;
        Parameters:
        value - The timestamp to set.
        Returns:
        This builder for chaining.

      • clearTimestamp

        public ReadSessionRequest.Builder clearTimestamp()
         Timestamp.
        uint64 timestamp = 5;
        Returns:
        This builder for chaining.

      • hasTailOffset

        public boolean hasTailOffset()
         Number of records before the tail, i.e. the next sequence number.
        uint64 tail_offset = 6;
        Specified by:
        hasTailOffset in interface ReadSessionRequestOrBuilder
        Returns:
        Whether the tailOffset field is set.

      • getTailOffset

        public long getTailOffset()
         Number of records before the tail, i.e. the next sequence number.
        uint64 tail_offset = 6;
        Specified by:
        getTailOffset in interface ReadSessionRequestOrBuilder
        Returns:
        The tailOffset.

      • setTailOffset

        public ReadSessionRequest.Builder setTailOffset​(long value)
         Number of records before the tail, i.e. the next sequence number.
        uint64 tail_offset = 6;
        Parameters:
        value - The tailOffset to set.
        Returns:
        This builder for chaining.

      • clearTailOffset

        public ReadSessionRequest.Builder clearTailOffset()
         Number of records before the tail, i.e. the next sequence number.
        uint64 tail_offset = 6;
        Returns:
        This builder for chaining.

      • hasLimit

        public boolean hasLimit()
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;
        Specified by:
        hasLimit in interface ReadSessionRequestOrBuilder
        Returns:
        Whether the limit field is set.

      • getLimit

        public ReadLimit getLimit()
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;
        Specified by:
        getLimit in interface ReadSessionRequestOrBuilder
        Returns:
        The limit.

      • setLimit

        public ReadSessionRequest.Builder setLimit​(ReadLimit value)
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;

      • setLimit

        public ReadSessionRequest.Builder setLimit​(ReadLimit.Builder builderForValue)
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;

      • mergeLimit

        public ReadSessionRequest.Builder mergeLimit​(ReadLimit value)
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;

      • clearLimit

        public ReadSessionRequest.Builder clearLimit()
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;

      • getLimitBuilder

        public ReadLimit.Builder getLimitBuilder()
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;

      • getLimitOrBuilder

        public ReadLimitOrBuilder getLimitOrBuilder()
         Limit on how many records can be returned. When a limit is specified, the session will be terminated as soon as
 the limit is met, or when the current tail of the stream is reached -- whichever occurs first.
 If no limit is specified, the session will remain open after catching up to the tail, and continue tailing as
 new messages are written to the stream.
        .s2.v1alpha.ReadLimit limit = 3;
        Specified by:
        getLimitOrBuilder in interface ReadSessionRequestOrBuilder

      • getHeartbeats

        public boolean getHeartbeats()
         Heartbeats can be enabled to monitor end-to-end session health.
 A heartbeat will be sent when the initial switch to real-time tailing happens,
 as well as when no records are available at a randomized interval between 5 and 15 seconds.
        bool heartbeats = 4;
        Specified by:
        getHeartbeats in interface ReadSessionRequestOrBuilder
        Returns:
        The heartbeats.

      • setHeartbeats

        public ReadSessionRequest.Builder setHeartbeats​(boolean value)
         Heartbeats can be enabled to monitor end-to-end session health.
 A heartbeat will be sent when the initial switch to real-time tailing happens,
 as well as when no records are available at a randomized interval between 5 and 15 seconds.
        bool heartbeats = 4;
        Parameters:
        value - The heartbeats to set.
        Returns:
        This builder for chaining.

      • clearHeartbeats

        public ReadSessionRequest.Builder clearHeartbeats()
         Heartbeats can be enabled to monitor end-to-end session health.
 A heartbeat will be sent when the initial switch to real-time tailing happens,
 as well as when no records are available at a randomized interval between 5 and 15 seconds.
        bool heartbeats = 4;
        Returns:
        This builder for chaining.

      • hasUntil

        public boolean hasUntil()
         Exclusive timestamp to read until.
 If provided, this is applied as an additional constraint on top of the `limit`,
 and will guarantee that all records returned have timestamps < the provided `until`.
        optional uint64 until = 7;
        Specified by:
        hasUntil in interface ReadSessionRequestOrBuilder
        Returns:
        Whether the until field is set.

      • getUntil

        public long getUntil()
         Exclusive timestamp to read until.
 If provided, this is applied as an additional constraint on top of the `limit`,
 and will guarantee that all records returned have timestamps < the provided `until`.
        optional uint64 until = 7;
        Specified by:
        getUntil in interface ReadSessionRequestOrBuilder
        Returns:
        The until.

      • setUntil

        public ReadSessionRequest.Builder setUntil​(long value)
         Exclusive timestamp to read until.
 If provided, this is applied as an additional constraint on top of the `limit`,
 and will guarantee that all records returned have timestamps < the provided `until`.
        optional uint64 until = 7;
        Parameters:
        value - The until to set.
        Returns:
        This builder for chaining.

      • clearUntil

        public ReadSessionRequest.Builder clearUntil()
         Exclusive timestamp to read until.
 If provided, this is applied as an additional constraint on top of the `limit`,
 and will guarantee that all records returned have timestamps < the provided `until`.
        optional uint64 until = 7;
        Returns:
        This builder for chaining.