Package sourcemock is a generated GoMock package.

Source_ServiceDesc is the grpc.ServiceDesc for Source service.

AckRequest is the request for acknowledging datum.

AckResponse is the response for acknowledging datum.

Offset is the offset of the datum.

PartitionsResponse is the response for the partitions request.

PendingResponse is the response for the pending request.

ReadRequest is the request for reading datum stream from user defined source.

ReadResponse is the response for reading datum stream from user defined source.

ReadyResponse is the health check result for user defined source.

UnimplementedSourceServer must be embedded to have forward compatible implementations.

SourceClient is the client API for Source service.

SourceServer is the server API for Source service.

UnsafeSourceServer may be embedded to opt out of forward compatibility for this service.