nsq

Documentation

Index

• type NSQ
  • func NewNSQ(addresses []string, cfg *nsq.Config, channelPrefix string) (*NSQ, error)
  • func (e *NSQ) Consumer(ctx context.Context, name string, f queueLib.ConsumerFunc, ...)
  • func (e *NSQ) Publish(ctx context.Context, message messageLib.IMessage, ...) error
  • func (e *NSQ) RpcRequest(ctx context.Context, key string, data []byte, ...) ([]byte, error)
  • func (e *NSQ) Run(ctx context.Context)
  • func (e *NSQ) Shutdown(ctx context.Context)
  • func (NSQ) String() string

Types

type NSQ

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

func NewNSQ

func NewNSQ(addresses []string, cfg *nsq.Config, channelPrefix string) (*NSQ, error)

NewNSQ nsq模式 只能监听一个channel

func (*NSQ) Consumer

func (e *NSQ) Consumer(ctx context.Context, name string, f queueLib.ConsumerFunc, optionFuncs ...func(*queueLib.ConsumeOptions))

Consumer 监听消费者

func (*NSQ) Publish

func (e *NSQ) Publish(ctx context.Context, message messageLib.IMessage, optionFuncs ...func(*queueLib.PublishOptions)) error

Publish 消息入生产者

func (*NSQ) RpcRequest

func (e *NSQ) RpcRequest(ctx context.Context, key string, data []byte, optionFuncs ...func(*queueLib.ClientOptions)) ([]byte, error)

func (*NSQ) Run

func (e *NSQ) Run(ctx context.Context)

func (*NSQ) Shutdown

func (e *NSQ) Shutdown(ctx context.Context)

func (NSQ) String

func (NSQ) String() string

String 字符串类型