activities

type Activities struct {
	Config       config.Config
	Injector     *do.Injector
	Orchestrator database.Orchestrator
	TaskSvc      *task.Service
}

type ApplyEventInput struct {
	DatabaseID string          `json:"database_id"`
	TaskID     uuid.UUID       `json:"task_id"`
	State      *resource.State `json:"state"`
	Event      *resource.Event `json:"event"`
}

type ApplyEventOutput struct {
	Event *resource.Event `json:"event"`
}

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

type CancelSwitchoverOutput struct{}

type CheckClusterHealthInput struct {
	DatabaseID string    `json:"database_id"`
	InstanceID string    `json:"instance_id"`
	TaskID     uuid.UUID `json:"task_id,omitempty"`
}

type CheckClusterHealthOutput struct {
	Healthy          bool   `json:"healthy"`
	LeaderInstanceID string `json:"leader_instance_id,omitempty"`
	Reason           string `json:"reason,omitempty"`
}

type CreatePgBackRestBackupInput struct {
	DatabaseID    string                    `json:"database_id"`
	InstanceID    string                    `json:"instance_id"`
	TaskID        uuid.UUID                 `json:"task_id"`
	BackupOptions *pgbackrest.BackupOptions `json:"backup_options"`
}

type CreatePgBackRestBackupOutput struct{}

type DeleteDbEntitiesInput struct {
	DatabaseID string `json:"database_id"`
}

type DeleteDbEntitiesOutput struct{}

type GetCurrentStateInput struct {
	DatabaseID string `json:"database_id"`
}

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

type GetInstanceResourcesInput struct {
	Spec *database.InstanceSpec
}

type GetInstanceResourcesOutput struct {
	Resources *database.InstanceResources
}

type GetPrimaryInstanceInput struct {
	DatabaseID string `json:"database_id"`
	InstanceID string `json:"instance_id"`
}

type GetPrimaryInstanceOutput struct {
	PrimaryInstanceID string `json:"instance_id"`
}

type GetRestoreResourcesInput struct {
	Spec          *database.InstanceSpec  `json:"spec"`
	TaskID        uuid.UUID               `json:"task_id"`
	RestoreConfig *database.RestoreConfig `json:"restore_config"`
}

type GetRestoreResourcesOutput struct {
	Resources        *database.InstanceResources `json:"resources"`
	RestoreResources *database.InstanceResources `json:"restore_resources"`
}

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

type LogTaskEventInput struct {
	DatabaseID string          `json:"database_id"`
	TaskID     uuid.UUID       `json:"task_id"`
	Entries    []task.LogEntry `json:"messages"`
}

type LogTaskEventOutput struct{}

type PerformFailoverInput struct {
	DatabaseID          string    `json:"database_id"`
	LeaderInstanceID    string    `json:"leader_instance_id"`
	CandidateInstanceID string    `json:"candidate_instance_id,omitempty"`
	TaskID              uuid.UUID `json:"task_id"`
}

type PerformFailoverOutput struct{}

type PerformSwitchoverInput struct {
	DatabaseID          string    `json:"database_id"`
	LeaderInstanceID    string    `json:"leader_instance_id"`
	CandidateInstanceID string    `json:"candidate_instance_id,omitempty"`
	ScheduledAt         time.Time `json:"scheduled_at,omitempty"`
	TaskID              uuid.UUID `json:"task_id"`
}

type PerformSwitchoverOutput struct{}

type PersistPlanSummariesInput struct {
	DatabaseID string                 `json:"database_id"`
	TaskID     uuid.UUID              `json:"task_id"`
	Plans      []resource.PlanSummary `json:"plans"`
}

type PersistPlanSummariesOutput struct{}

type PersistStateInput struct {
	DatabaseID string          `json:"database_id"`
	State      *resource.State `json:"state"`
}

type PersistStateOutput struct{}

type PlanRefreshInput struct {
	DatabaseID string          `json:"database_id"`
	State      *resource.State `json:"current"`
}

type PlanRefreshOutput struct {
	Plan resource.Plan `json:"plan"`
}

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

type RestartInstanceOutput struct{}

type SelectCandidateInput struct {
	DatabaseID      string          `json:"database_id"`
	NodeName        string          `json:"node_name"`
	ExcludeInstance string          `json:"exclude_instance"`
	Instances       []*InstanceHost `json:"instances,omitempty"` // optional
}

type SelectCandidateOutput struct {
	CandidateInstanceID string `json:"candidate_instance_id"`
	CandidateHostID     string `json:"candidate_host_id,omitempty"`
}

type StartInstanceInput struct {
	DatabaseID string       `json:"database_id"`
	InstanceID string       `json:"instance_id"`
	HostID     string       `json:"host_id"`
	Cohort     *host.Cohort `json:"cohort"`
	TaskID     uuid.UUID    `json:"task_id"`
}

type StartInstanceOutput struct{}

type StopInstanceInput struct {
	DatabaseID string       `json:"database_id"`
	InstanceID string       `json:"instance_id"`
	HostID     string       `json:"host_id"`
	Cohort     *host.Cohort `json:"cohort,omitempty"`
	TaskID     uuid.UUID    `json:"task_id"`
}

type StopInstanceOutput struct{}

type UpdateDbStateInput struct {
	DatabaseID string                 `json:"database_id"`
	State      database.DatabaseState `json:"state"`
}

type UpdateDbStateOutput struct{}

type UpdateTaskInput struct {
	DatabaseID    string             `json:"database_id"`
	TaskID        uuid.UUID          `json:"task_id"`
	UpdateOptions task.UpdateOptions `json:"update_options,omitempty"`
}

type UpdateTaskOutput struct{}

type ValidateInstanceSpecsInput struct {
	DatabaseID string                   `json:"database_id"`
	Specs      []*database.InstanceSpec `json:"spec"`
}

type ValidateInstanceSpecsOutput struct {
	Results []*database.ValidationResult `json:"results"`
}