Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReceiveWorker ¶
type ReceiveWorker struct { Redis *redis.Client Queue string PoolIdle time.Duration PoolActive time.Duration Handler interface{ Handle(message []byte) error } NumWorkers uint Batch uint // contains filtered or unexported fields }
func (*ReceiveWorker) Stop ¶
func (r *ReceiveWorker) Stop()
func (*ReceiveWorker) Work ¶
func (r *ReceiveWorker) Work()
Click to show internal directories.
Click to hide internal directories.