Documentation ¶
Index ¶
- type Nats
- func (n *Nats) Connect() error
- func (n *Nats) Init(cfg structs.NatsConfig) *Nats
- func (n *Nats) SendAwaitResponse(channel string, message *messages.Message) (*messages.Message, error)
- func (n *Nats) SendAwaitResponseMulti(channel string, message *messages.Message) ([]*messages.Message, error)
- func (n *Nats) SendAwaitResponseMultiSingle(channel string, message *messages.Message) ([]*messages.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Nats ¶
type Nats struct { Config structs.NatsConfig Conn *nats.Conn EncodedConn *nats.EncodedConn Error error }
func (*Nats) SendAwaitResponse ¶
func (*Nats) SendAwaitResponseMulti ¶
Click to show internal directories.
Click to hide internal directories.