nats

Documentation

Index

• type Eventbus
  • func NewEventbus(opts ...Option) *Eventbus
  • func (eb *Eventbus) Close() error
  • func (eb *Eventbus) Publish(ctx context.Context, topic string, payload interface{}) error
  • func (eb *Eventbus) Subscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error
  • func (eb *Eventbus) Unsubscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error
• type Option
  • func WithConn(conn *nats.Conn) Option
  • func WithTimeout(timeout time.Duration) Option
  • func WithUrl(url string) Option

Types

type Eventbus

type Eventbus struct {
	// contains filtered or unexported fields
}

func NewEventbus

func NewEventbus(opts ...Option) *Eventbus

func (*Eventbus) Close

func (eb *Eventbus) Close() error

Close 停止监听

func (*Eventbus) Publish

func (eb *Eventbus) Publish(ctx context.Context, topic string, payload interface{}) error

Publish 发布事件

func (*Eventbus) Subscribe

func (eb *Eventbus) Subscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error

Subscribe 订阅事件

func (*Eventbus) Unsubscribe

func (eb *Eventbus) Unsubscribe(ctx context.Context, topic string, handler eventbus.EventHandler) error

Unsubscribe 取消订阅

type Option

type Option func(o *options)

func WithConn

func WithConn(conn *nats.Conn) Option

WithConn 设置外部客户端连接

func WithTimeout

func WithTimeout(timeout time.Duration) Option

WithTimeout 客户端连接超时时间

func WithUrl

func WithUrl(url string) Option

WithUrl 设置连接地址