workflows

package

Go to main page

Versions in this module

v0

v0.8.0

May 6, 2026

Changes in this version

type DeleteDatabaseInput

+ Variables resource.Variables

type PgBackRestRestoreInput

+ Variables resource.Variables

type RefreshCurrentStateInput

+ Variables resource.Variables

type UpdateDatabaseInput

+ Variables resource.Variables

type Worker

+ func (w *Worker) Error() <-chan error

v0.8.0-rc.1

May 5, 2026

v0.7.0

Mar 27, 2026

Changes in this version

+ type RemoveHostTasks struct

+ DatabaseTasks []*task.Task

+ Task *task.Task

type Workflows

+ Orchestrator database.Orchestrator

v0.7.0-rc.1

Mar 25, 2026

v0.6.2

Dec 22, 2025

v0.6.2-rc.1

Dec 22, 2025

v0.6.1

Dec 19, 2025

v0.6.1-rc.1

Dec 19, 2025

v0.6.0

Dec 17, 2025

Changes in this version

type RefreshCurrentStateInput

+ RemoveHosts []string

+ type RemoveHostInput struct

+ DatabaseTaskIDs map[string]uuid.UUID

+ HostID string

+ TaskID uuid.UUID

+ UpdateDatabaseInputs []*UpdateDatabaseInput

+ type RemoveHostOutput struct

type Service

+ func (s *Service) RemoveHost(ctx context.Context, input *RemoveHostInput) ([]*task.Task, error)

type UpdateDatabaseInput

+ RemoveHosts []string

type Workflows

+ func (w *Workflows) RemoveHost(ctx workflow.Context, input *RemoveHostInput) (*RemoveHostOutput, error)

v0.6.0-rc.1

Dec 17, 2025

v0.5.1

Nov 24, 2025

Changes in this version

type ValidateSpecInput

+ PreviousSpec *database.Spec

v0.5.1-rc.1

Nov 24, 2025

v0.5.0

Nov 6, 2025

Changes in this version

+ var ErrDuplicateWorkflow = errors.New("duplicate workflow already in progress")

+ func Provide(i *do.Injector)

+ type CreatePgBackRestBackupInput struct

+ BackupFromStandby bool

+ BackupOptions *pgbackrest.BackupOptions

+ DatabaseID string

+ Instances []*InstanceHost

+ NodeName string

+ TaskID uuid.UUID

+ type CreatePgBackRestBackupOutput struct

+ type DeleteDatabaseInput struct

+ DatabaseID string

+ TaskID uuid.UUID

+ type DeleteDatabaseOutput struct

+ type FailoverInput struct

+ CandidateInstanceID string

+ DatabaseID string

+ Instances []*activities.InstanceHost

+ NodeName string

+ SkipValidation bool

+ TaskID uuid.UUID

+ type FailoverOutput struct

+ type InstanceHost struct

+ HostID string

+ InstanceID string

+ type Orchestrator interface

+ WorkerQueues func() ([]workflow.Queue, error)

+ type PgBackRestRestoreInput struct

+ NodeTaskIDs map[string]uuid.UUID

+ RestoreConfig *database.RestoreConfig

+ Spec *database.Spec

+ TargetNodes []string

+ TaskID uuid.UUID

+ type PgBackRestRestoreOutput struct

+ type PlanRestoreInput struct

+ Current *resource.State

+ NodeTaskIDs map[string]uuid.UUID

+ RestoreConfig *database.RestoreConfig

+ Spec *database.Spec

+ type PlanRestoreOutput struct

+ Plans []resource.Plan

+ type PlanUpdateInput struct

+ Current *resource.State

+ Options operations.UpdateDatabaseOptions

+ Spec *database.Spec

+ type PlanUpdateOutput struct

+ Plans []resource.Plan

+ type RefreshCurrentStateInput struct

+ DatabaseID string

+ TaskID uuid.UUID

+ type RefreshCurrentStateOutput struct

+ State *resource.State

+ type RestartInstanceInput struct

+ DatabaseID string

+ HostID string

+ InstanceID string

+ ScheduledAt time.Time

+ TaskID uuid.UUID

+ type RestartInstanceOutput struct

+ type Service struct

+ func NewService(cfg config.Config, client *client.Client, taskSvc *task.Service, ...) *Service

+ func (s *Service) CancelDatabaseTask(ctx context.Context, DatabaseID string, taskID uuid.UUID) (*task.Task, error)

+ func (s *Service) CreateDatabase(ctx context.Context, spec *database.Spec) (*task.Task, error)

+ func (s *Service) CreatePgBackRestBackup(ctx context.Context, databaseID string, nodeName string, ...) (*task.Task, error)

+ func (s *Service) DeleteDatabase(ctx context.Context, databaseID string) (*task.Task, error)

+ func (s *Service) FailoverDatabaseNode(ctx context.Context, input *FailoverInput) (*task.Task, error)

+ func (s *Service) PgBackRestRestore(ctx context.Context, spec *database.Spec, targetNodes []string, ...) (*task.Task, []*task.Task, error)

