orchestrator

Documentation

Index

• type Config
• type Orchestrator
  • func New(perf performer.Performer, metrics metrics.Manager, logger logger.Logger, ...) *Orchestrator
  • func (orch *Orchestrator) Close() error

Types

type Config

type Config struct {
	GetSitesInterval     time.Duration
	GetEventsInterval    time.Duration
	GetEventsParallelism int
	NumRunWorkers        int
	EventBacklog         int
}

Config helps callers set up the orchestrator.

type Orchestrator

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

Orchestrator is responsible for managing the event queue & related runners. It adds events, runs them, and gracefully closes down processes when needed.

func New

func New(perf performer.Performer, metrics metrics.Manager, logger logger.Logger, locker locker.Locker, config Config) *Orchestrator

New sets up a new orchestrator based on the passed configurations

func (*Orchestrator) Close

func (orch *Orchestrator) Close() error

Close the orchestrator processes.