transfer

type Factory func(Logger, StopFunc) (Transfer, error)

type Logger interface {
	// For debuging
	Debug(v ...any)
	// For debuging with format
	Debugf(format string, v ...any)
	// For logging info
	Info(v ...any)
	// For logging info with format
	Infof(format string, v ...any)
	// For warning
	Warning(v ...any)
	// For warning with format
	Warningf(format string, v ...any)
	// For logging error
	Error(v ...any)
	// For logging error with format
	Errorf(format string, v ...any)
}

type Option func(*Options)

type Options struct {
	// Speed is the data transfer speed for replication, no limit by default.
	Speed int32
	// CopyByChunk defines whether need to copy the artifact blob by chunk, copy by whole blob by default.
	CopyByChunk bool
}

type StopFunc func() bool

type Transfer interface {
	Transfer(src *model.Resource, dst *model.Resource, opts *Options) error
}