nutsdb

Documentation

Index

• func NewSearchOption(opts ...SearchOption) *searchOption
• type SearchOption
  • func WithEndKey(endKey []byte) SearchOption
  • func WithLimit(limit int) SearchOption
  • func WithOffset(offset int) SearchOption
  • func WithPrefix(prefix []byte) SearchOption
  • func WithReg(reg string) SearchOption
  • func WithStartKey(startKey []byte) SearchOption
• type Table
  • func NewTable(db *nutsdb.DB, name string, ttl uint32) (*Table, error)
  • func (tb *Table) BatchSet(ctx context.Context, args ...[]byte) error
  • func (tb *Table) Delete(ctx context.Context, key []byte) error
  • func (tb *Table) Get(ctx context.Context, key []byte, fn func(val []byte) error) error
  • func (tb *Table) GetTTL(ctx context.Context, key []byte) (int64, error)
  • func (tb *Table) Iterate(ctx context.Context, opt *nutsdb.IteratorOptions, ...) error
  • func (tb *Table) MGet(ctx context.Context, keys [][]byte, fn func(val []byte) error) error
  • func (tb *Table) MSet(ctx context.Context, args ...[]byte) error
  • func (tb Table) Name() string
  • func (tb *Table) Persist(ctx context.Context, key []byte, val []byte) error
  • func (tb *Table) Search(ctx context.Context, cb func(key []byte, value []byte) error, ...) error
  • func (tb *Table) Set(ctx context.Context, key []byte, val []byte) error
  • func (tb Table) TTL() uint32

Functions

func NewSearchOption

func NewSearchOption(opts ...SearchOption) *searchOption

Types

type SearchOption

type SearchOption = func(opt *searchOption)

func WithEndKey

func WithEndKey(endKey []byte) SearchOption

func WithLimit

func WithLimit(limit int) SearchOption

func WithOffset

func WithOffset(offset int) SearchOption

func WithPrefix

func WithPrefix(prefix []byte) SearchOption

func WithReg

func WithReg(reg string) SearchOption

func WithStartKey

func WithStartKey(startKey []byte) SearchOption

type Table

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

func NewTable

func NewTable(db *nutsdb.DB, name string, ttl uint32) (*Table, error)

func (*Table) BatchSet

func (tb *Table) BatchSet(ctx context.Context, args ...[]byte) error

func (*Table) Delete

func (tb *Table) Delete(ctx context.Context, key []byte) error

func (*Table) Get

func (tb *Table) Get(ctx context.Context, key []byte, fn func(val []byte) error) error

func (*Table) GetTTL

func (tb *Table) GetTTL(ctx context.Context, key []byte) (int64, error)

func (*Table) Iterate

func (tb *Table) Iterate(ctx context.Context, opt *nutsdb.IteratorOptions, fn func(key []byte, val []byte) error) error

func (*Table) MGet

func (tb *Table) MGet(ctx context.Context, keys [][]byte, fn func(val []byte) error) error

func (*Table) MSet

func (tb *Table) MSet(ctx context.Context, args ...[]byte) error

func (Table) Name

func (tb Table) Name() string

func (*Table) Persist

func (tb *Table) Persist(ctx context.Context, key []byte, val []byte) error

func (*Table) Search

func (tb *Table) Search(ctx context.Context, cb func(key []byte, value []byte) error, opts ...SearchOption) error

func (*Table) Set

func (tb *Table) Set(ctx context.Context, key []byte, val []byte) error

func (Table) TTL

func (tb Table) TTL() uint32