+ func (s *Service) RestartInstance(ctx context.Context, input *RestartInstanceInput) (*task.Task, error)

+ func (s *Service) StartInstance(ctx context.Context, input *StartInstanceInput) (*task.Task, error)

+ func (s *Service) StopInstance(ctx context.Context, input *StopInstanceInput) (*task.Task, error)

+ func (s *Service) SwitchoverDatabaseNode(ctx context.Context, input *SwitchoverInput) (*task.Task, error)

+ func (s *Service) UpdateDatabase(ctx context.Context, spec *database.Spec, forceUpdate bool) (*task.Task, error)

+ func (s *Service) ValidateSpec(ctx context.Context, spec *database.Spec) (*ValidateSpecOutput, error)

+ type StartInstanceInput struct

+ Cohort *host.Cohort

+ DatabaseID string

+ HostID string

+ InstanceID string

+ TaskID uuid.UUID

+ type StartInstanceOutput struct

+ type StopInstanceInput struct

+ Cohort *host.Cohort

+ DatabaseID string

+ HostID string

+ InstanceID string

+ TaskID uuid.UUID

+ type StopInstanceOutput struct

+ type SwitchoverInput struct

+ CandidateInstanceID string

+ DatabaseID string

+ Instances []*activities.InstanceHost

+ NodeName string

+ ScheduledAt time.Time

+ TaskID uuid.UUID

+ type SwitchoverOutput struct

+ type UpdateDatabaseInput struct

+ ForceUpdate bool

+ Spec *database.Spec

+ TaskID uuid.UUID

+ type UpdateDatabaseOutput struct

+ Updated *resource.State

+ type ValidateSpecInput struct

+ DatabaseID string

+ Spec *database.Spec

+ type ValidateSpecOutput struct

+ Errors []string

+ Valid bool

+ type Worker struct

+ func NewWorker(be backend.Backend, workflows *Workflows, orch Orchestrator) (*Worker, error)

+ func (w *Worker) Shutdown() error

+ func (w *Worker) Start(ctx context.Context) error

+ type Workflows struct

+ Activities *activities.Activities

+ Config config.Config

+ func (w *Workflows) CreatePgBackRestBackup(ctx workflow.Context, input *CreatePgBackRestBackupInput) (*CreatePgBackRestBackupOutput, error)

+ func (w *Workflows) DeleteDatabase(ctx workflow.Context, input *DeleteDatabaseInput) (*DeleteDatabaseOutput, error)

+ func (w *Workflows) ExecutePlanRestore(ctx workflow.Context, input *PlanRestoreInput) workflow.Future[*PlanRestoreOutput]

+ func (w *Workflows) ExecutePlanUpdate(ctx workflow.Context, input *PlanUpdateInput) workflow.Future[*PlanUpdateOutput]

+ func (w *Workflows) ExecuteRefreshCurrentState(ctx workflow.Context, input *RefreshCurrentStateInput) workflow.Future[*RefreshCurrentStateOutput]

+ func (w *Workflows) Failover(ctx workflow.Context, in *FailoverInput) (*FailoverOutput, error)

+ func (w *Workflows) PgBackRestRestore(ctx workflow.Context, input *PgBackRestRestoreInput) (*PgBackRestRestoreOutput, error)

+ func (w *Workflows) PlanRestore(ctx workflow.Context, input *PlanRestoreInput) (*PlanRestoreOutput, error)

+ func (w *Workflows) PlanUpdate(ctx workflow.Context, input *PlanUpdateInput) (*PlanUpdateOutput, error)

+ func (w *Workflows) RefreshCurrentState(ctx workflow.Context, input *RefreshCurrentStateInput) (*RefreshCurrentStateOutput, error)

+ func (w *Workflows) Register(work *worker.Worker) error

+ func (w *Workflows) RestartInstance(ctx workflow.Context, input *RestartInstanceInput) (*RestartInstanceOutput, error)

+ func (w *Workflows) StartInstance(ctx workflow.Context, input *StartInstanceInput) (*StartInstanceOutput, error)

+ func (w *Workflows) StopInstance(ctx workflow.Context, input *StopInstanceInput) (*StopInstanceOutput, error)

+ func (w *Workflows) Switchover(ctx workflow.Context, in *SwitchoverInput) (*SwitchoverOutput, error)

+ func (w *Workflows) UpdateDatabase(ctx workflow.Context, input *UpdateDatabaseInput) (*UpdateDatabaseOutput, error)

+ func (w *Workflows) ValidateSpec(ctx workflow.Context, input *ValidateSpecInput) (*ValidateSpecOutput, error)

v0.5.0-rc.2

Nov 6, 2025

v0.5.0-rc.1

Nov 5, 2025

v0.4.0

Oct 10, 2025

v0.4.0-rc.2

Oct 9, 2025

v0.4.0-rc.1

Oct 6, 2025

v0.3.0

Aug 19, 2025

v0.3.0-rc.1

Aug 19, 2025

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL