orchestrator

Documentation

Index

• Variables
• type Orchestrator
  • func NewOrchestrator(resticBin string, cfg *v1.Config, log *oplog.OpLog, ...) (*Orchestrator, error)
  • func (o *Orchestrator) ApplyConfig(cfg *v1.Config) error
  • func (o *Orchestrator) CancelOperation(operationId int64, status v1.OperationStatus) error
  • func (o *Orchestrator) Config() *v1.Config
  • func (o *Orchestrator) CreateUnscheduledTask(t tasks.Task, priority int, curTime time.Time) (tasks.ScheduledTask, error)
  • func (o *Orchestrator) GetPlan(planID string) (*v1.Plan, error)
  • func (o *Orchestrator) GetRepo(repoID string) (*v1.Repo, error)
  • func (o *Orchestrator) GetRepoOrchestrator(repoId string) (repo *repo.RepoOrchestrator, err error)
  • func (o *Orchestrator) Run(ctx context.Context)
  • func (o *Orchestrator) RunTask(ctx context.Context, st tasks.ScheduledTask) error
  • func (o *Orchestrator) ScheduleDefaultTasks(config *v1.Config) error
  • func (o *Orchestrator) ScheduleTask(t tasks.Task, priority int, callbacks ...func(error)) error

Variables

var ErrPlanNotFound = errors.New("plan not found")

var ErrRepoInitializationFailed = errors.New("repo initialization failed")

var ErrRepoNotFound = errors.New("repo not found")

Types

type Orchestrator

type Orchestrator struct {
	OpLog *oplog.OpLog
	// contains filtered or unexported fields
}

Orchestrator is responsible for managing repos and backups.

func NewOrchestrator

func NewOrchestrator(resticBin string, cfg *v1.Config, log *oplog.OpLog, logStore *logstore.LogStore) (*Orchestrator, error)

func (*Orchestrator) ApplyConfig

func (o *Orchestrator) ApplyConfig(cfg *v1.Config) error

func (*Orchestrator) CancelOperation

func (o *Orchestrator) CancelOperation(operationId int64, status v1.OperationStatus) error

func (*Orchestrator) Config

func (o *Orchestrator) Config() *v1.Config

func (*Orchestrator) CreateUnscheduledTask

func (o *Orchestrator) CreateUnscheduledTask(t tasks.Task, priority int, curTime time.Time) (tasks.ScheduledTask, error)

func (*Orchestrator) GetPlan

func (o *Orchestrator) GetPlan(planID string) (*v1.Plan, error)

func (*Orchestrator) GetRepo

func (o *Orchestrator) GetRepo(repoID string) (*v1.Repo, error)

func (*Orchestrator) GetRepoOrchestrator

func (o *Orchestrator) GetRepoOrchestrator(repoId string) (repo *repo.RepoOrchestrator, err error)

func (*Orchestrator) Run

func (o *Orchestrator) Run(ctx context.Context)

Run is the main orchestration loop. Cancel the context to stop the loop.

func (*Orchestrator) RunTask

func (o *Orchestrator) RunTask(ctx context.Context, st tasks.ScheduledTask) error

func (*Orchestrator) ScheduleDefaultTasks

func (o *Orchestrator) ScheduleDefaultTasks(config *v1.Config) error

rescheduleTasksIfNeeded checks if any tasks need to be rescheduled based on config changes.

func (*Orchestrator) ScheduleTask

func (o *Orchestrator) ScheduleTask(t tasks.Task, priority int, callbacks ...func(error)) error

ScheduleTask schedules a task to run at the next available time. note that o.mu must not be held when calling this function.