EventProcessorInstance.Builder |
EventProcessorInstance.Builder.addAllClaimedSegment(Iterable<? extends EventProcessorSegment> values) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.addClaimedSegment(int index,
EventProcessorSegment value) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.addClaimedSegment(int index,
EventProcessorSegment.Builder builderForValue) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.addClaimedSegment(EventProcessorSegment value) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.addClaimedSegment(EventProcessorSegment.Builder builderForValue) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessor.Builder.addClientInstanceBuilder() |
client instances that subscribed the event processor
|
EventProcessorInstance.Builder |
EventProcessor.Builder.addClientInstanceBuilder(int index) |
client instances that subscribed the event processor
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.clear() |
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.clearClaimedSegment() |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.clearClientId() |
the client identifier
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.clearIsRunning() |
true if the client instance of the event processor is running, false otherwise
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.clearMaxCapacity() |
the max number of segments that this client can claim
|
EventProcessorInstance.Builder |
EventProcessor.Builder.getClientInstanceBuilder(int index) |
client instances that subscribed the event processor
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.mergeFrom(com.google.protobuf.Message other) |
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.mergeFrom(EventProcessorInstance other) |
|
static EventProcessorInstance.Builder |
EventProcessorInstance.newBuilder() |
|
static EventProcessorInstance.Builder |
EventProcessorInstance.newBuilder(EventProcessorInstance prototype) |
|
EventProcessorInstance.Builder |
EventProcessorInstance.newBuilderForType() |
|
protected EventProcessorInstance.Builder |
EventProcessorInstance.newBuilderForType(com.google.protobuf.AbstractMessage.BuilderParent parent) |
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.removeClaimedSegment(int index) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setClaimedSegment(int index,
EventProcessorSegment value) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setClaimedSegment(int index,
EventProcessorSegment.Builder builderForValue) |
status of all segments claimed by the client
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setClientId(String value) |
the client identifier
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setClientIdBytes(com.google.protobuf.ByteString value) |
the client identifier
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setIsRunning(boolean value) |
true if the client instance of the event processor is running, false otherwise
|
EventProcessorInstance.Builder |
EventProcessorInstance.Builder.setMaxCapacity(int value) |
the max number of segments that this client can claim
|
EventProcessorInstance.Builder |
EventProcessorInstance.toBuilder() |
|