manager

Documentation

Index

• type DependencySpec
• type Manager
  • func (manager *Manager) Ready(ctx context.Context) (tasks <-chan string, err error)
  • func (manager *Manager) Register(ctx context.Context, id string) error
• type Resolver
• type TaskToGroup

Types

type DependencySpec

type DependencySpec struct {
	Name string
	Data any
}

type Manager

type Manager struct {
	System       core.AbstractSystem
	Dependencies dependency.Manager
	TaskToGroup  TaskToGroup
	Resolvers    map[string]Resolver
	Logger       *slog.Logger
}

func (*Manager) Ready

func (manager *Manager) Ready(ctx context.Context) (tasks <-chan string, err error)

func (*Manager) Register

func (manager *Manager) Register(ctx context.Context, id string) error

type Resolver

type Resolver interface {
	Bind(ctx context.Context, id string, data any) error
	Ready(ctx context.Context) (<-chan string, error)
}

type TaskToGroup

type TaskToGroup interface {
	Save(ctx context.Context, task string, group string) error
	TaskByGroup(ctx context.Context, group string) (task string, err error)
	GroupByTask(ctx context.Context, task string) (group string, err error)
}