nsq

Documentation

Index

• type Nsq
  • func New(nodeList []string) (*Nsq, error)
  • func (s *Nsq) SendDelayMsg(ctx context.Context, topic string, orderingKey string, data []byte, ...) error
  • func (s *Nsq) SendMsg(ctx context.Context, topic string, orderingKey string, data []byte) error
  • func (s *Nsq) Stop() error

Types

type Nsq

type Nsq struct {
	NsqClient nsq.Client
}

Nsq is a type of connector

func New

func New(nodeList []string) (*Nsq, error)

New creates a new Nsq connector

func (*Nsq) SendDelayMsg

func (s *Nsq) SendDelayMsg(ctx context.Context, topic string, orderingKey string, data []byte, delay time.Duration) error

SendDelayMsg is the stores that send delay events

func (*Nsq) SendMsg

func (s *Nsq) SendMsg(ctx context.Context, topic string, orderingKey string, data []byte) error

SendMsg is the stores that send real-time events

func (*Nsq) Stop

func (s *Nsq) Stop() error

Stop stops the nsq connector gracefully.