common

type ConcurrencyLimiter interface {
	AcquireWorkSlot(ctx context.Context) (ReleaseFunc, error)
}

type DeletePrm struct {
	Address   oid.Address
	StorageID []byte
	Size      uint64
}

type DeleteRes struct{}

type ExistsPrm struct {
	Address   oid.Address
	StorageID []byte
}

type ExistsRes struct {
	Exists bool
}

type GetPrm struct {
	Address   oid.Address
	StorageID []byte
	Raw       bool
}

type GetRangePrm struct {
	Address   oid.Address
	Range     objectSDK.Range
	StorageID []byte
}

type GetRangeRes struct {
	Data []byte
}

type GetRes struct {
	Object  *objectSDK.Object
	RawData []byte
}

type IteratePrm struct {
	Handler      IterationHandler
	IgnoreErrors bool
}

type IterateRes struct{}

type IterationElement struct {
	ObjectData []byte
	Address    oid.Address
	StorageID  []byte
}

type IterationHandler func(IterationElement) error

type MetaStorage interface {
	UpdateStorageID(ctx context.Context, addr oid.Address, storageID []byte) error
}

type PutPrm struct {
	Address      oid.Address
	Object       *objectSDK.Object
	RawData      []byte
	DontCompress bool
}

type PutRes struct {
	StorageID []byte
}

type RateLimiter interface {
	ReadRequest(context.Context) (ReleaseFunc, error)
	WriteRequest(context.Context) (ReleaseFunc, error)
}

type RebuildLimiter interface {
	ConcurrencyLimiter
	RateLimiter
}

type RebuildPrm struct {
	MetaStorage MetaStorage
	Limiter     RebuildLimiter
	FillPercent int
}

type RebuildRes struct {
	ObjectsMoved uint64
	FilesRemoved uint64
}

type ReleaseFunc func()

type Storage interface {
	Open(mode mode.ComponentMode) error
	Init() error
	Close(context.Context) error

	Type() string
	Path() string
	ObjectsCount(ctx context.Context) (uint64, error)

	SetCompressor(cc *compression.Compressor)
	Compressor() *compression.Compressor

	// SetReportErrorFunc allows to provide a function to be called on disk errors.
	// This function MUST be called before Open.
	SetReportErrorFunc(f func(context.Context, string, error))
	SetParentID(parentID string)

	Get(context.Context, GetPrm) (GetRes, error)
	GetRange(context.Context, GetRangePrm) (GetRangeRes, error)
	Exists(context.Context, ExistsPrm) (ExistsRes, error)
	Put(context.Context, PutPrm) (PutRes, error)
	Delete(context.Context, DeletePrm) (DeleteRes, error)
	Iterate(context.Context, IteratePrm) (IterateRes, error)
	Rebuild(context.Context, RebuildPrm) (RebuildRes, error)
}