Package | Description |
---|---|
org.apache.hedwig.protocol |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addAllRemoteComponents(Iterable<? extends PubSubProtocol.RegionSpecificSeqId> values)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addRemoteComponents(int index,
PubSubProtocol.RegionSpecificSeqId.Builder builderForValue)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addRemoteComponents(int index,
PubSubProtocol.RegionSpecificSeqId value)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addRemoteComponents(PubSubProtocol.RegionSpecificSeqId.Builder builderForValue)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addRemoteComponents(PubSubProtocol.RegionSpecificSeqId value)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clear() |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clearLocalComponent()
optional uint64 localComponent = 1; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clearRemoteComponents()
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.clone() |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.LedgerRange.Builder.getEndSeqIdIncludedBuilder()
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.Message.Builder.getMsgIdBuilder()
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.ConsumeRequest.Builder.getMsgIdBuilder()
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.SubscriptionState.Builder.getMsgIdBuilder()
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.PublishResponse.Builder.getPublishedMsgIdBuilder()
If the request was a publish request, this was the message Id of the published message.
|
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.mergeFrom(com.google.protobuf.Message other) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.mergeFrom(PubSubProtocol.MessageSeqId other) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.newBuilder() |
static PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.newBuilder(PubSubProtocol.MessageSeqId prototype) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.newBuilderForType() |
protected PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.removeRemoteComponents(int index)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setLocalComponent(long value)
optional uint64 localComponent = 1; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setRemoteComponents(int index,
PubSubProtocol.RegionSpecificSeqId.Builder builderForValue)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setRemoteComponents(int index,
PubSubProtocol.RegionSpecificSeqId value)
repeated .Hedwig.RegionSpecificSeqId remoteComponents = 2; |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
PubSubProtocol.MessageSeqId.Builder |
PubSubProtocol.MessageSeqId.toBuilder() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.LedgerRange.Builder |
PubSubProtocol.LedgerRange.Builder.setEndSeqIdIncluded(PubSubProtocol.MessageSeqId.Builder builderForValue)
optional .Hedwig.MessageSeqId endSeqIdIncluded = 2; |
PubSubProtocol.Message.Builder |
PubSubProtocol.Message.Builder.setMsgId(PubSubProtocol.MessageSeqId.Builder builderForValue)
optional .Hedwig.MessageSeqId msgId = 3; |
PubSubProtocol.ConsumeRequest.Builder |
PubSubProtocol.ConsumeRequest.Builder.setMsgId(PubSubProtocol.MessageSeqId.Builder builderForValue)
the msgId is cumulative: all messages up to this id are marked as consumed
|
PubSubProtocol.SubscriptionState.Builder |
PubSubProtocol.SubscriptionState.Builder.setMsgId(PubSubProtocol.MessageSeqId.Builder builderForValue)
required .Hedwig.MessageSeqId msgId = 1; |
PubSubProtocol.PublishResponse.Builder |
PubSubProtocol.PublishResponse.Builder.setPublishedMsgId(PubSubProtocol.MessageSeqId.Builder builderForValue)
If the request was a publish request, this was the message Id of the published message.
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.