Versions in this module Expand all Collapse all v0 v0.0.2 Apr 8, 2026 Changes in this version + var ErrMethodNotSupportedForNoneQueue = errors.New("method not supported when queue is none") + var ErrPanic = errors.New("panic") + var ErrRoundTookTooLongToScore = errors.New(...) + var ErrUnknownPanic = errors.New("unknown panic") + type None struct + func NewNoneQueue() (*None, error) + func (n None) Acknowledge(q queueing.QCheck) + func (n None) Ping(group *servicegroup.ServiceGroup) error + func (n None) Receive() + func (n None) Send(sds []*queueing.ScoringData) ([]*queueing.QCheck, error, error) + type PubSub struct + func NewNonePubSub(config queueing.Config) (*PubSub, error) + func (p PubSub) NotifyTopic(topic string) + func (p PubSub) ReceiveUpdateFromTopic(topic string) <-chan struct{}
Go to main page