NewServer creates a new sinkServer object.

ResponseFailure creates a failed Response with the given id and error message.

ResponseFallback creates a Response with the Fallback field set to true.

ResponseOK creates a successful Response with the given id.

ResponsesBuilder returns an empty instance of Responses.

WithMaxMessageSize sets the sinkServer max receive message size and the sinkServer max send message size to the given size.

WithServerInfoFilePath sets the sinkServer info file path.

WithSockAddr start the sinkServer with the given sock addr.

Response is the processing result of each message.

Service implements the proto gen server interface and contains the sinkfn operation handler.

Datum is the interface of incoming message payload for sink function.

Sinker is the interface of sink function implementation.

Option is the interface to apply options.

SinkerFunc is utility type used to convert a Sink function to a Sinker.