workflows

type CreatePgBackRestBackupInput struct {
	DatabaseID        string                    `json:"database_id"`
	TaskID            uuid.UUID                 `json:"task_id"`
	NodeName          string                    `json:"node_name"`
	BackupFromStandby bool                      `json:"backup_from_standby"`
	Instances         []*InstanceHost           `json:"instances"`
	BackupOptions     *pgbackrest.BackupOptions `json:"backup_options"`
}

type CreatePgBackRestBackupOutput struct{}

type DeleteDatabaseInput struct {
	DatabaseID string    `json:"database_id"`
	TaskID     uuid.UUID `json:"task_id"`
}

type DeleteDatabaseOutput struct{}

type FailoverInput struct {
	DatabaseID          string
	NodeName            string
	Instances           []*activities.InstanceHost
	CandidateInstanceID string
	SkipValidation      bool
	TaskID              uuid.UUID
}

type FailoverOutput struct{}

type InstanceHost struct {
	InstanceID string `json:"instance_id"`
	HostID     string `json:"host_id"`
}

type Orchestrator interface {
	WorkerQueues() ([]workflow.Queue, error)
}

type PgBackRestRestoreInput struct {
	TaskID        uuid.UUID               `json:"task_id"`
	Spec          *database.Spec          `json:"spec"`
	TargetNodes   []string                `json:"target_nodes"`
	RestoreConfig *database.RestoreConfig `json:"restore_config"`
	NodeTaskIDs   map[string]uuid.UUID    `json:"node_tasks_ids"`
}

type PgBackRestRestoreOutput struct{}

type PlanRestoreInput struct {
	Spec          *database.Spec          `json:"spec"`
	Current       *resource.State         `json:"current"`
	RestoreConfig *database.RestoreConfig `json:"restore_config"`
	NodeTaskIDs   map[string]uuid.UUID    `json:"node_tasks_ids"`
}

type PlanRestoreOutput struct {
	Plans []resource.Plan `json:"plans"`
}

type PlanUpdateInput struct {
	Options operations.UpdateDatabaseOptions `json:"options"`
	Spec    *database.Spec                   `json:"spec"`
	Current *resource.State                  `json:"current"`
}

type PlanUpdateOutput struct {
	Plans []resource.Plan `json:"plans"`
}

type RefreshCurrentStateInput struct {
	DatabaseID string    `json:"database_id"`
	TaskID     uuid.UUID `json:"task_id"`
}

type RefreshCurrentStateOutput struct {
	State *resource.State `json:"state"`
}

type RestartInstanceInput struct {
	HostID      string    `json:"host_id"`
	DatabaseID  string    `json:"database_id"`
	InstanceID  string    `json:"instance_id"`
	TaskID      uuid.UUID `json:"task_id"`
	ScheduledAt time.Time `json:"scheduled_at"` // Optional, if empty, restart immediately
}

type RestartInstanceOutput struct{}

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

type StartInstanceInput struct {
	DatabaseID string
	InstanceID string
	HostID     string
	Cohort     *host.Cohort
	TaskID     uuid.UUID
}

type StartInstanceOutput struct{}

type StopInstanceInput struct {
	DatabaseID string
	InstanceID string
	HostID     string
	Cohort     *host.Cohort
	TaskID     uuid.UUID
}

type StopInstanceOutput struct{}

type SwitchoverInput struct {
	DatabaseID          string
	NodeName            string
	Instances           []*activities.InstanceHost
	CandidateInstanceID string
	ScheduledAt         time.Time
	TaskID              uuid.UUID
}

type SwitchoverOutput struct{}

type UpdateDatabaseInput struct {
	TaskID      uuid.UUID      `json:"task_id"`
	Spec        *database.Spec `json:"spec"`
	ForceUpdate bool           `json:"force_update"`
}

type UpdateDatabaseOutput struct {
	Updated *resource.State `json:"current"`
}

type ValidateSpecInput struct {
	DatabaseID   string
	Spec         *database.Spec
	PreviousSpec *database.Spec
}

type ValidateSpecOutput struct {
	Valid  bool     `json:"valid"`
	Errors []string `json:"errors,omitempty"`
}

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

type Workflows struct {
	Config     config.Config
	Activities *activities.Activities
}