Versions in this module Expand all Collapse all v0 v0.0.2 Apr 8, 2026 Changes in this version + var ErrNSQDProducerAddressNotProvided = errors.New("must provide nsqd producer address") + var ErrNotProvidedAnyNSQLookupdOrNSQD = errors.New("you haven't provided any nsqlookupd mor nsqd nodes for the consumer") + var ErrPanic = errors.New("panic") + var ErrProvidedBothNSQLookupdAndNSQD = errors.New(...) + var ErrUnknownPanic = errors.New("unknown panic") + var ErrWorkersFailed = errors.New("some workers failed to receive the checks. Make sure that is by design") + type PubSub struct + func NewNSQPubSub(config queueing.Config) (*PubSub, error) + func (p PubSub) NotifyTopic(topic string) + func (p PubSub) ReceiveUpdateFromTopic(topic string) <-chan struct{} + type WorkerQueue struct + func NewNSQWorkerQueue(config queueing.Config) (*WorkerQueue, error) + func (n WorkerQueue) Acknowledge(qCheck queueing.QCheck) + func (n WorkerQueue) Ping(group *servicegroup.ServiceGroup) error + func (n WorkerQueue) Receive() + func (n WorkerQueue) Send(scoringDataAggregate []*queueing.ScoringData) ([]*queueing.QCheck, error, error)
Go to main page