badger

Documentation

Index

• type Config
• type Module
  • func (filter *Module) Add(bucket string, key []byte) error
  • func (filter *Module) AddValue(bucket string, key []byte, value []byte) error
  • func (filter *Module) AddValueCompress(bucket string, key []byte, value []byte) error
  • func (filter *Module) CheckThenAdd(bucket string, key []byte) (b bool, err error)
  • func (filter *Module) Close() error
  • func (filter *Module) Delete(bucket string, key []byte) error
  • func (filter *Module) DeleteKey(bucket string, key []byte) error
  • func (filter *Module) Exists(bucket string, key []byte) bool
  • func (filter *Module) ExistsKey(bucket string, key []byte) (bool, error)
  • func (filter *Module) GetCompressedValue(bucket string, key []byte) ([]byte, error)
  • func (filter *Module) GetValue(bucket string, key []byte) ([]byte, error)
  • func (module *Module) Name() string
  • func (filter *Module) Open() error
  • func (module *Module) Setup()
  • func (module *Module) Start() error
  • func (module *Module) Stop() error

Types

type Config

type Config struct {
	Enabled bool `config:"enabled"`

	SingleBucketMode   bool   `config:"single_bucket_mode"`
	Path               string `config:"path"`
	InMemoryMode       bool   `config:"memory_mode"`
	SyncWrites         bool   `config:"sync_writes"`
	MemTableSize       int64  `config:"mem_table_size"`
	ValueLogFileSize   int64  `config:"value_log_file_size"`
	ValueThreshold     int64  `config:"value_threshold"`
	ValueLogMaxEntries uint32 `config:"value_log_max_entries"`
	NumMemtables       int    `config:"num_mem_tables"`

	NumLevelZeroTables      int `config:"num_level0_tables"`
	NumLevelZeroTablesStall int `config:"num_level0_tables_stall"`

	ValueLogGCEnabled           bool    `config:"value_log_gc_enabled"`
	ValueLogDiscardRatio        float64 `config:"value_log_gc_discard_ratio"`
	ValueLogGCIntervalInSeconds int     `config:"value_log_gc_interval_in_seconds"`
}

type Module

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

func (*Module) Add

func (filter *Module) Add(bucket string, key []byte) error

func (*Module) AddValue

func (filter *Module) AddValue(bucket string, key []byte, value []byte) error

func (*Module) AddValueCompress

func (filter *Module) AddValueCompress(bucket string, key []byte, value []byte) error

func (*Module) CheckThenAdd

func (filter *Module) CheckThenAdd(bucket string, key []byte) (b bool, err error)

func (*Module) Close

func (filter *Module) Close() error

func (*Module) Delete

func (filter *Module) Delete(bucket string, key []byte) error

func (*Module) DeleteKey

func (filter *Module) DeleteKey(bucket string, key []byte) error

func (*Module) Exists

func (filter *Module) Exists(bucket string, key []byte) bool

func (*Module) ExistsKey

func (filter *Module) ExistsKey(bucket string, key []byte) (bool, error)

func (*Module) GetCompressedValue

func (filter *Module) GetCompressedValue(bucket string, key []byte) ([]byte, error)

func (*Module) GetValue

func (filter *Module) GetValue(bucket string, key []byte) ([]byte, error)

for kv implementation

func (*Module) Name

func (module *Module) Name() string

func (*Module) Open

func (filter *Module) Open() error

func (*Module) Setup

func (module *Module) Setup()

func (*Module) Start

func (module *Module) Start() error

func (*Module) Stop

func (module *Module) Stop() error