rclone

type Bucket struct {
	Storage string
	Bucket  string
}

type CompareRes struct {
	SrcStor  string
	DestStor string
	Bucket   string

	MissFrom []string
	MissTo   []string
	Differ   []string
	Error    []string
	Match    []string
	IsMatch  bool
}

type Config struct {
	MemoryCalc      MemoryCalc                `yaml:"memoryCalc"`
	MemoryLimit     MemoryLimit               `yaml:"memoryLimit"`
	LocalFileLimit  ratelimit.SemaphoreConfig `yaml:"localFileLimit"`
	GlobalFileLimit ratelimit.SemaphoreConfig `yaml:"globalFileLimit"`
}

type CopySvc interface {
	BucketObjects(ctx context.Context, user string, bucket Bucket, opts ...func(o *minio.ListObjectsOptions)) iter.Seq2[ObjectInfo, error]
	IsBucketVersioned(ctx context.Context, user string, bucket Bucket) (bool, error)
	GetVersionInfo(ctx context.Context, user string, to File) ([]ObjectVersionInfo, error)
	DeleteDestinationObject(ctx context.Context, user string, to File) error
	GetLastMigratedVersionInfo(ctx context.Context, user string, to File) (ObjectVersionInfo, error)
	CopyObject(ctx context.Context, user string, from File, to File) error
}

type File struct {
	Storage string
	Bucket  string
	Name    string
	Version string
}

type LimiterSvc interface {
	Reserve(ctx context.Context, size int64) (func(), error)
}

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

type MemoryCalc struct {
	Const string  `yaml:"const"`
	Mul   float64 `yaml:"mul"`
}

type MemoryLimit struct {
	Limit    string        `yaml:"limit"`
	RetryMin time.Duration `yaml:"retryMin"`
	RetryMax time.Duration `yaml:"retryMax"`
	Enabled  bool          `yaml:"enabled"`
}

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

type ObjectInfo struct {
	LastModified time.Time
	Key          string
	VersionID    string
	Etag         string
	StorageClass string
	Size         uint64
}

type ObjectVersionInfo struct {
	Version string
	Size    uint64
}

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

type Service interface {
	CopyTo(ctx context.Context, user string, from, to File, size int64) error

	Compare(ctx context.Context, listMatch bool, user, from, to, fromBucket string, toBucket string) (*CompareRes, error)
}