cherryNats

Index ¶

• Constants
• func GetNatsMsg() *nats.Msg
• func NewReqID() uint64
• func NewStringReqID() string
• func PoolClose()
• func Publish(subject string, data []byte) error
• func PublishMsg(msg *nats.Msg) error
• func ReleaseNatsMsg(natsMsg *nats.Msg)
• func ReplySync(reqID, reply string, data []byte) error
• func Request(subject string, data []byte, timeout ...time.Duration) ([]byte, error)
• func RequestSync(reqID, subject string, data []byte, timeout ...time.Duration) ([]byte, error)
• func Subscribe(subject string, cb nats.MsgHandler) error
• type Connect
• • func NewConnect(id int, replySubject string, opts ...OptionFunc) *Connect
• • func (p *Connect) Address() string
  • func (p *Connect) Close()
  • func (p *Connect) Connect()
  • func (p *Connect) GetID() int
  • func (p *Connect) MaxReconnects() int
  • func (p *Connect) QueueSubscribe(subject, queue string, cb nats.MsgHandler) error
  • func (p *Connect) ReconnectDelay() time.Duration
  • func (p *Connect) ReplySync(reqID, reply string, data []byte) error
  • func (p *Connect) Request(subject string, data []byte, tod ...time.Duration) ([]byte, error)
  • func (p *Connect) RequestSync(reqID, subject string, data []byte, tod ...time.Duration) ([]byte, error)
  • func (p *Connect) RequestTimeout() time.Duration
  • func (p *Connect) StatsInterval() time.Duration
  • func (p *Connect) Subscribe(subject string, cb nats.MsgHandler) error
  • func (p *Connect) Timeout(tod ...time.Duration) time.Duration
• type ConnectPool
• • func InitPool(replySubject string, config cfacade.ProfileJSON, isConnect bool) *ConnectPool
  • func NewConnectPool(replySubject string, config cfacade.ProfileJSON, isConnect bool) *ConnectPool
  • func Pool() *ConnectPool
• • func (p *ConnectPool) GetConnect() *Connect
• type OptionFunc
• • func WithAddress(address string) OptionFunc
  • func WithAuth(user, password string) OptionFunc
  • func WithIsStats(isStats bool) OptionFunc
  • func WithParams(maxReconnects int) OptionFunc
  • func WithReconnectDelay(delay time.Duration) OptionFunc
  • func WithRequestTimeout(timeout time.Duration) OptionFunc
  • func WithStatsInterval(seconds int) OptionFunc