secondary

Documentation

Index

• type Task
  • func NewTask(args TaskArgs) (*Task, error)
  • func (t *Task) Execute(ctx context.Context) error
• type TaskArgs

Types

type Task

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

func NewTask

func NewTask(args TaskArgs) (*Task, error)

func (*Task) Execute

func (t *Task) Execute(ctx context.Context) error

type TaskArgs

type TaskArgs struct {
	TaskID string

	SourceClusterID string
	TargetClusterID string

	Backup *backuppb.BackupInfo

	Params *cfg.Config

	BackupDir     string
	BackupStorage storage.Client

	TaskMgr *taskmgr.Mgr
}