worker

Documentation

Index

• Constants
• type Worker
  • func NewWorker(workerID string, radapter *rdb.Adapter, messages <-chan *redis.Message, ...) *Worker
  • func (w *Worker) Listen()

Constants

const (
	DefaultTickerInterval = 2 * time.Second
	MaxFreqResultItems    = 100
)

Types

type Worker

type Worker struct {
	ID string
	// contains filtered or unexported fields
}

func NewWorker

func NewWorker(
	workerID string,
	radapter *rdb.Adapter,
	messages <-chan *redis.Message,
	exitEvent chan os.Signal,
	jobLogger jobLogger,
) *Worker

func (*Worker) Listen

func (w *Worker) Listen()