postgres

package

Go to main page

Versions in this module

v0

v0.7.0

Dec 2, 2025

Changes in this version

+ func NewBytePrimaryKey(name driver.ColumnKey) *primaryKey

+ func WithContainerImage(name string) option

+ func WithContainerName(name string) option

+ func WithDBName(name string) option

+ func WithHost(host string) option

+ func WithPassword(pw string) option

+ func WithPort(port string) option

+ func WithUser(user string) option

type ContainerConfig

+ func ConfigFromDataSource(s string) (*ContainerConfig, error)

+ func ConfigFromEnv() *ContainerConfig

type KeyValueStoreNotifier

+ func (db *KeyValueStoreNotifier) Close() error

type Logger

+ Debugf func(format string, args ...any)

type Notifier

+ func (db *Notifier) Close() error

v0.6.0

Oct 2, 2025

v0.5.2

Sep 30, 2025

v0.5.1

Sep 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)

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