protocol

type Cmd struct {

	// The name of the command
	Name string

	// The argument line, following the commandName
	Arg string

	// The header line, if the command has one
	HeaderJSON string

	// The command payload, if the command has such
	Body []byte
}

type Message struct {

	// The sequenceId of the message, which is given by the
	// server an is strictly monotonically increasing at least within a root topic.
	ID uint64

	// The topic path
	Path Path

	// The user id of the message sender
	UserID string

	// The id of the sending application
	ApplicationID string

	// Filters applied to this message. The message will be sent only to the
	// routes that match the filters
	Filters map[string]string

	// The time of publishing, as Unix Timestamp date
	Time int64

	// The header line of the message (optional). If set, then it has to be a valid JSON object structure.
	HeaderJSON string

	// The message payload
	Body []byte

	// Used in cluster mode to identify a guble node
	NodeID uint8
}

type MessageDeliveryCallback func(*Message)

type NotificationMessage struct {

	// The name of the message
	Name string

	// The argument line, following the messageName
	Arg string

	// The optional json data supplied with the message
	Json string

	// Flag which indicates, if the notification is an error
	IsError bool
}

type Path string