NewAuthShufflerClient returns a ShufflerClient which uses the Authorizer to obtain and attach an Authorization bearer token to every issued request.

NewVerifiedShufflerServer adapts an AuthShufflerServer into a ShufflerServer by using the provided Verifier to verify incoming request Authorizations.

The connector has exited, but cannot be restarted yet.

The connector is running but has produced no data.

The poll succeeded and a transaction will be drained.

The connector has exited and new session should be started.

Container is a description of a running connector container.

IndexedShuffleResponse is an implementation of message.Message which indexes a specific document within a ShuffleResponse.

ShuffleRequest is the request message of a Shuffle RPC.

ShuffleResponse is the streamed response message of a Shuffle RPC.

UnimplementedCombinerServer can be embedded to have forward compatible implementations.

UnimplementedShufflerServer can be embedded to have forward compatible implementations.

AuthShufflerServer is similar to ShufflerServer except: - Requests have already been verified with accompanying Claims.

CombinerClient is the client API for Combiner service.

CombinerServer is the server API for Combiner service.

ShufflerClient is the client API for Shuffler service.

ShufflerServer is the server API for Shuffler service.