usrv

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

type Handler func(req, res Message)

type Logger interface {
	Trace(msg string, args ...interface{})
	Debug(msg string, args ...interface{})
	Info(msg string, args ...interface{})
	Warn(msg string, args ...interface{}) error
	Error(msg string, args ...interface{}) error
	Fatal(msg string, args ...interface{})
}

type Message interface {
	From() string
	To() string
	Property() Property
	CorrelationId() string

	Content() ([]byte, error)
	SetContent([]byte, error)
}

type Property map[string]string

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

type Transport interface {

	// Attach a logger to the transport.
	SetLogger(logger Logger)

	// Configure the transport.
	Config(params map[string]string) error

	// Close the transport.
	Close() error

	// Bind service endpoint. Returns a channel that emits incoming Messages to that endpoint
	Bind(service string, endpoint string) (<-chan Message, error)

	// Send a message.
	Send(message Message, timeout time.Duration, expectReply bool) <-chan Message

	// Create a message to be delivered to a target endpoint
	MessageTo(from string, toService string, toEndpoint string) Message

	// Create a message that serves as a reply to an incoming message
	ReplyTo(message Message) Message
}