db_task

package

v0.1.2 Latest Latest Go to latest Published: Jul 18, 2024 License: MIT Imports: 20 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDbTask(task *db.DbTask, dbApi *db.DbApi) job.Task

type DbTask struct {
	*db.DbTask

	*job.BaseTaskDependency
	// contains filtered or unexported fields
}

func (t *DbTask) Cancel(reason string)

func (t *DbTask) GetName() string

func (t *DbTask) IsDone() bool

func (t *DbTask) IsFailed() bool

func (t *DbTask) IsPending() bool

func (t *DbTask) IsRunning() bool

func (t *DbTask) JobID() uuid.UUID

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

func (t *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) RestoreDb(task *DbTask) (err error)

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