Package mxaccess_gateway.v1
Class MxaccessGateway.ReplayGap.Builder
java.lang.Object
com.google.protobuf.AbstractMessageLite.Builder
com.google.protobuf.AbstractMessage.Builder<BuilderT>
com.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
mxaccess_gateway.v1.MxaccessGateway.ReplayGap.Builder
- All Implemented Interfaces:
com.google.protobuf.Message.Builder,com.google.protobuf.MessageLite.Builder,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Cloneable,MxaccessGateway.ReplayGapOrBuilder
- Enclosing class:
- MxaccessGateway.ReplayGap
public static final class MxaccessGateway.ReplayGap.Builder
extends com.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
implements MxaccessGateway.ReplayGapOrBuilder
Reconnect-replay gap signal carried by a sentinel MxEvent (MxEvent.replay_gap) when a client resumes StreamEvents via after_worker_sequence but the requested sequence predates the oldest event still held in the session replay ring. The events in the open interval (requested_after_sequence, oldest_available_sequence) were evicted from the ring and cannot be replayed, so the client must re-snapshot rather than assume a contiguous event history.Protobuf type
mxaccess_gateway.v1.ReplayGap-
Method Summary
Modifier and TypeMethodDescriptionbuild()clear()The oldest worker_sequence still retained in the replay ring and available for replay.The worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).static final com.google.protobuf.Descriptors.Descriptorcom.google.protobuf.Descriptors.DescriptorlongThe oldest worker_sequence still retained in the replay ring and available for replay.longThe worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).protected com.google.protobuf.GeneratedMessage.FieldAccessorTablefinal booleanmergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) mergeFrom(com.google.protobuf.Message other) setOldestAvailableSequence(long value) The oldest worker_sequence still retained in the replay ring and available for replay.setRequestedAfterSequence(long value) The worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).Methods inherited from class com.google.protobuf.GeneratedMessage.Builder
addRepeatedField, clearField, clearOneof, clone, getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, getUnknownFieldSetBuilder, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, internalGetMutableMapField, internalGetMutableMapFieldReflection, isClean, markClean, mergeUnknownFields, mergeUnknownLengthDelimitedField, mergeUnknownVarintField, newBuilderForField, onBuilt, onChanged, parseUnknownField, setField, setRepeatedField, setUnknownFields, setUnknownFieldSetBuilder, setUnknownFieldsProto3Methods inherited from class com.google.protobuf.AbstractMessage.Builder
findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite.Builder
addAll, addAll, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, newUninitializedMessageExceptionMethods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.Message.Builder
mergeDelimitedFrom, mergeDelimitedFromMethods inherited from interface com.google.protobuf.MessageLite.Builder
mergeFromMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Method Details
-
getDescriptor
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() -
internalGetFieldAccessorTable
protected com.google.protobuf.GeneratedMessage.FieldAccessorTable internalGetFieldAccessorTable()- Specified by:
internalGetFieldAccessorTablein classcom.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
-
clear
- Specified by:
clearin interfacecom.google.protobuf.Message.Builder- Specified by:
clearin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
clearin classcom.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
-
getDescriptorForType
public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.Message.Builder- Specified by:
getDescriptorForTypein interfacecom.google.protobuf.MessageOrBuilder- Overrides:
getDescriptorForTypein classcom.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-
build
- Specified by:
buildin interfacecom.google.protobuf.Message.Builder- Specified by:
buildin interfacecom.google.protobuf.MessageLite.Builder
-
buildPartial
- Specified by:
buildPartialin interfacecom.google.protobuf.Message.Builder- Specified by:
buildPartialin interfacecom.google.protobuf.MessageLite.Builder
-
mergeFrom
- Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<MxaccessGateway.ReplayGap.Builder>
-
mergeFrom
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage.Builder<MxaccessGateway.ReplayGap.Builder>
-
mergeFrom
public MxaccessGateway.ReplayGap.Builder mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Specified by:
mergeFromin interfacecom.google.protobuf.Message.Builder- Specified by:
mergeFromin interfacecom.google.protobuf.MessageLite.Builder- Overrides:
mergeFromin classcom.google.protobuf.AbstractMessage.Builder<MxaccessGateway.ReplayGap.Builder>- Throws:
IOException
-
getRequestedAfterSequence
public long getRequestedAfterSequence()The worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).
uint64 requested_after_sequence = 1;- Specified by:
getRequestedAfterSequencein interfaceMxaccessGateway.ReplayGapOrBuilder- Returns:
- The requestedAfterSequence.
-
setRequestedAfterSequence
The worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).
uint64 requested_after_sequence = 1;- Parameters:
value- The requestedAfterSequence to set.- Returns:
- This builder for chaining.
-
clearRequestedAfterSequence
The worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).
uint64 requested_after_sequence = 1;- Returns:
- This builder for chaining.
-
getOldestAvailableSequence
public long getOldestAvailableSequence()The oldest worker_sequence still retained in the replay ring and available for replay. Events with worker_sequence in the open interval (requested_after_sequence, oldest_available_sequence) were evicted and are unrecoverable. oldest_available_sequence itself IS still retained: a client that wishes to resume without incurring another gap MUST set after_worker_sequence = oldest_available_sequence - 1 in the next StreamEventsRequest, which will cause the server to replay starting at oldest_available_sequence (the first retained event).
uint64 oldest_available_sequence = 2;- Specified by:
getOldestAvailableSequencein interfaceMxaccessGateway.ReplayGapOrBuilder- Returns:
- The oldestAvailableSequence.
-
setOldestAvailableSequence
The oldest worker_sequence still retained in the replay ring and available for replay. Events with worker_sequence in the open interval (requested_after_sequence, oldest_available_sequence) were evicted and are unrecoverable. oldest_available_sequence itself IS still retained: a client that wishes to resume without incurring another gap MUST set after_worker_sequence = oldest_available_sequence - 1 in the next StreamEventsRequest, which will cause the server to replay starting at oldest_available_sequence (the first retained event).
uint64 oldest_available_sequence = 2;- Parameters:
value- The oldestAvailableSequence to set.- Returns:
- This builder for chaining.
-
clearOldestAvailableSequence
The oldest worker_sequence still retained in the replay ring and available for replay. Events with worker_sequence in the open interval (requested_after_sequence, oldest_available_sequence) were evicted and are unrecoverable. oldest_available_sequence itself IS still retained: a client that wishes to resume without incurring another gap MUST set after_worker_sequence = oldest_available_sequence - 1 in the next StreamEventsRequest, which will cause the server to replay starting at oldest_available_sequence (the first retained event).
uint64 oldest_available_sequence = 2;- Returns:
- This builder for chaining.
-