forked from TrueCloudLab/frostfs-node
[#312] wc: Delete unused Iterate method
Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
parent
cf8531ccd7
commit
d4a2d0d3e8
2 changed files with 0 additions and 55 deletions
|
@ -4,7 +4,6 @@ import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
|
||||||
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/blobstor/common"
|
|
||||||
oid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/object/id"
|
oid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/object/id"
|
||||||
"go.etcd.io/bbolt"
|
"go.etcd.io/bbolt"
|
||||||
)
|
)
|
||||||
|
@ -12,59 +11,6 @@ import (
|
||||||
// ErrNoDefaultBucket is returned by IterateDB when default bucket for objects is missing.
|
// ErrNoDefaultBucket is returned by IterateDB when default bucket for objects is missing.
|
||||||
var ErrNoDefaultBucket = errors.New("no default bucket")
|
var ErrNoDefaultBucket = errors.New("no default bucket")
|
||||||
|
|
||||||
// IterationPrm contains iteration parameters.
|
|
||||||
type IterationPrm struct {
|
|
||||||
handler func([]byte) error
|
|
||||||
ignoreErrors bool
|
|
||||||
}
|
|
||||||
|
|
||||||
// WithHandler sets a callback to be executed on every object.
|
|
||||||
func (p *IterationPrm) WithHandler(f func([]byte) error) {
|
|
||||||
p.handler = f
|
|
||||||
}
|
|
||||||
|
|
||||||
// WithIgnoreErrors sets a flag indicating that errors should be ignored.
|
|
||||||
func (p *IterationPrm) WithIgnoreErrors(ignore bool) {
|
|
||||||
p.ignoreErrors = ignore
|
|
||||||
}
|
|
||||||
|
|
||||||
// Iterate iterates over all objects present in write cache.
|
|
||||||
// This is very difficult to do correctly unless write-cache is put in read-only mode.
|
|
||||||
// Thus we silently fail if shard is not in read-only mode to avoid reporting misleading results.
|
|
||||||
func (c *cache) Iterate(prm IterationPrm) error {
|
|
||||||
c.modeMtx.RLock()
|
|
||||||
defer c.modeMtx.RUnlock()
|
|
||||||
if !c.readOnly() {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
|
|
||||||
err := c.db.View(func(tx *bbolt.Tx) error {
|
|
||||||
b := tx.Bucket(defaultBucket)
|
|
||||||
return b.ForEach(func(k, data []byte) error {
|
|
||||||
return prm.handler(data)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
var fsPrm common.IteratePrm
|
|
||||||
fsPrm.IgnoreErrors = prm.ignoreErrors
|
|
||||||
fsPrm.LazyHandler = func(addr oid.Address, f func() ([]byte, error)) error {
|
|
||||||
data, err := f()
|
|
||||||
if err != nil {
|
|
||||||
if prm.ignoreErrors {
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return prm.handler(data)
|
|
||||||
}
|
|
||||||
|
|
||||||
_, err = c.fsTree.Iterate(fsPrm)
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
// IterateDB iterates over all objects stored in bbolt.DB instance and passes them to f until error return.
|
// IterateDB iterates over all objects stored in bbolt.DB instance and passes them to f until error return.
|
||||||
// It is assumed that db is an underlying database of some WriteCache instance.
|
// It is assumed that db is an underlying database of some WriteCache instance.
|
||||||
//
|
//
|
||||||
|
|
|
@ -32,7 +32,6 @@ type Cache interface {
|
||||||
// Returns apistatus.ObjectNotFound if object is missing in the Cache.
|
// Returns apistatus.ObjectNotFound if object is missing in the Cache.
|
||||||
// Returns ErrReadOnly if the Cache is currently in the read-only mode.
|
// Returns ErrReadOnly if the Cache is currently in the read-only mode.
|
||||||
Delete(context.Context, oid.Address) error
|
Delete(context.Context, oid.Address) error
|
||||||
Iterate(IterationPrm) error
|
|
||||||
Put(context.Context, common.PutPrm) (common.PutRes, error)
|
Put(context.Context, common.PutPrm) (common.PutRes, error)
|
||||||
SetMode(mode.Mode) error
|
SetMode(mode.Mode) error
|
||||||
SetLogger(*logger.Logger)
|
SetLogger(*logger.Logger)
|
||||||
|
|
Loading…
Reference in a new issue