db_task

package

v0.1.0-rc.1 Latest Latest Go to latest Published: Jun 11, 2024 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDbTask(task *db.DbTask) job.Job

type DbTask struct {
	*db.DbTask
}

func (j *DbTask) Cancelling(reason string)

func (j *DbTask) GetName() string

func (j *DbTask) IsCancelling() bool

func (j *DbTask) IsDone() bool

func (j *DbTask) IsFailed() bool

func (j *DbTask) IsPending() bool

func (j *DbTask) IsRunning() bool

func (j *DbTask) Requires() []uuid.UUID

func (j *DbTask) UUID() uuid.UUID

type DbTaskHandler struct {
	DbApi    *db.DbApi
	DbConfig *config.DbConfig
	// contains filtered or unexported fields
}

func NewDbTaskHandler(dbConfig *config.DbConfig) *DbTaskHandler

func (h *DbTaskHandler) BackupDb(task *DbTask) (err error)

func (h *DbTaskHandler) CreateDatabase(task *DbTask) error

func (h *DbTaskHandler) CreateUser(task *DbTask) (err error)

func (h *DbTaskHandler) Handle(msg server.NamedElement) error

func (h *DbTaskHandler) Init(setter server.GlobalSetter) (err error)

func (h *DbTaskHandler) MigrateOut(task *DbTask) error

func (h *DbTaskHandler) PostInit(getter server.GlobalGetter) error

func (h *DbTaskHandler) RecoverJobs() (jobs []job.Job, err error)

func (h *DbTaskHandler) RestoreDb(task *DbTask) (err error)

func (h *DbTaskHandler) WaitReadyDb(task *DbTask) (err error)