dbwrapper

Documentation

Index

• func ScheduleJob(txw *WriteTxWrapper) func(name string, params interface{}) error
• type DB
  • func New(db bolted.Database, vm *goja.Runtime, logger logr.Logger) *DB
  • func (db *DB) Read(f func(*readTxWrapper) (interface{}, error)) (res interface{}, err error)
  • func (db *DB) Watch(matcher []string, fn func(interface{}) (bool, error)) (*observeSelectable, func())
  • func (db *DB) Write(f func(*WriteTxWrapper) (interface{}, error)) (res interface{}, err error)
• type WriteTxWrapper
  • func (wtw *WriteTxWrapper) CreateMap(path dbpath.Path) error
  • func (wtw *WriteTxWrapper) Delete(path dbpath.Path) error
  • func (wtw *WriteTxWrapper) Exists(path []string) (bool, error)
  • func (wtw *WriteTxWrapper) Get(path []string) (string, error)
  • func (wtw *WriteTxWrapper) ID() (uint64, error)
  • func (wtw *WriteTxWrapper) IsMap(path []string) (bool, error)
  • func (wtw *WriteTxWrapper) Iterator(path []string) (*iteratorWrapper, error)
  • func (wtw *WriteTxWrapper) IteratorFor(path []string, seek string, limit int) (*goja.Object, error)
  • func (wtw *WriteTxWrapper) Put(path dbpath.Path, value string) error
  • func (wtw *WriteTxWrapper) ReverseIteratorFor(path []string, seek string, limit int) (*goja.Object, error)
  • func (wtw *WriteTxWrapper) Size(path []string) (uint64, error)

Functions

func ScheduleJob

func ScheduleJob(txw *WriteTxWrapper) func(name string, params interface{}) error

Types

type DB

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

func New

func New(db bolted.Database, vm *goja.Runtime, logger logr.Logger) *DB

func (*DB) Read

func (db *DB) Read(f func(*readTxWrapper) (interface{}, error)) (res interface{}, err error)

func (*DB) Watch

func (db *DB) Watch(matcher []string, fn func(interface{}) (bool, error)) (*observeSelectable, func())

func (*DB) Write

func (db *DB) Write(f func(*WriteTxWrapper) (interface{}, error)) (res interface{}, err error)

type WriteTxWrapper

type WriteTxWrapper struct {
	VM *goja.Runtime
	bolted.WriteTx
}

func (*WriteTxWrapper) CreateMap

func (wtw *WriteTxWrapper) CreateMap(path dbpath.Path) error

func (*WriteTxWrapper) Delete

func (wtw *WriteTxWrapper) Delete(path dbpath.Path) error

func (*WriteTxWrapper) Exists

func (wtw *WriteTxWrapper) Exists(path []string) (bool, error)

func (*WriteTxWrapper) Get

func (wtw *WriteTxWrapper) Get(path []string) (string, error)

func (*WriteTxWrapper) ID

func (wtw *WriteTxWrapper) ID() (uint64, error)

func (*WriteTxWrapper) IsMap

func (wtw *WriteTxWrapper) IsMap(path []string) (bool, error)

func (*WriteTxWrapper) Iterator

func (wtw *WriteTxWrapper) Iterator(path []string) (*iteratorWrapper, error)

func (*WriteTxWrapper) IteratorFor

func (wtw *WriteTxWrapper) IteratorFor(path []string, seek string, limit int) (*goja.Object, error)

func (*WriteTxWrapper) Put

func (wtw *WriteTxWrapper) Put(path dbpath.Path, value string) error

func (*WriteTxWrapper) ReverseIteratorFor

func (wtw *WriteTxWrapper) ReverseIteratorFor(path []string, seek string, limit int) (*goja.Object, error)

func (*WriteTxWrapper) Size

func (wtw *WriteTxWrapper) Size(path []string) (uint64, error)