models

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
}

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)
	SetLogger(*logger.Logger, []zap.Field)

	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)
}