orchestrator

package

v1.0.0 Latest Latest Go to latest Published: May 20, 2024 License: GPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

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

View Source

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

View Source

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

This section is empty.

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

Orchestrator is responsible for managing repos and backups.

func NewOrchestrator(resticBin string, cfg *v1.Config, oplog *oplog.OpLog, logStore *rotatinglog.RotatingLog) (*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) 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)

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

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

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

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.