NewCloseRequest returns a new close request.

NewConsumeRequest creates and returns a new consume request.

NewConsumeResponse creates and returns a new consume response.

NewControlResponse creates and returns a new control response.

NewErrorResponse creates and returns a new Error response.

NewOpenRequest returns a new open request.

NewPublishRequest returns a new publish request.

NewPublishResponse creates and returns a new publish response.

NewRequestFromBytes creates a new Request out of a payload in bytes.

NewResponseFromBytes creates a new Response from supplied []byte.

ConsumeMessage represents a message received from the server in a consume response.

ConsumeParams represents the params of a consume request.

ConsumeResult represents the result of a consume request.

ControlResult represents the result of a control request.

Error represents a jsonrpc error.

PublishParams represents the params of a publish request.

PublishResult represents the result of a publish request.

Request represents a jsonrpc request.

Response represents a jsonrpc response.

Method represents a jsonrpc method call.