kk_executor

Documentation

Index

• func Executor(stage *kk_stage.Stage, do func() error, failBack func() error) error
• type SyncExecutor
  • func (e *SyncExecutor) Execute() error

Functions

func Executor

func Executor(stage *kk_stage.Stage, do func() error, failBack func() error) error

Executor 失败时执行回滚程序

Types

type SyncExecutor

type SyncExecutor struct {
	Stage        *kk_stage.Stage
	DB           *gorm.DB
	DBDo         func(tx *gorm.DB) error
	MinIOObjects []kk_minio.OPObject
}

SyncExecutor sync executor

func (*SyncExecutor) Execute

func (e *SyncExecutor) Execute() error