public abstract static class CommandCompletionServiceGrpc.CommandCompletionServiceImplBase
extends java.lang.Object
implements io.grpc.BindableService
Allows clients to observe the status of their submissions. Commands may be submitted via the Command Submission Service. The on-ledger effects of their submissions are disclosed by the Transaction Service. Commands may fail in 2 distinct manners: 1. Failure communicated in the gRPC error of the submission. 2. Failure communicated in a Completion. Only successfully submitted commands may produce a completion event. Clients that do not receive a successful completion about their submission MUST NOT assume that it was successful. Clients SHOULD subscribe to the CompletionStream before starting to submit commands to prevent race conditions.
Constructor and Description |
---|
CommandCompletionServiceImplBase() |
Modifier and Type | Method and Description |
---|---|
io.grpc.ServerServiceDefinition |
bindService() |
void |
completionEnd(CommandCompletionServiceOuterClass.CompletionEndRequest request,
io.grpc.stub.StreamObserver<CommandCompletionServiceOuterClass.CompletionEndResponse> responseObserver)
Returns the offset after the latest completion.
|
void |
completionStream(CommandCompletionServiceOuterClass.CompletionStreamRequest request,
io.grpc.stub.StreamObserver<CommandCompletionServiceOuterClass.CompletionStreamResponse> responseObserver)
Subscribe to command completion events.
|
public void completionStream(CommandCompletionServiceOuterClass.CompletionStreamRequest request, io.grpc.stub.StreamObserver<CommandCompletionServiceOuterClass.CompletionStreamResponse> responseObserver)
Subscribe to command completion events. Errors: - ``UNAUTHENTICATED``: if the request does not include a valid access token - ``PERMISSION_DENIED``: if the claims in the token are insufficient to perform a given operation - ``NOT_FOUND``: if the request does not include a valid ledger id or if the ledger has been pruned before ``begin`` - ``INVALID_ARGUMENT``: if the payload is malformed or is missing required fields - ``OUT_OF_RANGE``: if the absolute offset is not before the end of the ledger
public void completionEnd(CommandCompletionServiceOuterClass.CompletionEndRequest request, io.grpc.stub.StreamObserver<CommandCompletionServiceOuterClass.CompletionEndResponse> responseObserver)
Returns the offset after the latest completion. Errors: - ``UNAUTHENTICATED``: if the request does not include a valid access token - ``PERMISSION_DENIED``: if the claims in the token are insufficient to perform a given operation - ``NOT_FOUND``: if the request does not include a valid ledger id
public final io.grpc.ServerServiceDefinition bindService()
bindService
in interface io.grpc.BindableService