Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNSQDProducerAddressNotProvided = errors.New("must provide nsqd producer address")
View Source
var ErrNotProvidedAnyNSQLookupdOrNSQD = errors.New("you haven't provided any nsqlookupd mor nsqd nodes for the consumer")
View Source
var ErrPanic = errors.New("panic")
View Source
var ErrProvidedBothNSQLookupdAndNSQD = errors.New("must either provide a list of nsqlookupd nodes, or list of nsqd nodes for the consumer, but not both")
View Source
var ErrUnknownPanic = errors.New("unknown panic")
View Source
var ErrWorkersFailed = errors.New("some workers failed to receive the checks. Make sure that is by design")
Functions ¶
This section is empty.
Types ¶
type PubSub ¶
type PubSub struct {
// contains filtered or unexported fields
}
func (PubSub) NotifyTopic ¶
func (PubSub) ReceiveUpdateFromTopic ¶
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(qCheck 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(scoringDataAggregate []*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
Source Files
Click to show internal directories.
Click to hide internal directories.