Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientInterface ¶
type ClientInterface interface { Subscribe(subj string, cb MsgHandler) (NatsSubscriptionInterface, error) QueueSubscribe(subj, queue string, cb MsgHandler) (NatsSubscriptionInterface, error) Publish(subj string, data []byte) error LastError() error Flush() error SubscribeSync(reply string) (NatsSubscriptionInterface, error) PublishRequest(subj string, reply string, data []byte) error }
func Connect ¶
func Connect(natsURL string) (ClientInterface, error)
type MsgHandler ¶
type MsgHandler func(*Msg)
Click to show internal directories.
Click to hide internal directories.