Package mxaccess_gateway.v1
Class MxaccessGateway.ReplayGap
java.lang.Object
com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessage
com.google.protobuf.GeneratedMessage
mxaccess_gateway.v1.MxaccessGateway.ReplayGap
- All Implemented Interfaces:
com.google.protobuf.Message,com.google.protobuf.MessageLite,com.google.protobuf.MessageLiteOrBuilder,com.google.protobuf.MessageOrBuilder,Serializable,MxaccessGateway.ReplayGapOrBuilder
- Enclosing class:
- MxaccessGateway
public static final class MxaccessGateway.ReplayGap
extends com.google.protobuf.GeneratedMessage
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- See Also:
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classReconnect-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.Nested classes/interfaces inherited from class com.google.protobuf.GeneratedMessage
com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>,BuilderT extends com.google.protobuf.GeneratedMessage.ExtendableBuilder<MessageT, BuilderT>>, com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.ExtendableMessageOrBuilder<MessageT extends com.google.protobuf.GeneratedMessage.ExtendableMessage<MessageT>>, com.google.protobuf.GeneratedMessage.FieldAccessorTable, com.google.protobuf.GeneratedMessage.GeneratedExtension<ContainingT extends com.google.protobuf.Message, T extends Object>, com.google.protobuf.GeneratedMessage.UnusedPrivateParameter Nested classes/interfaces inherited from class com.google.protobuf.AbstractMessage
com.google.protobuf.AbstractMessage.BuilderParentNested classes/interfaces inherited from class com.google.protobuf.AbstractMessageLite
com.google.protobuf.AbstractMessageLite.InternalOneOfEnum -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final intstatic final intFields inherited from class com.google.protobuf.GeneratedMessage
alwaysUseFieldBuilders, loggedPre22TypeNames, unknownFieldsFields inherited from class com.google.protobuf.AbstractMessage
memoizedSizeFields inherited from class com.google.protobuf.AbstractMessageLite
memoizedHashCode -
Method Summary
Modifier and TypeMethodDescriptionbooleanstatic MxaccessGateway.ReplayGapstatic final com.google.protobuf.Descriptors.DescriptorlongThe oldest worker_sequence still retained in the replay ring and available for replay.com.google.protobuf.Parser<MxaccessGateway.ReplayGap>longThe worker_sequence the client asked to resume after (StreamEventsRequest.after_worker_sequence).intinthashCode()protected com.google.protobuf.GeneratedMessage.FieldAccessorTablefinal booleannewBuilder(MxaccessGateway.ReplayGap prototype) protected MxaccessGateway.ReplayGap.BuildernewBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) static MxaccessGateway.ReplayGapparseDelimitedFrom(InputStream input) static MxaccessGateway.ReplayGapparseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static MxaccessGateway.ReplayGapparseFrom(byte[] data) static MxaccessGateway.ReplayGapparseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static MxaccessGateway.ReplayGapparseFrom(com.google.protobuf.ByteString data) static MxaccessGateway.ReplayGapparseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static MxaccessGateway.ReplayGapparseFrom(com.google.protobuf.CodedInputStream input) static MxaccessGateway.ReplayGapparseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static MxaccessGateway.ReplayGapparseFrom(InputStream input) static MxaccessGateway.ReplayGapparseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static MxaccessGateway.ReplayGapparseFrom(ByteBuffer data) static MxaccessGateway.ReplayGapparseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) static com.google.protobuf.Parser<MxaccessGateway.ReplayGap>parser()voidwriteTo(com.google.protobuf.CodedOutputStream output) Methods inherited from class com.google.protobuf.GeneratedMessage
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMapFieldReflection, isStringEmpty, makeExtensionsImmutable, makeMutableCopy, makeMutableCopy, mergeFromAndMakeImmutableInternal, newFileScopedGeneratedExtension, newInstance, newMessageScopedGeneratedExtension, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTagMethods inherited from class com.google.protobuf.AbstractMessage
findInitializationErrors, getInitializationErrorString, hashFields, toStringMethods inherited from class com.google.protobuf.AbstractMessageLite
addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface com.google.protobuf.MessageLite
toByteArray, toByteString, writeDelimitedTo, writeToMethods inherited from interface com.google.protobuf.MessageOrBuilder
findInitializationErrors, getAllFields, getDescriptorForType, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof
-
Field Details
-
REQUESTED_AFTER_SEQUENCE_FIELD_NUMBER
public static final int REQUESTED_AFTER_SEQUENCE_FIELD_NUMBER- See Also:
-
OLDEST_AVAILABLE_SEQUENCE_FIELD_NUMBER
public static final int OLDEST_AVAILABLE_SEQUENCE_FIELD_NUMBER- See Also:
-
-
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
-
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.
-
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.
-
isInitialized
public final boolean isInitialized()- Specified by:
isInitializedin interfacecom.google.protobuf.MessageLiteOrBuilder- Overrides:
isInitializedin classcom.google.protobuf.GeneratedMessage
-
writeTo
- Specified by:
writeToin interfacecom.google.protobuf.MessageLite- Overrides:
writeToin classcom.google.protobuf.GeneratedMessage- Throws:
IOException
-
getSerializedSize
public int getSerializedSize()- Specified by:
getSerializedSizein interfacecom.google.protobuf.MessageLite- Overrides:
getSerializedSizein classcom.google.protobuf.GeneratedMessage
-
equals
- Specified by:
equalsin interfacecom.google.protobuf.Message- Overrides:
equalsin classcom.google.protobuf.AbstractMessage
-
hashCode
public int hashCode()- Specified by:
hashCodein interfacecom.google.protobuf.Message- Overrides:
hashCodein classcom.google.protobuf.AbstractMessage
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException - Throws:
com.google.protobuf.InvalidProtocolBufferException
-
parseFrom
- Throws:
IOException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseDelimitedFrom
- Throws:
IOException
-
parseDelimitedFrom
public static MxaccessGateway.ReplayGap parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(com.google.protobuf.CodedInputStream input) throws IOException - Throws:
IOException
-
parseFrom
public static MxaccessGateway.ReplayGap parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException - Throws:
IOException
-
newBuilderForType
- Specified by:
newBuilderForTypein interfacecom.google.protobuf.Message- Specified by:
newBuilderForTypein interfacecom.google.protobuf.MessageLite
-
newBuilder
-
newBuilder
-
toBuilder
- Specified by:
toBuilderin interfacecom.google.protobuf.Message- Specified by:
toBuilderin interfacecom.google.protobuf.MessageLite
-
newBuilderForType
protected MxaccessGateway.ReplayGap.Builder newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) - Overrides:
newBuilderForTypein classcom.google.protobuf.AbstractMessage
-
getDefaultInstance
-
parser
-
getParserForType
- Specified by:
getParserForTypein interfacecom.google.protobuf.Message- Specified by:
getParserForTypein interfacecom.google.protobuf.MessageLite- Overrides:
getParserForTypein classcom.google.protobuf.GeneratedMessage
-
getDefaultInstanceForType
- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageLiteOrBuilder- Specified by:
getDefaultInstanceForTypein interfacecom.google.protobuf.MessageOrBuilder
-