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) CHandle() unsafe.Pointer
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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) BeginTemporalRo ¶
func (*DB) BeginTemporalRwNosync ¶
func (*DB) EnsureVersionCompatibility ¶
func (*DB) UpdateNosync ¶
func (*DB) ViewTemporal ¶
Source Files
Click to show internal directories.
Click to hide internal directories.