db

Mar 3, 2024

Changes in this version

+ type Scanner interface

+ Scan func(ctx context.Context, tenantId string, start, end int64, fs *v1.Filters) (arrow.Record, error)

Sep 24, 2023

Changes in this version

+ func Path(dbPath string) string

Sep 21, 2023

Changes in this version

+ func Observe(ctx context.Context, prefix []byte, obs func(context.Context, *badger.KVList))

Sep 1, 2023

Changes in this version

+ func GetRaft(ctx context.Context) *badger.DB

+ func OpenRaft(ctx context.Context, path string) (context.Context, *badger.DB)

+ func SetKeyChangeObserver(ctx context.Context, obs func(context.Context, *badger.KVList) error)

+ type Iter interface

+ Close func()

+ Key func() []byte

+ Next func()

+ Rewind func()

+ Valid func() bool

+ Value func(value func([]byte) error) error

+ type IterOpts struct

+ PrefetchSize int

+ PrefetchValues bool

+ Prefix []byte

+ Reverse bool

+ type Observer struct

+ OnChange func(context.Context, *badger.KVList) error

+ Silent bool

+ func (cb *Observer) Changed(kv *badger.KVList) error

+ type Provider interface

+ NewTransaction func(update bool) Txn

+ Txn func(update bool, f func(txn Txn) error) error

+ With func(func(db *badger.DB) error) error

+ type Txn interface

+ Close func() error

+ Delete func(key []byte) error

+ Get func(key []byte, value func(val []byte) error, notFound ...func() error) error

+ Has func(key []byte) bool

+ Iter func(IterOpts) Iter

+ Set func(key, value []byte) error

+ SetTTL func(key, value []byte, ttl time.Duration) error

Aug 12, 2023

Changes in this version

+ func Open(ctx context.Context, path string) (context.Context, *badger.DB)

Jun 3, 2023

Changes in this version

+ func Check(ctx context.Context) bool

+ func Exists(ctx context.Context, where func(db *gorm.DB) *gorm.DB) bool

+ func ExistsDB(db *gorm.DB, where func(db *gorm.DB) *gorm.DB) bool

+ func Get(ctx context.Context) *gorm.DB

+ func LOG(ctx context.Context, err error, msg string, ...)

+ func Set(ctx context.Context, db *gorm.DB) context.Context