driver

package

Go to main page

Versions in this module

v0

v0.4.0

Jan 6, 2025

Changes in this version

+ var DeadlockDetected = errors.New("deadlock detected")

+ var UniqueKeyViolation = errors.New("unique key violation")

+ type BasePersistence interface

+ BeginUpdate func() error

+ Close func() error

+ Commit func() error

+ DeleteState func(namespace driver.Namespace, key driver.PKey) error

+ DeleteStates func(namespace driver.Namespace, keys ...driver.PKey) map[driver.PKey]error

+ Discard func() error

+ GetState func(namespace driver.Namespace, key driver.PKey) (V, error)

+ GetStateRangeScanIterator func(namespace driver.Namespace, startKey, endKey driver.PKey) (collections.Iterator[*R], error)

+ GetStateSetIterator func(ns driver.Namespace, keys ...driver.PKey) (collections.Iterator[*R], error)

+ SetState func(namespace driver.Namespace, key driver.PKey, value V) error

+ SetStates func(namespace driver.Namespace, kvs map[driver.PKey]V) map[driver.PKey]error

+ Stats func() any

+ type ColumnKey = string

type Driver

+ NewTransactionalUnversioned func(dataSourceName string, config Config) (TransactionalUnversionedPersistence, error)

+ NewTransactionalVersioned func(dataSourceName string, config Config) (TransactionalVersionedPersistence, error)

+ NewUnversioned func(dataSourceName string, config Config) (UnversionedPersistence, error)

+ type NamedDriver = driver.NamedDriver[Driver]

+ type Notifier interface

+ Subscribe func(callback TriggerCallback) error

+ UnsubscribeAll func() error

+ type Operation int

+ const Delete

+ const Insert

+ const Unknown

+ const Update

+ type QueryExecutor = driver.QueryExecutor

+ type SQLError = error

+ type SQLErrorWrapper interface

+ WrapError func(error) error

+ type TransactionalUnversionedPersistence interface

+ NewWriteTransaction func() (UnversionedWriteTransaction, error)

+ type TriggerCallback func(Operation, map[ColumnKey]string)

+ type UnversionedNotifier interface

+ type UnversionedPersistence interface

+ type UnversionedRead struct

+ Key driver.PKey

+ Raw driver.RawValue

+ type UnversionedResultsIterator = collections.Iterator[*UnversionedRead]

+ type UnversionedValue = driver.RawValue

+ type UnversionedWriteTransaction interface

+ Commit func() error

+ DeleteState func(namespace driver.Namespace, key driver.PKey) error

+ Discard func() error

+ SetState func(namespace driver.Namespace, key driver.PKey, value UnversionedValue) error

+ type VersionedMetadataValue = driver.VersionedMetadataValue

+ type VersionedNotifier interface

type VersionedPersistence

+ SetStateMetadatas func(ns driver.Namespace, kvs map[driver.PKey]driver.VersionedMetadataValue) map[driver.PKey]error

+ type VersionedValue = driver.VersionedValue

type WriteTransaction

+ DeleteState func(namespace driver.Namespace, key driver.PKey) error

v0.3.0

Oct 5, 2023

Changes in this version

type Config

+ IsSet func(key string) bool

type Driver

+ NewTransactionalVersionedPersistence func(sp view.ServiceProvider, dataSourceName string, config Config) (TransactionalVersionedPersistence, error)

+ type TransactionalVersionedPersistence interface

+ NewWriteTransaction func() (WriteTransaction, error)

+ type WriteTransaction interface

+ Commit func() error

+ Discard func() error

+ SetState func(namespace, key string, value []byte, block, txnum uint64) error

v0.2.0

Dec 7, 2022

v0.1.0

Nov 16, 2022

Changes in this version

+ type Config interface

+ UnmarshalKey func(key string, rawVal interface{}) error

+ type Driver interface

+ New func(sp view.ServiceProvider, dataSourceName string, config Config) (Persistence, error)

+ NewVersioned func(sp view.ServiceProvider, dataSourceName string, config Config) (VersionedPersistence, error)

+ type Persistence interface

+ BeginUpdate func() error

+ Close func() error

+ Commit func() error

+ DeleteState func(namespace, key string) error

+ Discard func() error

+ GetState func(namespace, key string) ([]byte, error)

+ GetStateRangeScanIterator func(namespace string, startKey string, endKey string) (ResultsIterator, error)

+ SetState func(namespace, key string, value []byte) error

+ type Read struct

+ Key string

+ Raw []byte

+ type ResultsIterator interface

+ Close func()

+ Next func() (*Read, error)

+ type VersionedPersistence interface

+ BeginUpdate func() error

+ Close func() error

+ Commit func() error

+ DeleteState func(namespace, key string) error

+ Discard func() error

+ GetState func(namespace, key string) ([]byte, uint64, uint64, error)

+ GetStateMetadata func(namespace, key string) (map[string][]byte, uint64, uint64, error)

+ GetStateRangeScanIterator func(namespace string, startKey string, endKey string) (VersionedResultsIterator, error)

+ SetState func(namespace, key string, value []byte, block, txnum uint64) error

+ SetStateMetadata func(namespace, key string, metadata map[string][]byte, block, txnum uint64) error

+ type VersionedRead struct

+ Block uint64

+ IndexInBlock int

+ Key string

+ Raw []byte

+ func (v *VersionedRead) K() string

+ func (v *VersionedRead) V() []byte

+ type VersionedResultsIterator interface

+ Close func()

+ Next func() (*VersionedRead, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL