Documentation ¶
Index ¶
- type Broker
- func (h *Broker) GetTimeout() time.Duration
- func (h *Broker) GetVersion() string
- func (h *Broker) MessageLogger(f func(m *nats.Msg)) func(m *nats.Msg)
- func (h *Broker) Parse(m *nats.Msg, e interface{}) (*Container, error)
- func (h *Broker) Publish(message string, rid string, in interface{}) error
- func (h *Broker) RID(r *http.Request) string
- func (h *Broker) Reply(m *nats.Msg, rid string, e interface{})
- func (h *Broker) Request(message string, rid string, in, out interface{}) (*Container, error)
- func (h *Broker) WriteCode(message string, rid string, code int, e interface{})
- func (h *Broker) WriteErrorCode(message string, rid string, code int, err error)
- type Container
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
func (*Broker) GetTimeout ¶
func (*Broker) GetVersion ¶
func (*Broker) MessageLogger ¶
func (h *Broker) MessageLogger(f func(m *nats.Msg)) func(m *nats.Msg)
Click to show internal directories.
Click to hide internal directories.