workers

Documentation

Index

• type Workers
  • func (w *Workers) Start()
  • func (w *Workers) Stop()

Types

type Workers

type Workers struct {
	// Main task scheduler instance.
	Scheduler sched.Scheduler

	// ClientAPI / federator worker pools.
	ClientAPI runners.WorkerPool
	Federator runners.WorkerPool

	// Enqueue functions for clientAPI / federator worker pools,
	// these are pointers to Processor{}.Enqueue___() msg functions.
	// This prevents dependency cycling as Processor depends on Workers.
	EnqueueClientAPI func(context.Context, ...messages.FromClientAPI)
	EnqueueFederator func(context.Context, ...messages.FromFederator)

	// Media manager worker pools.
	Media runners.WorkerPool
	// contains filtered or unexported fields
}

func (*Workers) Start

func (w *Workers) Start()

Start will start all of the contained worker pools (and global scheduler).

func (*Workers) Stop

func (w *Workers) Stop()

Stop will stop all of the contained worker pools (and global scheduler).