clouddb

May 23, 2024

Changes in this version

type DB

+ func (d *DB) Validate() error

Jun 19, 2023

Changes in this version

type DB

+ func (d *DB) Search(typ string, search map[string]any) (Iterator, error)

Jun 19, 2023

Changes in this version

type DB

+ func (d *DB) NewIterator(start, limit []byte) Iterator

+ func (d *DB) NewIteratorPrefix(pfx []byte) Iterator

+ type Iterator interface

+ Apply func(v any) error

+ Key func() []byte

+ Next func() bool

+ Prev func() bool

+ Release func()

+ Seek func([]byte) bool

+ Value func() []byte

Jun 19, 2023

Changes in this version

+ func ValidateBackup(r io.Reader) error

type DB

+ func (d *DB) BackupTo(w io.Writer) error

+ func (d *DB) Reindex() error

+ func (d *DB) RestoreFrom(r io.Reader) error

Jun 15, 2023

Changes in this version

type Status

+ func (s Status) String() string

Jun 15, 2023

Changes in this version

type DB

+ func (d *DB) Has(id []byte) (bool, error)

Jun 15, 2023

Changes in this version

+ const PktFetchLog

+ const PktGetInfo

+ const PktGetInfoResp

+ const PktGetLogIds

+ const PktLogIdsPush

+ const PktLogPush

+ const RecordDelete

+ const RecordSet

+ const ResponseFlag

+ var ErrKeyConflict = errors.New("record's key conflicts with an existing record")

+ func ApplyUpdate(obj any, upd any) (any, error)

+ func ComputeDelta(old, now any) (any, error)

+ func RegisterType(t *Type)

+ type DB struct

+ func New(name string, rpc RPC) (*DB, error)

+ func (d *DB) Close() error

+ func (d *DB) DebugDump(w io.Writer)

+ func (d *DB) Delete(id []byte) error

+ func (d *DB) Get(id []byte, target any) error

+ func (d *DB) GetRaw(id []byte) (json.RawMessage, error)

+ func (d *DB) GetStatus() Status

+ func (d *DB) SearchFirst(typ string, search map[string]any, target any) ([]byte, error)

+ func (d *DB) SearchFirstRaw(typ string, search map[string]any) ([]byte, json.RawMessage, error)

+ func (d *DB) Set(id []byte, val any) error

+ func (d *DB) String() string

+ func (d *DB) WaitReady()

+ type RPC interface

+ All func(ctx context.Context, data []byte) ([]any, error)

+ Broadcast func(ctx context.Context, data []byte) error

+ Connect func(cb func(context.Context, []byte) ([]byte, error))

+ CountAllPeers func() int

+ ListOnlinePeers func() []string

+ Request func(ctx context.Context, id string, data []byte) ([]byte, error)

+ Self func() string

+ Send func(ctx context.Context, id string, data []byte) error

+ type Status int

+ const Error

+ const Initializing

+ const Ready

+ const Syncing

+ type Type struct

+ Keys []*TypeKey

+ Name string

+ Version int

+ func (t *Type) Hash() []byte

+ type TypeKey struct

+ Fields []string

+ Method string

+ Name string

+ Unique bool