nsq

Documentation

Index

• Constants
• func NewConsumerClient() *consumer
• func NewNsqClient() *nsqClient
• type Consumer
• type NsqClient
• type Publish
  • func NewPublishClient() Publish

Constants

const (
	ChannelNsq string = "garden-be"
)

Functions

func NewConsumerClient

func NewConsumerClient() *consumer

func NewNsqClient

func NewNsqClient() *nsqClient

Types

type Consumer

type Consumer interface {
	SubscribeMsg(topic string, cmd func([]byte) error) error
}

type NsqClient

type NsqClient interface {
	NsqProducer() (*nsq.Producer, error)
	NsqConsumer(topic string, ch string) (*nsq.Consumer, error)
	GetNsqProducerLink() string
	GetNsqConsumerLink() string
}

type Publish

type Publish interface {
	PublishMsg(topic string, msg interface{}) (err error)
}

func NewPublishClient

func NewPublishClient() Publish