Versions in this module Expand all Collapse all v0 v0.0.2 Apr 8, 2026 Changes in this version + const None + const Nsq + var ErrInvalidPubSub = errors.New("invalid pubsub selected") + var ErrInvalidQueue = errors.New("invalid queue selected") + type MasterStreamPubSub interface + NotifyTopic func(topic string) + ReceiveUpdateFromTopic func(topic string) <-chan struct{} + func NewMasterStreamPubSub(c queueing.Config) (MasterStreamPubSub, error) + type WorkerQueue interface + Acknowledge func(queueing.QCheck) + Ping func(group *servicegroup.ServiceGroup) error + Receive func() + Send func([]*queueing.ScoringData) (queue []*queueing.QCheck, nonCriticalErr error, CriticalErr error) + func NewWorkerQueue(c queueing.Config) (WorkerQueue, error)
Go to main page