Versions in this module Expand all Collapse all v0 v0.6.0 Oct 2, 2025 v0.5.0 Jul 16, 2025 v0.4.1 Jul 16, 2025 Changes in this version + const Persistence + const PostgresImage + var AllOperations = []driver.Operation + var IsolationLevels = isolationLevelMapper + func NewConditionInterpreter() *interpreter + func NewNamedDriver(config driver.Config, dbProvider DbProvider) driver.NamedDriver + func NewPaginationInterpreter() common.PagInterpreter + func NewPersistenceWithOpts[V common3.DBObject](cfg *ConfigProvider, dbProvider DbProvider, name driver.PersistenceName, ...) (V, error) + func NewSanitizer() *stringSanitizer + func NewSimplePrimaryKey(name driver.ColumnKey) *primaryKey + func Open(opts Opts) (*common.RWDB, error) + func StartPostgres(t Logger, printLogs bool) (func(), string, error) + func StartPostgresWithFmt(configs []*ContainerConfig) (func(), error) + type AuditInfoStore struct + func NewAuditInfoStore(dbs *common2.RWDB, tables common3.TableNames) (*AuditInfoStore, error) + type BindingStore struct + func NewBindingStore(dbs *common2.RWDB, tables common3.TableNames) (*BindingStore, error) + func (db *BindingStore) PutBinding(ctx context.Context, ephemeral, longTerm view.Identity) error + type Config struct + DataSource string + MaxIdleConns *int + MaxIdleTime *time.Duration + MaxOpenConns int + SkipCreateTable bool + TableNameParams []string + TablePrefix string + Tracing *common2.TracingConfig + type ConfigProvider struct + func NewConfigProvider(config config) *ConfigProvider + func (r *ConfigProvider) GetOpts(name driver.PersistenceName, params ...string) (*Config, error) + type ContainerConfig struct + Container string + Image string + func DefaultConfig(node string) *ContainerConfig + func ReadDataSource(s string) (*ContainerConfig, error) + type DataSourceProvider interface + DataSource func() string + type DbConfig struct + DBName string + Host string + Pass string + Port int + User string + func (c *DbConfig) DataSource() string + type DbProvider interface + Get func(Opts) (*common.RWDB, error) + func NewDbProvider() DbProvider + type Driver struct + func NewDriver(config driver.Config) *Driver + func NewDriverWithDbProvider(config driver.Config, dbProvider DbProvider) *Driver + func (d *Driver) NewAuditInfo(name driver.PersistenceName, params ...string) (driver.AuditInfoStore, error) + func (d *Driver) NewBinding(name driver.PersistenceName, params ...string) (driver.BindingStore, error) + func (d *Driver) NewKVS(name driver.PersistenceName, params ...string) (driver.KeyValueStore, error) + func (d *Driver) NewSignerInfo(name driver.PersistenceName, params ...string) (driver.SignerInfoStore, error) + type ErrorMapper struct + func (m *ErrorMapper) WrapError(err error) error + type KeyValueStore struct + func NewKeyValueStore(dbs *common3.RWDB, tables common4.TableNames) (*KeyValueStore, error) + func (db *KeyValueStore) GetStateRangeScanIterator(ctx context.Context, ns driver.Namespace, startKey, endKey string) (iterators.Iterator[*driver.UnversionedRead], error) + func (db *KeyValueStore) GetStateSetIterator(ctx context.Context, ns driver.Namespace, keys ...driver.PKey) (iterators.Iterator[*driver.UnversionedRead], error) + func (db *KeyValueStore) SetStateWithTx(ctx context.Context, tx *sql.Tx, ns driver.Namespace, pkey driver.PKey, ...) error + func (db *KeyValueStore) SetStates(ctx context.Context, ns driver.Namespace, ...) map[driver.PKey]error + type KeyValueStoreNotifier struct + func (db *KeyValueStoreNotifier) CreateSchema() error + type Logger interface + Errorf func(string, ...any) + Log func(...any) + type Notifier struct + func NewNotifier(writeDB *sql.DB, table, dataSource string, notifyOperations []driver.Operation, ...) *Notifier + func (db *Notifier) CreateSchema() error + func (db *Notifier) GetSchema() string + func (db *Notifier) Subscribe(callback driver.TriggerCallback) error + func (db *Notifier) UnsubscribeAll() error + type Opts struct + DataSource string + MaxIdleConns int + MaxIdleTime time.Duration + MaxOpenConns int + TableNameParams []string + TablePrefix string + Tracing *common2.TracingConfig + type SignerInfoStore struct + func NewSignerInfoStore(dbs *common2.RWDB, tables common3.TableNames) (*SignerInfoStore, error)
Go to main page