Versions in this module Expand all Collapse all v0 v0.14.1 Jul 7, 2026 Changes in this version + var AllOperations = []driver.Operation + func NewAdvisoryLockFactory() ... + func NewCleanupLeaderFactory() ... + func NewConditionInterpreter() *interpreter + func NewNamedDriver(config driver3.Config, dbProvider fscPostgres.DbProvider) driver3.NamedDriver + func NewPaginationInterpreter() common.PagInterpreter + type AdvisoryLock struct + func NewAdvisoryLock(ctx context.Context, db *sql.DB, lockID int64) (*AdvisoryLock, bool, error) + func (l *AdvisoryLock) Close() error + type AuditTransactionStore struct + func NewAuditTransactionStore(dbs *scommon.RWDB, tableNames sqlcommon.TableNames) (*AuditTransactionStore, error) + func (s *AuditTransactionStore) CreateSchema() error + func (s *AuditTransactionStore) GetSchema() string + func (s *AuditTransactionStore) WriteDB() *sql.DB + type Driver struct + AuditTx lazy.Provider[fscPostgres.Config, *AuditTransactionStore] + Endorser lazy.Provider[fscPostgres.Config, *EndorserStore] + Identity lazy.Provider[fscPostgres.Config, *IdentityStore] + KeyStore lazy.Provider[fscPostgres.Config, *KeystoreStore] + OwnerTx lazy.Provider[fscPostgres.Config, *TransactionStore] + Token lazy.Provider[fscPostgres.Config, *TokenStore] + TokenLock lazy.Provider[fscPostgres.Config, *TokenLockStore] + Wallet lazy.Provider[fscPostgres.Config, *WalletStore] + func NewDriver(config driver3.Config) *Driver + func NewDriverWithDbProvider(config driver3.Config, dbProvider fscPostgres.DbProvider) *Driver + func (d *Driver) NewAuditTransaction(name driver2.PersistenceName, params ...string) (driver3.AuditTransactionStore, error) + func (d *Driver) NewEndorser(name driver2.PersistenceName, params ...string) (driver3.EndorserStore, error) + func (d *Driver) NewIdentity(name driver2.PersistenceName, params ...string) (driver3.IdentityStore, error) + func (d *Driver) NewKeyStore(name driver2.PersistenceName, params ...string) (driver3.KeyStore, error) + func (d *Driver) NewOwnerTransaction(name driver2.PersistenceName, params ...string) (driver3.TokenTransactionStore, error) + func (d *Driver) NewToken(name driver2.PersistenceName, params ...string) (driver3.TokenStore, error) + func (d *Driver) NewTokenLock(name driver2.PersistenceName, params ...string) (driver3.TokenLockStore, error) + func (d *Driver) NewWallet(name driver2.PersistenceName, params ...string) (driver3.WalletStore, error) + type EndorserStore struct + func NewEndorserStore(dbs *scommon.RWDB, tables common3.TableNames) (*EndorserStore, error) + func (s *EndorserStore) CreateSchema() error + func (s *EndorserStore) GetSchema() string + type IdentityNotifier struct + func NewIdentityNotifier(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, dataSource string) (*IdentityNotifier, error) + func (n *IdentityNotifier) Subscribe(callback func(idriver.Operation, idriver.IdentityConfigurationRecord)) error + type IdentityStore struct + func NewIdentityStore(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, dataSource string) (*IdentityStore, error) + func (s *IdentityStore) CreateSchema() error + func (s *IdentityStore) GetSchema() string + type KeystoreStore struct + func NewKeystoreStore(dbs *common2.RWDB, tableNames common3.TableNames) (*KeystoreStore, error) + func (s *KeystoreStore) CreateSchema() error + func (s *KeystoreStore) GetSchema() string + type Notifier struct + func NewNotifier(writeDB *sql.DB, table, dataSource string, notifyOperations []driver.Operation, ...) *Notifier + func (db *Notifier) Close() error + func (db *Notifier) CreateSchema() error + func (db *Notifier) GetSchema() string + func (db *Notifier) ListenerError() <-chan error + func (db *Notifier) Subscribe(callback driver.TriggerCallback) error + func (db *Notifier) UnsubscribeAll() error + type PrimaryKey struct + func NewBytePrimaryKey(name driver.ColumnKey) *PrimaryKey + func NewSimplePrimaryKey(name driver.ColumnKey) *PrimaryKey + type TokenLockStore struct + func NewTokenLockStore(dbs *common2.RWDB, tableNames common5.TableNames) (*TokenLockStore, error) + func (db *TokenLockStore) Cleanup(ctx context.Context, leaseExpiry time.Duration) error + func (s *TokenLockStore) CreateSchema() error + func (s *TokenLockStore) GetSchema() string + type TokenNotifier struct + func NewTokenNotifier(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, dataSource string) (*TokenNotifier, error) + func (n *TokenNotifier) Subscribe(callback func(tokensdriver.Operation, tokensdriver.TokenRecordReference)) error + type TokenStore struct + func NewTokenStoreWithNotifier(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, notifier *TokenNotifier) (*TokenStore, error) + func (s *TokenStore) CreateSchema() error + func (s *TokenStore) GetSchema() string + type TransactionNotifier struct + func NewTransactionNotifier(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, dataSource string) (*TransactionNotifier, error) + func (n *TransactionNotifier) Subscribe(callback func(tokensdriver.Operation, tokensdriver.TransactionRecordReference)) error + type TransactionStore struct + func NewTransactionStoreWithNotifier(dbs *scommon.RWDB, tableNames sqlcommon.TableNames, ...) (*TransactionStore, error) + func (db *TransactionStore) ClaimPendingTransactions(ctx context.Context, params tokensdriver.RecoveryClaimParams) ([]*tokensdriver.RecoveryClaim, error) + func (db *TransactionStore) CleanupExpiredClaims(ctx context.Context) (int, error) + func (db *TransactionStore) ReleaseRecoveryClaim(ctx context.Context, txID string, owner string, message string) error + func (s *TransactionStore) CreateSchema() error + func (s *TransactionStore) GetSchema() string + type WalletStore struct + func NewWalletStore(dbs *common2.RWDB, tableNames common3.TableNames) (*WalletStore, error) + func (s *WalletStore) CreateSchema() error + func (s *WalletStore) GetSchema() string
Go to main page