engine

type Object interface {
	Exists() bool

	Quarantine() error

	Metadata() map[string]string

	ContentLength() int64

	CopyRange(io.Writer, int64, int64) (int64, error)

	Copy(...io.Writer) (int64, error)

	SetData(size int64) (io.Writer, error)

	Commit(metadata map[string]string) error

	CommitMeta(metadata map[string]string) error

	Delete(metadata map[string]string) error

	Close() error

	Repr() string
}

type ObjectEngine interface {
	New(vars map[string]string, needData bool) (Object, error)

	GetHashes(device, partition string, recalculate []string) (map[string]string, error)

	Close() error
}

type ObjectEngineConstructor func(conf.Config, *conf.Policy, *flag.FlagSet, *sync.WaitGroup) (ObjectEngine, error)