nsq

Documentation

Index

• Variables
• type PubSub
  • func NewNSQPubSub(config queueing.Config) (*PubSub, error)
  • func (p PubSub) NotifyTopic(topic string)
  • func (p PubSub) ReceiveUpdateFromTopic(topic string) <-chan struct{}
• type WorkerQueue
  • func NewNSQWorkerQueue(config queueing.Config) (*WorkerQueue, error)
  • func (n WorkerQueue) Acknowledge(q queueing.QCheck)
  • func (n WorkerQueue) Ping(group *servicegroup.ServiceGroup) error
  • func (n WorkerQueue) Receive()
  • func (n WorkerQueue) Send(sds []*queueing.ScoringData) ([]*queueing.QCheck, error, error)

Variables

var ErrNSQDProducerAddressNotProvided = errors.New("must provide nsqd producer address")

var ErrPanic = errors.New("panic")

var ErrProvidedBothNSQLookupdAndNSQD = errors.New("must either provide a list of nsqlookupd nodes, or list of nsqd nodes for the consumer, but not both")

var ErrUnknownPanic = errors.New("unknown panic")

var ErrWorkersFailed = errors.New("some workers failed to receive the checks. Make sure that is by design")

Types

type PubSub

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

func NewNSQPubSub

func NewNSQPubSub(config queueing.Config) (*PubSub, error)

func (PubSub) NotifyTopic

func (p PubSub) NotifyTopic(topic string)

func (PubSub) ReceiveUpdateFromTopic

func (p PubSub) ReceiveUpdateFromTopic(topic string) <-chan struct{}

type WorkerQueue

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

func NewNSQWorkerQueue

func NewNSQWorkerQueue(config queueing.Config) (*WorkerQueue, error)

func (WorkerQueue) Acknowledge

func (n WorkerQueue) Acknowledge(q queueing.QCheck)

func (WorkerQueue) Ping

func (n WorkerQueue) Ping(group *servicegroup.ServiceGroup) error

func (WorkerQueue) Receive

func (n WorkerQueue) Receive()

func (WorkerQueue) Send

func (n WorkerQueue) Send(sds []*queueing.ScoringData) ([]*queueing.QCheck, error, error)

Send sends scoring data to the NSQD nodes, and returns either a list of checks with a warning, or an error