writecachebadger

package

v0.37.0 Latest Latest Go to latest Published: Dec 7, 2023 License: GPL-3.0 Imports: 34 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

git.frostfs.info/TrueCloudLab/frostfs-node

Links

Open Source Insights

Documentation ¶

Index ¶

func Get(db *badger.DB, key []byte) ([]byte, error)
func IterateDB(db *badger.DB, f func(oid.Address) error) error
func New(opts ...Option) writecache.Cache
func OpenDB(p string, ro bool, l *logger.Logger) (*badger.DB, error)
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Get ¶

func Get(db *badger.DB, key []byte) ([]byte, error)

Get fetches object from the underlying database. Key should be a stringified address.

Returns an error of type apistatus.ObjectNotFound if the requested object is missing in db.

func IterateDB ¶

func IterateDB(db *badger.DB, f func(oid.Address) error) error

IterateDB iterates over all objects stored in badger.DB instance and passes them to f until error return. It is assumed that db is an underlying database of some WriteCache instance.

DB must not be nil and should be opened.

func New ¶

func New(opts ...Option) writecache.Cache

New creates new writecache instance.

func OpenDB ¶

func OpenDB(p string, ro bool, l *logger.Logger) (*badger.DB, error)

OpenDB opens a badger instance for write-cache. Opens in read-only mode if ro is true.

Types ¶

type Option ¶

type Option func(*options)

Option represents write-cache configuration option.

func WithBlobstor ¶

func WithBlobstor(bs writecache.MainStorage) Option

WithBlobstor sets main object storage.

func WithFlushWorkersCount ¶

func WithFlushWorkersCount(c int) Option

func WithGCInterval ¶

func WithGCInterval(d time.Duration) Option

WithGCInterval sets the duration of the interval to run GC cycles.

func WithLogger ¶

func WithLogger(log *logger.Logger) Option

WithLogger sets logger.

func WithMaxCacheSize ¶

func WithMaxCacheSize(sz uint64) Option

WithMaxCacheSize sets maximum write-cache size in bytes.

func WithMaxObjectSize ¶

func WithMaxObjectSize(sz uint64) Option

WithMaxObjectSize sets maximum object size to be stored in write-cache.

func WithMetabase ¶

func WithMetabase(db writecache.Metabase) Option

WithMetabase sets metabase.

func WithMetrics ¶

func WithMetrics(metrics writecache.Metrics) Option

WithMetrics sets metrics implementation.

func WithPath ¶

func WithPath(path string) Option

WithPath sets path to writecache db.

func WithReportErrorFunc ¶

func WithReportErrorFunc(f func(string, error)) Option

WithReportErrorFunc sets error reporting function.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL