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 provides a worker pool that handles both
	// incoming client actions, and our own side-effects.
	ClientAPI runners.WorkerPool

	// Federator provides a worker pool that handles both
	// incoming federated actions, and our own side-effects.
	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)
	EnqueueFediAPI   func(context.Context, ...messages.FromFediAPI)

	// 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).