Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option interface {
Apply(*Options)
}
An Option configures a mutex.
func WithMaxInFlight ¶
WithMaxInFlight Maximum number of messages to allow in flight (concurrency knob)
func WithRunFunc ¶
WithRunFunc setup the run func of queue
type OptionFunc ¶ added in v0.1.0
type OptionFunc func(*Options)
OptionFunc is a function that configures a queue.
func (OptionFunc) Apply ¶ added in v0.1.0
func (f OptionFunc) Apply(option *Options)
Apply calls f(option)
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker for NSQ
func (*Worker) Queue ¶
func (w *Worker) Queue(job core.QueuedMessage) error
Queue send notification to queue
Click to show internal directories.
Click to hide internal directories.