badger

Documentation

Index

• Constants
• func NewFromCmdlineOptions() plugin.Plugin
• type BadgerLogger
  • func NewBadgerLogger(logger *slog.Logger) *BadgerLogger
  • func (b *BadgerLogger) Debugf(msg string, args ...any)
  • func (b *BadgerLogger) Errorf(msg string, args ...any)
  • func (b *BadgerLogger) Infof(msg string, args ...any)
  • func (b *BadgerLogger) Warningf(msg string, args ...any)
• type BlobStoreBadger
  • func New(opts ...BlobStoreBadgerOptionFunc) (*BlobStoreBadger, error)
  • func (d *BlobStoreBadger) Close() error
  • func (d *BlobStoreBadger) DB() *badger.DB
  • func (b *BlobStoreBadger) GetCommitTimestamp() (int64, error)
  • func (d *BlobStoreBadger) NewTransaction(update bool) *badger.Txn
  • func (b *BlobStoreBadger) SetCommitTimestamp(txn *badger.Txn, timestamp int64) error
  • func (d *BlobStoreBadger) Start() error
  • func (d *BlobStoreBadger) Stop() error
• type BlobStoreBadgerOptionFunc
  • func WithBlockCacheSize(size uint64) BlobStoreBadgerOptionFunc
  • func WithDataDir(dataDir string) BlobStoreBadgerOptionFunc
  • func WithGc(enabled bool) BlobStoreBadgerOptionFunc
  • func WithIndexCacheSize(size uint64) BlobStoreBadgerOptionFunc
  • func WithLogger(logger *slog.Logger) BlobStoreBadgerOptionFunc
  • func WithPromRegistry(registry prometheus.Registerer) BlobStoreBadgerOptionFunc

Constants

const (
	DefaultBlockCacheSize = 1610612736 // 1.5GB (increased from 768MB)
	DefaultIndexCacheSize = 536870912  // 512MB (increased from 256MB)
)

Default cache sizes for BadgerDB (in bytes)

Functions

func NewFromCmdlineOptions

func NewFromCmdlineOptions() plugin.Plugin

Types

type BadgerLogger

type BadgerLogger struct {
	// contains filtered or unexported fields
}

BadgerLogger is a wrapper type to give our logger the expected interface

func NewBadgerLogger

func NewBadgerLogger(logger *slog.Logger) *BadgerLogger

func (*BadgerLogger) Debugf

func (b *BadgerLogger) Debugf(msg string, args ...any)

func (*BadgerLogger) Errorf

func (b *BadgerLogger) Errorf(msg string, args ...any)

func (*BadgerLogger) Infof

func (b *BadgerLogger) Infof(msg string, args ...any)

func (*BadgerLogger) Warningf

func (b *BadgerLogger) Warningf(msg string, args ...any)

type BlobStoreBadger

type BlobStoreBadger struct {
	// contains filtered or unexported fields
}

BlobStoreBadger stores all data in badger. Data may not be persisted

func New

func New(opts ...BlobStoreBadgerOptionFunc) (*BlobStoreBadger, error)

New creates a new database

func (*BlobStoreBadger) Close

func (d *BlobStoreBadger) Close() error

Close gets the database handle from our BlobStore and closes it

func (*BlobStoreBadger) DB

func (d *BlobStoreBadger) DB() *badger.DB

DB returns the database handle

func (*BlobStoreBadger) GetCommitTimestamp

func (b *BlobStoreBadger) GetCommitTimestamp() (int64, error)

func (*BlobStoreBadger) NewTransaction

func (d *BlobStoreBadger) NewTransaction(update bool) *badger.Txn

NewTransaction creates a new badger transaction

func (*BlobStoreBadger) SetCommitTimestamp

func (b *BlobStoreBadger) SetCommitTimestamp(
	txn *badger.Txn,
	timestamp int64,
) error

func (*BlobStoreBadger) Start

func (d *BlobStoreBadger) Start() error

Start implements the plugin.Plugin interface

func (*BlobStoreBadger) Stop

func (d *BlobStoreBadger) Stop() error

Stop implements the plugin.Plugin interface

type BlobStoreBadgerOptionFunc

type BlobStoreBadgerOptionFunc func(*BlobStoreBadger)

func WithBlockCacheSize

func WithBlockCacheSize(size uint64) BlobStoreBadgerOptionFunc

WithBlockCacheSize specifies the block cache size

func WithDataDir

func WithDataDir(dataDir string) BlobStoreBadgerOptionFunc

WithDataDir specifies the data directory to use for storage

func WithGc

func WithGc(enabled bool) BlobStoreBadgerOptionFunc

WithGc specifies whether garbage collection is enabled

func WithIndexCacheSize

func WithIndexCacheSize(size uint64) BlobStoreBadgerOptionFunc

WithIndexCacheSize specifies the index cache size

func WithLogger

func WithLogger(logger *slog.Logger) BlobStoreBadgerOptionFunc

WithLogger specifies the logger object to use for logging messages

func WithPromRegistry

func WithPromRegistry(
	registry prometheus.Registerer,
) BlobStoreBadgerOptionFunc

WithPromRegistry specifies the prometheus registry to use for metrics