scheduler

type CreatePgBackRestBackupScheduleInput struct {
	DatabaseID string `json:"database_id"`
	NodeName   string `json:"node_name"`
	Type       string `json:"type"`
}

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

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

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

type ScheduledJobResource struct {
	ID        string                 `json:"id"`                   // Unique job identifier
	CronExpr  string                 `json:"cron_expr"`            // Cron expression for scheduling
	Workflow  string                 `json:"workflow"`             // Name of the workflow to execute
	Args      map[string]interface{} `json:"args"`                 // Arguments to the workflow
	DependsOn []resource.Identifier  `json:"depends_on,omitempty"` // Optional resource dependencies
}

type ScheduledJobRunner struct {
	Job      *StoredScheduledJob
	Executor WorkflowExecutor
	Logger   zerolog.Logger
	Store    *ScheduledJobStore
}

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

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

type StoredLeader struct {
	storage.StoredValue
	HostID    string
	CreatedAt time.Time
}

type StoredScheduledJob struct {
	storage.StoredValue
	ID       string         `json:"id"`
	CronExpr string         `json:"cron_expr"`
	Workflow string         `json:"workflow"`
	ArgsJSON map[string]any `json:"args_json"`
}

type WorkflowExecutor interface {
	Execute(ctx context.Context, workflowName string, args map[string]interface{}) error
}