NewJsonRpcErr creates new JSON-RPC error.

NewNexusConn creates new nexus connection from net.conn.

NewTask creates a new task with the provided Nexus connection.

CountOpts represents the common options when requesting a count.

ListOpts represents the common options when requesting a list.

Msg represents a pipe single message.

NexusConn represents the Nexus connection.

Pipe represents a pipe.

PipeData represents a pipe messages group obtained in read ops.

PipeOpts represents pipe creation options.

Task represents a task pushed to Nexus.

TaskOpts represents task push options.

TopicData represents a topic messages group obtained in read ops.

TopicMsg represents a single topic message.