rpc

type Client struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Envelope struct {
	// method to call on the server side
	Method string `json:"m,omitempty"`
	// nsq topic to send reply to
	ReplyTo string `json:"r,omitempty"`
	// connection between request and response
	CorrelationID uint32 `json:"c,omitempty"`
	// unix timestamp when message expires, after that should be dropped
	ExpiresAt int64 `json:"x,omitempty"`
	// applicationn error reponse, if server side failed and Body is missing
	Error string `json:"e,omitempty"`
	// message body
	Body []byte `json:"-"`
}

type Server struct {
	// contains filtered or unexported fields
}