jobs

Documentation

Index

• Variables
• func NewBackgroundOrchestrator(name string) a.Component
• type Orchestrator
  • func NewOrchestrator(name string) *Orchestrator
  • func (o *Orchestrator) Handle(ctx context.Context, t Task) (Task, error)
  • func (o *Orchestrator) Shutdown(ctx context.Context) error
  • func (o *Orchestrator) Start(ctx context.Context) error
  • func (o *Orchestrator) WithHandler(h TaskHandler, t reflect.Type) *Orchestrator
  • func (o *Orchestrator) WithLogger(l *slog.Logger) *Orchestrator
• type Task
• type TaskHandler

Variables

var (
	ErrOrchestratorStopped              error
	ErrOrchestratorTimeout              error
	ErrOrchestratorUnknownHandler       error
	ErrOrchestratorUndefinedConcurrency error
)

Functions

func NewBackgroundOrchestrator

func NewBackgroundOrchestrator(name string) a.Component

Types

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(name string) *Orchestrator

func (*Orchestrator) Handle

func (o *Orchestrator) Handle(ctx context.Context, t Task) (Task, error)

func (*Orchestrator) Shutdown

func (o *Orchestrator) Shutdown(ctx context.Context) error

func (*Orchestrator) Start

func (o *Orchestrator) Start(ctx context.Context) error

func (*Orchestrator) WithHandler

func (o *Orchestrator) WithHandler(h TaskHandler, t reflect.Type) *Orchestrator

func (*Orchestrator) WithLogger

func (o *Orchestrator) WithLogger(l *slog.Logger) *Orchestrator

type Task

type Task interface {
	Type() reflect.Type
}

type TaskHandler

type TaskHandler interface {
	Type() reflect.Type
	Handle(ctx context.Context, t Task) (Task, error)
	MaxConcurrent() int
}