embed

Documentation

Index

• func Count(dbname, collname string, spec map[string]any) int
• func Distinct(dbname, collname, field string) ([]any, error)
• func Get(dbname, collname string, spec map[string]any, idx, limit int) []map[string]any
• func GetSorted(dbname, collname string, spec map[string]any, skeys []string, ...) []map[string]any
• func InitDB(dbDir string) error
• func Insert(dbname, collname string, records []map[string]any)
• func InsertRecord(dbname, collname string, rec map[string]any) error
• func Remove(dbname, collname string, spec map[string]any) error
• func Update(dbname, collname string, spec, newdata map[string]any)
• func Upsert(dbname, collname, attr string, records []map[string]any) error
• type EmbedDB
  • func (d *EmbedDB) Count(dbname, collname string, spec map[string]any) int
  • func (d *EmbedDB) Distinct(dbname, collname, field string) ([]any, error)
  • func (d *EmbedDB) Get(dbname, collname string, spec map[string]any, idx, limit int) []map[string]any
  • func (d *EmbedDB) GetSorted(dbname, collname string, spec map[string]any, skeys []string, ...) []map[string]any
  • func (d *EmbedDB) InitDB(uri string)
  • func (d *EmbedDB) Insert(dbname, collname string, records []map[string]any)
  • func (d *EmbedDB) InsertRecord(dbname, collname string, rec map[string]any) error
  • func (d *EmbedDB) Remove(dbname, collname string, spec map[string]any) error
  • func (d *EmbedDB) Update(dbname, collname string, spec, newdata map[string]any)
  • func (d *EmbedDB) Upsert(dbname, collname, attr string, records []map[string]any) error

Functions

func Count

func Count(dbname, collname string, spec map[string]any) int

Count records in BadgerDB

func Distinct

func Distinct(dbname, collname, field string) ([]any, error)

Distinct gets number records from document-oriented db

func Get

func Get(dbname, collname string, spec map[string]any, idx, limit int) []map[string]any

Get records from BadgerDB

func GetSorted

func GetSorted(dbname, collname string, spec map[string]any, skeys []string, sortOrder, idx, limit int) []map[string]any

GetSorted fetches records from document-oriented db sorted by given key with specific order

func InitDB

func InitDB(dbDir string) error

InitDB initializes the Badger database

func Insert

func Insert(dbname, collname string, records []map[string]any)

Insert records into BadgerDB

func InsertRecord

func InsertRecord(dbname, collname string, rec map[string]any) error

InsertRecord insert record with given spec to document-oriented db

func Remove

func Remove(dbname, collname string, spec map[string]any) error

Remove records from BadgerDB

func Update

func Update(dbname, collname string, spec, newdata map[string]any)

Update records in BadgerDB

func Upsert

func Upsert(dbname, collname, attr string, records []map[string]any) error

Upsert records into BadgerDB

Types

type EmbedDB

type EmbedDB struct {
}

EmbedDB represent embedded database

func (*EmbedDB) Count

func (d *EmbedDB) Count(dbname, collname string, spec map[string]any) int

Count returns total number of records within database/collection and given spec

func (*EmbedDB) Distinct

func (d *EmbedDB) Distinct(dbname, collname, field string) ([]any, error)

Distinct returns distinct collection of records

func (*EmbedDB) Get

func (d *EmbedDB) Get(dbname, collname string, spec map[string]any, idx, limit int) []map[string]any

Get fetches data from underlying database/collection

func (*EmbedDB) GetSorted

func (d *EmbedDB) GetSorted(dbname, collname string, spec map[string]any, skeys []string, sortOrder, idx, limit int) []map[string]any

GetSorted returns sorted records from given database/collection using provided spec, sorted keys, order and limits

func (*EmbedDB) InitDB

func (d *EmbedDB) InitDB(uri string)

InitDB initialize embedded database

func (*EmbedDB) Insert

func (d *EmbedDB) Insert(dbname, collname string, records []map[string]any)

Insert inserts records into provided database/collection

func (*EmbedDB) InsertRecord

func (d *EmbedDB) InsertRecord(dbname, collname string, rec map[string]any) error

InsertRecord inserts single record into given database/collection

func (*EmbedDB) Remove

func (d *EmbedDB) Remove(dbname, collname string, spec map[string]any) error

Remove deletes records in given database/collection using given spec

func (*EmbedDB) Update

func (d *EmbedDB) Update(dbname, collname string, spec, newdata map[string]any)

Update updates data into given database/collection

func (*EmbedDB) Upsert

func (d *EmbedDB) Upsert(dbname, collname, attr string, records []map[string]any) error

Upsert inserts records into provided database/collection and attribute