Documentation ¶
Index ¶
- type Option
- func WithAddr(addr string) Option
- func WithChannel(channel string) Option
- func WithChannelSize(size int) Option
- func WithCluster(enable bool) Option
- func WithConnectionString(connectionString string) Option
- func WithDB(db int) Option
- func WithLogger(l queue.Logger) Option
- func WithPassword(passwd string) Option
- func WithRunFunc(fn func(context.Context, queue.QueuedMessage) error) Option
- type Worker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*Worker)
Option for queue system
func WithConnectionString ¶
WithConnectionString redis connection string
func WithRunFunc ¶
WithRunFunc setup the run func of queue
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker for Redis
func (*Worker) BusyWorkers ¶ added in v0.0.3
BusyWorkers return count of busy workers currently.
Click to show internal directories.
Click to hide internal directories.