kvdb

Documentation

Index

• Variables
• func New(node peer.Node) kvdb.Factory
• type Batch
  • func (b *Batch) Commit() error
  • func (b *Batch) Delete(key string) error
  • func (b *Batch) Put(key string, value []byte) error
• type FilterKeyRegEx
  • func NewFilterKeyRegEx(regexs ...string) (*FilterKeyRegEx, error)
  • func (f *FilterKeyRegEx) Filter(e query.Entry) bool

Variables

var (
	QueryBufferSize        = 1024
	ReadQueryResultTimeout = 50 * time.Millisecond
)

var MaxTimeBetweenGroupedWrites = 5 * time.Millisecond

Functions

func New

func New(node peer.Node) kvdb.Factory

Types

type Batch

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

func (*Batch) Commit

func (b *Batch) Commit() error

func (*Batch) Delete

func (b *Batch) Delete(key string) error

func (*Batch) Put

func (b *Batch) Put(key string, value []byte) error

type FilterKeyRegEx

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

func NewFilterKeyRegEx

func NewFilterKeyRegEx(regexs ...string) (*FilterKeyRegEx, error)

func (*FilterKeyRegEx) Filter

func (f *FilterKeyRegEx) Filter(e query.Entry) bool