Documentation
¶
Index ¶
- type Conn
- type Transport
- func (t *Transport) Close()
- func (t *Transport) Handle(path string, group string, handler func([]byte, func([]byte))) error
- func (t *Transport) IsOpen() bool
- func (t *Transport) Listen(callback func())
- func (t *Transport) OnClose(handler interface{})
- func (t *Transport) Publish(topic string, data []byte) error
- func (t *Transport) Request(path string, payload []byte, timeOut int) ([]byte, error)
- func (t *Transport) Subscribe(topic string, group string, handler func([]byte)) error
- func (t *Transport) SubscribeForRawMsg(topic string, group string, handler func(interface{})) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Transport ¶
type Transport struct {
// contains filtered or unexported fields
}
Transport object
func (*Transport) OnClose ¶
func (t *Transport) OnClose(handler interface{})
OnClose adds a handler to NATS close event
Source Files
Click to show internal directories.
Click to hide internal directories.