remotedb

Documentation

Index

• func NewRemote(v gointerfaces.Version, logger log.Logger, remoteKV remote.KVClient) remoteOpts
• type DB
  • func (db *DB) AllTables() kv.TableCfg
  • func (db *DB) BeginRo(ctx context.Context) (txn kv.Tx, err error)
  • func (db *DB) BeginRw(ctx context.Context) (kv.RwTx, error)
  • func (db *DB) BeginRwNosync(ctx context.Context) (kv.RwTx, error)
  • func (db *DB) BeginTemporalRo(ctx context.Context) (kv.TemporalTx, error)
  • func (db *DB) BeginTemporalRw(ctx context.Context) (kv.RwTx, error)
  • func (db *DB) BeginTemporalRwNosync(ctx context.Context) (kv.RwTx, error)
  • func (db *DB) Close()
  • func (db *DB) EnsureVersionCompatibility() bool
  • func (db *DB) PageSize() uint64
  • func (db *DB) ReadOnly() bool
  • func (db *DB) Update(ctx context.Context, f func(tx kv.RwTx) error) (err error)
  • func (db *DB) UpdateNosync(ctx context.Context, f func(tx kv.RwTx) error) (err error)
  • func (db *DB) View(ctx context.Context, f func(tx kv.Tx) error) (err error)
  • func (db *DB) ViewTemporal(ctx context.Context, f func(tx kv.TemporalTx) error) (err error)

Functions

func NewRemote

func NewRemote(v gointerfaces.Version, logger log.Logger, remoteKV remote.KVClient) remoteOpts

NewRemote defines new remove KV connection (without actually opening it) version parameters represent the version the KV client is expecting, compatibility check will be performed when the KV connection opens

Types

type DB

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

func (*DB) AllTables

func (db *DB) AllTables() kv.TableCfg

func (*DB) BeginRo

func (db *DB) BeginRo(ctx context.Context) (txn kv.Tx, err error)

func (*DB) BeginRw

func (db *DB) BeginRw(ctx context.Context) (kv.RwTx, error)

func (*DB) BeginRwNosync

func (db *DB) BeginRwNosync(ctx context.Context) (kv.RwTx, error)

func (*DB) BeginTemporalRo

func (db *DB) BeginTemporalRo(ctx context.Context) (kv.TemporalTx, error)

func (*DB) BeginTemporalRw

func (db *DB) BeginTemporalRw(ctx context.Context) (kv.RwTx, error)

func (*DB) BeginTemporalRwNosync

func (db *DB) BeginTemporalRwNosync(ctx context.Context) (kv.RwTx, error)

func (*DB) Close

func (db *DB) Close()

func (*DB) EnsureVersionCompatibility

func (db *DB) EnsureVersionCompatibility() bool

func (*DB) PageSize

func (db *DB) PageSize() uint64

func (*DB) ReadOnly

func (db *DB) ReadOnly() bool

func (*DB) Update

func (db *DB) Update(ctx context.Context, f func(tx kv.RwTx) error) (err error)

func (*DB) UpdateNosync

func (db *DB) UpdateNosync(ctx context.Context, f func(tx kv.RwTx) error) (err error)

func (*DB) View

func (db *DB) View(ctx context.Context, f func(tx kv.Tx) error) (err error)

func (*DB) ViewTemporal

func (db *DB) ViewTemporal(ctx context.Context, f func(tx kv.TemporalTx) error) (err error)