inmemorytaskmanager

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (q *Queue) Enqueue(pe event.ProcessedEvent) error
• type TaskManager
  • func New() *TaskManager
  • func (tm *TaskManager) Publish(e event.ProcessedEvent) error
• type Worker
  • func NewWorker(tm *TaskManager, h worker.TaskHandler) *Worker
  • func (w *Worker) Run(_ <-chan bool, _ *sync.WaitGroup) error

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

Queue represents an in-memory job queue.

func NewQueue

func NewQueue() *Queue

func (*Queue) Enqueue

func (q *Queue) Enqueue(pe event.ProcessedEvent) error

Enqueue adds a new job to the in-memory queue.

type TaskManager

type TaskManager struct {
	Queue *Queue
}

func New

func New() *TaskManager

func (*TaskManager) Publish

func (tm *TaskManager) Publish(e event.ProcessedEvent) error

type Worker

type Worker struct {
	TaskManager *TaskManager
	Handler     worker.TaskHandler
}

func NewWorker

func NewWorker(tm *TaskManager, h worker.TaskHandler) *Worker

func (*Worker) Run

func (w *Worker) Run(_ <-chan bool, _ *sync.WaitGroup) error