postgres

package

Go to main page

Versions in this module

v0

v0.27.0

Nov 2, 2026

v0.26.0

Oct 26, 2026

Changes in this version

+ const MaxLockBatchCandidates

type TokenLockStore

+ func (db *TokenLockStore) Lock(ctx context.Context, tokenID *token.ID, consumerTxID transaction.ID, ...) error

+ func (db *TokenLockStore) LockBatch(ctx context.Context, tokenIDs []*token.ID, consumerTxID transaction.ID, ...) (driver.BatchLockOutcome, error)

+ func (db *TokenLockStore) RoundTrips() int64

+ func (db *TokenLockStore) UniqueViolations() int64

v0.24.0

Oct 15, 2026

Changes in this version

+ var ErrNotifierClosed = errors.New("notifier is closed")

type AuditTransactionStore

+ func (s *AuditTransactionStore) AcquireLeadership(ctx context.Context, lockID int64) (tokensdriver.RecoveryLeadership, bool, error)

type TransactionStore

+ func (s *TransactionStore) AcquireLeadership(ctx context.Context, lockID int64) (tokensdriver.RecoveryLeadership, bool, error)

v0.22.0

Sep 18, 2026

v0.21.0

Sep 14, 2026

Changes in this version

+ func NewAdvisoryLockFactoryForID(lockID int64) func(context.Context, *sql.DB) (tokensdriver.RecoveryLeadership, bool, error)

+ func NewCleanupLeaderFactoryForID(lockID int64) func(context.Context, *sql.DB) (tokensdriver.CleanupLeadership, bool, error)

type AuditTransactionStore

+ func (s *AuditTransactionStore) ClaimPendingTransactions(ctx context.Context, params tokensdriver.RecoveryClaimParams) ([]*tokensdriver.RecoveryClaim, error)

+ func (s *AuditTransactionStore) ReleaseRecoveryClaim(ctx context.Context, txID string, owner string, _ string) error

v0.18.0

Aug 26, 2026

Changes in this version

type Notifier

+ func (db *Notifier) TransportError() <-chan error

v0.17.0

Aug 12, 2026

Changes in this version

type TokenLockStore

+ func (db *TokenLockStore) AcquireCleanupLeadership(ctx context.Context) (driver.CleanupLeadership, bool, error)

v0.16.0

Aug 1, 2026

v0.15.1

Jul 22, 2026

v0.14.2

Jul 10, 2026

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

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