Documentation
¶
Index ¶
- type HttpConfig
- type HttpTransport
- func (t *HttpTransport) Bind(service string, endpoint string) (<-chan usrv.Message, error)
- func (t *HttpTransport) Close() error
- func (t *HttpTransport) Config(params map[string]string) error
- func (t *HttpTransport) MessageTo(from string, toService string, toEndpoint string) usrv.Message
- func (t *HttpTransport) ReplyTo(msg usrv.Message) usrv.Message
- func (t *HttpTransport) Send(m usrv.Message, timeout time.Duration, expectReply bool) <-chan usrv.Message
- func (t *HttpTransport) SetLogger(logger usrv.Logger)
- type InMemTransport
- func (t *InMemTransport) Bind(service string, endpoint string) (<-chan usrv.Message, error)
- func (t *InMemTransport) Close() error
- func (t *InMemTransport) Config(params map[string]string) error
- func (t *InMemTransport) MessageTo(from string, toService string, toEndpoint string) usrv.Message
- func (t *InMemTransport) ReplyTo(msg usrv.Message) usrv.Message
- func (t *InMemTransport) Send(m usrv.Message, timeout time.Duration, expectReply bool) <-chan usrv.Message
- func (t *InMemTransport) SetLogger(logger usrv.Logger)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HttpConfig ¶
func NewHttpConfig ¶
func NewHttpConfig(serverPort int) HttpConfig
func NewHttpsConfig ¶
func NewHttpsConfig(serverPort int, certFile, certKeyFile string) HttpConfig
type HttpTransport ¶
type HttpTransport struct {
// A mutex for synchronized access to the server instance
sync.Mutex
// contains filtered or unexported fields
}
func NewHttp ¶
func NewHttp() *HttpTransport
func (*HttpTransport) Close ¶
func (t *HttpTransport) Close() error
func (*HttpTransport) SetLogger ¶
func (t *HttpTransport) SetLogger(logger usrv.Logger)
type InMemTransport ¶
type InMemTransport struct {
// contains filtered or unexported fields
}
func NewInMemory ¶
func NewInMemory() *InMemTransport
func (*InMemTransport) Close ¶
func (t *InMemTransport) Close() error
func (*InMemTransport) SetLogger ¶
func (t *InMemTransport) SetLogger(logger usrv.Logger)
Source Files
Click to show internal directories.
Click to hide internal directories.