xreg

type Args struct {
	Custom any // Additional arguments that are specific for a given xact.
	UUID   string
}

type BckRenameArgs struct {
	BckFrom *meta.Bck
	BckTo   *meta.Bck
	RebID   string
	Phase   string
}

type DsortArgs struct {
	BckFrom *meta.Bck
	BckTo   *meta.Bck
}

type ECEncodeArgs struct {
	Phase string
}

type Flt struct {
	Bck         *meta.Bck
	OnlyRunning *bool
	ID          string
	Kind        string
	Buckets     []*meta.Bck
}

type MNCArgs struct {
	Tag    string
	Copies int
}

type RenewBase struct {
	Args
	Bck *meta.Bck
}

type RenewRes struct {
	Entry Renewable // Depending on situation can be new or old entry.
	Err   error     // Error that occurred during renewal.
	UUID  string    // "" if a new entry has been created, ID of the existing xaction otherwise
}

type Renewable interface {
	New(args Args, bck *meta.Bck) Renewable // new xaction stub that can be `Start`-ed.
	Start() error                           // starts an xaction, will be called when entry is stored into registry
	Kind() string
	Get() core.Xact
	WhenPrevIsRunning(prevEntry Renewable) (action WPR, err error)
	Bucket() *meta.Bck
	UUID() string
}

type TCBArgs struct {
	DP      core.DP
	BckFrom *meta.Bck
	BckTo   *meta.Bck
	Msg     *apc.TCBMsg
	Phase   string
}

type TCObjsArgs struct {
	BckFrom *meta.Bck
	BckTo   *meta.Bck
	DP      core.DP
}

type WPR int