common

package

Go to main page

Versions in this module

v0

v0.7.0

Dec 4, 2025

Changes in this version

+ func CloseFunc(closer func() error)

type IdentityStore

+ func NewNoCacheIdentityStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter, ...) (*IdentityStore, error)

+ func (db *IdentityStore) RegisterIdentityDescriptor(ctx context.Context, descriptor *idriver.IdentityDescriptor, ...) error

+ type KeystoreStore struct

+ func NewKeystoreStore(readDB, writeDB *sql.DB, tables TableNames, ci qcommon.CondInterpreter, ...) (*KeystoreStore, error)

+ func (db *KeystoreStore) Close() error

+ func (db *KeystoreStore) CreateSchema() error

+ func (db *KeystoreStore) Get(key string, state interface{}) error

+ func (db *KeystoreStore) GetRaw(key string) ([]byte, error)

+ func (db *KeystoreStore) GetSchema() string

+ func (db *KeystoreStore) Put(key string, state interface{}) error

type TableNames

+ KeyStore string

v0.5.0

Jul 17, 2025

Changes in this version

+ func HasMovementsParams(params driver.QueryMovementsParams) cond.Condition

+ func HasTokenDetails(params driver.QueryTokenDetailsParams, tokenTable common.Table) cond.Condition

+ func HasTokens(colTxID, colIdx common.FieldName, ids ...*token.ID) cond.Condition

+ func HasTransactionParams(params driver.QueryTransactionsParams, table common.Table) cond.Condition

+ func HasValidationParams(params driver.QueryValidationRecordsParams) cond.Condition

+ func IsExpiredToken(tokenRequests, tokenLocks common3.Table, leaseExpiry time.Duration) cond.Condition

+ func TestAWAddMovement(t *testing.T, store transactionsStoreConstructor)

+ func TestAWAddTokenRequest(t *testing.T, store transactionsStoreConstructor)

+ func TestAWAddTransaction(t *testing.T, store transactionsStoreConstructor)

+ func TestAWAddValidationRecord(t *testing.T, store transactionsStoreConstructor)

+ func TestAddTransactionEndorsementAck(t *testing.T, store transactionsStoreConstructor)

+ func TestGetStatus(t *testing.T, store transactionsStoreConstructor)

+ func TestGetTokenRequest(t *testing.T, store transactionsStoreConstructor)

+ func TestGetTransactionEndorsementAcks(t *testing.T, store transactionsStoreConstructor)

+ func TestGetWalletID(t *testing.T, store walletStoreConstructor)

+ func TestGetWalletIDs(t *testing.T, store walletStoreConstructor)

+ func TestIdentityExists(t *testing.T, store walletStoreConstructor)

+ func TestLoadMeta(t *testing.T, store walletStoreConstructor)

+ func TestLock(t *testing.T, store tokenLockStoreConstructor)

+ func TestQueryMovements(t *testing.T, store transactionsStoreConstructor, ...)

+ func TestQueryTokenRequests(t *testing.T, store transactionsStoreConstructor, ...)

+ func TestQueryTransactions(t *testing.T, store transactionsStoreConstructor)

+ func TestQueryValidations(t *testing.T, store transactionsStoreConstructor, ...)

+ func TestSetStatus(t *testing.T, store transactionsStoreConstructor)

+ func TestStoreIdentity(t *testing.T, store walletStoreConstructor)

+ func TestUnlockByTxID(t *testing.T, store tokenLockStoreConstructor)

+ type AnyUUID struct

+ func (a AnyUUID) Match(v driver2.Value) bool

+ type IdentityStore struct

+ func NewCachedIdentityStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter) (*IdentityStore, error)

+ func NewIdentityStore(readDB, writeDB *sql.DB, tables TableNames, signerInfoCache cache[bool], ...) (*IdentityStore, error)

+ func (db *IdentityStore) AddConfiguration(ctx context.Context, wp driver.IdentityConfiguration) error

+ func (db *IdentityStore) Close() error

+ func (db *IdentityStore) ConfigurationExists(ctx context.Context, id, typ, url string) (bool, error)

+ func (db *IdentityStore) CreateSchema() error

+ func (db *IdentityStore) GetAuditInfo(ctx context.Context, id []byte) ([]byte, error)

+ func (db *IdentityStore) GetExistingSignerInfo(ctx context.Context, ids ...tdriver.Identity) ([]string, error)

+ func (db *IdentityStore) GetSchema() string

+ func (db *IdentityStore) GetSignerInfo(ctx context.Context, identity []byte) ([]byte, error)

+ func (db *IdentityStore) GetTokenInfo(ctx context.Context, id []byte) ([]byte, []byte, error)

+ func (db *IdentityStore) IteratorConfigurations(ctx context.Context, configurationType string) (driver3.IdentityConfigurationIterator, error)

+ func (db *IdentityStore) SignerInfoExists(ctx context.Context, id []byte) (bool, error)

+ func (db *IdentityStore) StoreIdentityData(ctx context.Context, id []byte, identityAudit []byte, tokenMetadata []byte, ...) error

+ func (db *IdentityStore) StoreSignerInfo(ctx context.Context, id, info []byte) error

+ type PersistenceConstructor func(*common.RWDB, TableNames) (V, error)

+ type QueryConstructorTraits struct

+ MultipleParenthesis bool

+ SupportsIN bool

+ type TableNames struct

+ Certifications string

+ IdentityConfigurations string

+ IdentityInfo string

+ Movements string

+ Ownership string

+ PublicParams string

+ Requests string

+ Signers string

+ TokenLocks string

+ Tokens string

+ TransactionEndorseAck string

+ Transactions string

+ Validations string

+ Wallets string

+ type TokenLockStore struct

+ Logger logging.Logger

+ ReadDB *sql.DB

+ Table tokenLockTables

+ WriteDB *sql.DB

+ func NewTokenLockStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter) (*TokenLockStore, error)

+ func (db *TokenLockStore) Close() error

+ func (db *TokenLockStore) CreateSchema() error

+ func (db *TokenLockStore) GetSchema() string

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

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

+ type TokenStore struct

+ func NewTokenStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter) (*TokenStore, error)

+ func (db *TokenStore) Balance(ctx context.Context, walletID string, typ token.Type) (uint64, error)

+ func (db *TokenStore) Close() error

+ func (db *TokenStore) CreateSchema() error

+ func (db *TokenStore) DeleteTokens(ctx context.Context, deletedBy string, ids ...*token.ID) error

+ func (db *TokenStore) ExistsCertification(ctx context.Context, tokenID *token.ID) bool

+ func (db *TokenStore) GetAllTokenInfos(ctx context.Context, ids []*token.ID) ([][]byte, error)

+ func (db *TokenStore) GetCertifications(ctx context.Context, ids []*token.ID) ([][]byte, error)

+ func (db *TokenStore) GetSchema() string

+ func (db *TokenStore) GetTokenMetadata(ctx context.Context, ids []*token.ID) ([][]byte, error)

+ func (db *TokenStore) GetTokenOutputs(ctx context.Context, ids []*token.ID, callback tdriver.QueryCallbackFunc) error

+ func (db *TokenStore) GetTokenOutputsAndMeta(ctx context.Context, ids []*token.ID) ([][]byte, [][]byte, []token.Format, error)

+ func (db *TokenStore) GetTokens(ctx context.Context, inputs ...*token.ID) ([]*token.Token, error)

+ func (db *TokenStore) IsMine(ctx context.Context, txID string, index uint64) (bool, error)

+ func (db *TokenStore) ListAuditTokens(ctx context.Context, ids ...*token.ID) ([]*token.Token, error)

+ func (db *TokenStore) ListHistoryIssuedTokens(ctx context.Context) (*token.IssuedTokens, error)

+ func (db *TokenStore) ListUnspentTokens(ctx context.Context) (*token.UnspentTokens, error)

+ func (db *TokenStore) ListUnspentTokensBy(ctx context.Context, walletID string, typ token.Type) (*token.UnspentTokens, error)

+ func (db *TokenStore) NewTokenDBTransaction() (driver.TokenStoreTransaction, error)

+ func (db *TokenStore) PublicParams(ctx context.Context) ([]byte, error)

+ func (db *TokenStore) PublicParamsByHash(ctx context.Context, rawHash tdriver.PPHash) ([]byte, error)

+ func (db *TokenStore) QueryTokenDetails(ctx context.Context, params driver.QueryTokenDetailsParams) ([]driver.TokenDetails, error)

+ func (db *TokenStore) SetSupportedTokenFormats(formats []token.Format) error

+ func (db *TokenStore) SpendableTokensIteratorBy(ctx context.Context, walletID string, typ token.Type) (tdriver.SpendableTokensIterator, error)

+ func (db *TokenStore) StoreCertifications(ctx context.Context, certifications map[*token.ID][]byte) error

+ func (db *TokenStore) StorePublicParams(ctx context.Context, raw []byte) error

+ func (db *TokenStore) StoreToken(ctx context.Context, tr driver.TokenRecord, owners []string) (err error)

+ func (db *TokenStore) TransactionExists(ctx context.Context, id string) (bool, error)

+ func (db *TokenStore) UnspentLedgerTokensIteratorBy(ctx context.Context) (tdriver.LedgerTokensIterator, error)

+ func (db *TokenStore) UnspentTokensIterator(ctx context.Context) (tdriver.UnspentTokensIterator, error)

+ func (db *TokenStore) UnspentTokensIteratorBy(ctx context.Context, walletID string, tokenType token.Type) (tdriver.UnspentTokensIterator, error)

+ func (db *TokenStore) UnsupportedTokensIteratorBy(ctx context.Context, walletID string, tokenType token.Type) (tdriver.UnsupportedTokensIterator, error)

+ func (db *TokenStore) WhoDeletedTokens(ctx context.Context, inputs ...*token.ID) ([]string, []bool, error)

+ type TransactionStore struct

+ func NewAuditTransactionStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter, ...) (*TransactionStore, error)

+ func NewOwnerTransactionStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter, ...) (*TransactionStore, error)

+ func (db *TransactionStore) AddTransactionEndorsementAck(ctx context.Context, txID string, endorser token.Identity, sigma []byte) (err error)

+ func (db *TransactionStore) BeginAtomicWrite() (driver.AtomicWrite, error)

+ func (db *TransactionStore) Close() error

+ func (db *TransactionStore) CreateSchema() error

+ func (db *TransactionStore) GetSchema() string

+ func (db *TransactionStore) GetStatus(ctx context.Context, txID string) (driver.TxStatus, string, error)

+ func (db *TransactionStore) GetTokenRequest(ctx context.Context, txID string) ([]byte, error)

+ func (db *TransactionStore) GetTransactionEndorsementAcks(ctx context.Context, txID string) (map[string][]byte, error)

+ func (db *TransactionStore) QueryMovements(ctx context.Context, params driver.QueryMovementsParams) (res []*driver.MovementRecord, err error)

+ func (db *TransactionStore) QueryTokenRequests(ctx context.Context, params driver.QueryTokenRequestsParams) (driver.TokenRequestIterator, error)

+ func (db *TransactionStore) QueryTransactions(ctx context.Context, params driver.QueryTransactionsParams, ...) (*driver3.PageIterator[*driver.TransactionRecord], error)

+ func (db *TransactionStore) QueryValidations(ctx context.Context, params driver.QueryValidationRecordsParams) (driver.ValidationRecordsIterator, error)

+ func (db *TransactionStore) SetStatus(ctx context.Context, txID string, status driver.TxStatus, message string) error

+ type WalletStore struct

+ func NewWalletStore(readDB, writeDB *sql.DB, tables TableNames, ci common3.CondInterpreter) (*WalletStore, error)

+ func (db *WalletStore) Close() error

+ func (db *WalletStore) CreateSchema() error

+ func (db *WalletStore) GetSchema() string

+ func (db *WalletStore) GetWalletID(ctx context.Context, identity token.Identity, roleID int) (driver.WalletID, error)

+ func (db *WalletStore) GetWalletIDs(ctx context.Context, roleID int) ([]driver.WalletID, error)

+ func (db *WalletStore) IdentityExists(ctx context.Context, identity token.Identity, wID driver.WalletID, roleID int) bool

+ func (db *WalletStore) LoadMeta(ctx context.Context, identity token.Identity, wID driver.WalletID, roleID int) ([]byte, error)

+ func (db *WalletStore) StoreIdentity(ctx context.Context, identity token.Identity, eID string, wID driver.WalletID, ...) error

v0.4.0

Jan 7, 2025

Changes in this version

+ const ABC

+ const DeleteStatement

+ const InsertStatement

+ const QueryLabel

+ const ResultRowsLabel

+ const SelectDistinctStatement

+ const SelectStatement

+ const TST

+ const UpdateStatement

+ var TokenNotifierCases = []struct{ ... }

+ var TokensCases = []struct{ ... }

+ func Close(closer Closer)

+ func GetTableNames(prefix string) (tableNames, error)

+ func NewAuditTransactionDB(sqlDB *sql.DB, opts NewDBOpts, ci TokenInterpreter) (driver.AuditTransactionDB, error)

+ func NewCachedIdentityDB(db *sql.DB, opts NewDBOpts) (driver.IdentityDB, error)

+ func NewTokenDB(db *sql.DB, opts NewDBOpts, ci TokenInterpreter) (driver.TokenDB, error)

+ func NewTransactionDB(db *sql.DB, opts NewDBOpts, ci TokenInterpreter) (driver.TokenTransactionDB, error)

+ func NewWalletDB(db *sql.DB, opts NewDBOpts) (driver.WalletDB, error)

+ func QueryUnique[T any](db *sql.DB, query string, args ...any) (T, error)

+ func StartPostgresContainer(t *testing.T) (func(), string)

+ func StartPostgresWithFmt(configs map[string]*PostgresConfig) (func(), error)

+ func TCertification(t *testing.T, db *TokenDB)

+ func TDeleteAndMine(t *testing.T, db *TokenDB)

+ func TDeleteMultiple(t *testing.T, db *TokenDB)

+ func TGetTokenInfos(t *testing.T, db *TokenDB)

+ func TListAuditTokens(t *testing.T, db *TokenDB)

+ func TListIssuedTokens(t *testing.T, db *TokenDB)

+ func TPublicParams(t *testing.T, db *TokenDB)

+ func TQueryTokenDetails(t *testing.T, db *TokenDB)

+ func TSaveAndGetToken(t *testing.T, db *TokenDB)

+ func TSubscribeRead(t *testing.T, db driver.TokenDB, notifier driver.TokenNotifier)

+ func TSubscribeStore(t *testing.T, db driver.TokenDB, notifier driver.TokenNotifier)

+ func TSubscribeStoreDelete(t *testing.T, db driver.TokenDB, notifier driver.TokenNotifier)

+ func TSubscribeStoreNoCommit(t *testing.T, db driver.TokenDB, notifier driver.TokenNotifier)

+ func TTokenTypes(t *testing.T, db *TokenDB)

+ func TTransaction(t *testing.T, db *TokenDB)

+ type AtomicWrite struct

+ func (w *AtomicWrite) AddMovement(r *driver.MovementRecord) error

+ func (w *AtomicWrite) AddTokenRequest(txID string, tr []byte, applicationMetadata map[string][]byte, ...) error

+ func (w *AtomicWrite) AddTransaction(r *driver.TransactionRecord) error

+ func (w *AtomicWrite) AddValidationRecord(txID string, meta map[string][]byte) error

+ func (w *AtomicWrite) Commit() error

+ func (w *AtomicWrite) Rollback()

+ type Closer interface

+ Close func() error

+ type DBOpener = Opener[*sql.DB]

+ func NewSQLDBOpener(optsKey, envVarKey string) *DBOpener

+ type DataSourceProvider = postgres2.DataSourceProvider

+ type Delete struct

+ func NewDeleteFrom(table string) *Delete

+ func (s *Delete) Compile() (string, error)

+ func (s *Delete) Where(where string) *Delete

+ type IdentityConfigurationIterator struct

+ func (w *IdentityConfigurationIterator) Close() error

+ func (w *IdentityConfigurationIterator) HasNext() bool

+ func (w *IdentityConfigurationIterator) Next() (driver.IdentityConfiguration, error)

+ type IdentityDB struct

+ func NewIdentityDB(db *sql.DB, tablePrefix string, createSchema bool, signerInfoCache cache[bool], ...) (*IdentityDB, error)

+ func (db *IdentityDB) AddConfiguration(wp driver.IdentityConfiguration) error

+ func (db *IdentityDB) ConfigurationExists(id, typ string) (bool, error)

+ func (db *IdentityDB) GetAuditInfo(id []byte) ([]byte, error)

+ func (db *IdentityDB) GetSchema() string

+ func (db *IdentityDB) GetSignerInfo(identity []byte) ([]byte, error)

+ func (db *IdentityDB) GetTokenInfo(id []byte) ([]byte, []byte, error)

+ func (db *IdentityDB) IteratorConfigurations(configurationType string) (driver.Iterator[driver.IdentityConfiguration], error)

+ func (db *IdentityDB) SignerInfoExists(id []byte) (bool, error)

+ func (db *IdentityDB) StoreIdentityData(id []byte, identityAudit []byte, tokenMetadata []byte, ...) error

+ func (db *IdentityDB) StoreSignerInfo(id, info []byte) error

+ type Insert struct

+ func NewInsertInto(table string) *Insert

+ func (i *Insert) Compile() (string, error)

+ func (i *Insert) Rows(rows string) *Insert

+ type NewDBFunc func(db *sql.DB, opts NewDBOpts) (V, error)

+ type NewDBOpts struct

+ CreateSchema bool

+ DataSource string

+ TablePrefix string

+ func NewDBOptsFromOpts(o Opts) NewDBOpts

+ type OpenDBFunc func(k Opts) (V, error)

+ type Opener struct

+ func NewOpenerFromMap[V any](optsKey, envVarKey string, constructors map[common.SQLDriverType]OpenDBFunc[V]) *Opener[V]

+ func NewOpener[V any](optsKey, envVarKey string, constructors OpenDBFunc[V]) *Opener[V]

+ func (d *Opener[V]) Open(cp driver.ConfigProvider, tmsID token.TMSID) (V, error)

+ func (d *Opener[V]) OpenSQLDB(driverName common.SQLDriverType, dataSourceName string, maxOpenConns int, ...) (V, error)

+ func (d *Opener[V]) OpenWithOpts(cp driver.ConfigProvider, tmsID token.TMSID) (V, *Opts, error)

+ type Opts = common.Opts

+ type PostgresConfig = postgres2.ContainerConfig

+ func DefaultPostgresConfig(node string) *PostgresConfig

+ type Select struct

+ func NewSelect(columns ...string) *Select

+ func NewSelectDistinct(columns ...string) *Select

+ func (s *Select) Compile() (string, error)

+ func (s *Select) From(tables ...string) *Select

+ func (s *Select) OrderBy(orderBy string) *Select

+ func (s *Select) Where(where string) *Select

+ type TokenDB struct

+ func (db *TokenDB) Balance(walletID string, typ token.Type) (uint64, error)

+ func (db *TokenDB) Close()

+ func (db *TokenDB) DeleteTokens(deletedBy string, ids ...*token.ID) error

+ func (db *TokenDB) ExistsCertification(tokenID *token.ID) bool

+ func (db *TokenDB) GetAllTokenInfos(ids []*token.ID) ([][]byte, error)

+ func (db *TokenDB) GetCertifications(ids []*token.ID) ([][]byte, error)

+ func (db *TokenDB) GetSchema() string

+ func (db *TokenDB) GetTokenMetadata(ids []*token.ID) ([][]byte, error)

+ func (db *TokenDB) GetTokenOutputs(ids []*token.ID, callback tdriver.QueryCallbackFunc) error

+ func (db *TokenDB) GetTokenOutputsAndMeta(ctx context.Context, ids []*token.ID) ([][]byte, [][]byte, []token.Format, error)

+ func (db *TokenDB) GetTokens(inputs ...*token.ID) ([]*token.Token, error)

+ func (db *TokenDB) IsMine(txID string, index uint64) (bool, error)

+ func (db *TokenDB) ListAuditTokens(ids ...*token.ID) ([]*token.Token, error)

+ func (db *TokenDB) ListHistoryIssuedTokens() (*token.IssuedTokens, error)

+ func (db *TokenDB) ListUnspentTokens() (*token.UnspentTokens, error)

+ func (db *TokenDB) ListUnspentTokensBy(walletID string, typ token.Type) (*token.UnspentTokens, error)

+ func (db *TokenDB) NewTokenDBTransaction() (driver.TokenDBTransaction, error)

+ func (db *TokenDB) PublicParams() ([]byte, error)

+ func (db *TokenDB) PublicParamsByHash(rawHash tdriver.PPHash) ([]byte, error)

+ func (db *TokenDB) QueryTokenDetails(params driver.QueryTokenDetailsParams) ([]driver.TokenDetails, error)

+ func (db *TokenDB) SetSupportedTokenFormats(formats []token.Format) error

+ func (db *TokenDB) SpendableTokensIteratorBy(ctx context.Context, walletID string, typ token.Type) (tdriver.SpendableTokensIterator, error)

+ func (db *TokenDB) StoreCertifications(certifications map[*token.ID][]byte) (err error)

+ func (db *TokenDB) StorePublicParams(raw []byte) error

+ func (db *TokenDB) StoreToken(tr driver.TokenRecord, owners []string) (err error)

+ func (db *TokenDB) TransactionExists(ctx context.Context, id string) (bool, error)

+ func (db *TokenDB) UnspentTokensIterator() (tdriver.UnspentTokensIterator, error)

+ func (db *TokenDB) UnspentTokensIteratorBy(ctx context.Context, walletID string, tokenType token.Type) (tdriver.UnspentTokensIterator, error)

+ func (db *TokenDB) WhoDeletedTokens(inputs ...*token.ID) ([]string, []bool, error)

+ type TokenInterpreter interface

+ HasMovementsParams func(params driver.QueryMovementsParams) common.Condition

+ HasTokenDetails func(params driver.QueryTokenDetailsParams, tokenTable string) common.Condition

+ HasTokenFormats func(colTokenType common.FieldName, formats ...token.Format) common.Condition

+ HasTokenTypes func(colTokenType common.FieldName, tokenTypes ...token.Type) common.Condition

+ HasTokens func(colTxID, colIdx common.FieldName, ids ...*token.ID) common.Condition

+ HasTransactionParams func(params driver.QueryTransactionsParams, table string) common.Condition

+ HasValidationParams func(params driver.QueryValidationRecordsParams) common.Condition

+ func NewTokenInterpreter(ci common.Interpreter) TokenInterpreter

+ type TokenLockDB struct

+ DB *sql.DB

+ Logger logging.Logger

+ Table tokenLockTables

+ func NewTokenLockDB(db *sql.DB, opts NewDBOpts) (*TokenLockDB, error)

+ func (db *TokenLockDB) Close() error

+ func (db *TokenLockDB) GetSchema() string

+ func (db *TokenLockDB) Lock(tokenID *token.ID, consumerTxID transaction.ID) error

+ func (db *TokenLockDB) UnlockByTxID(consumerTxID transaction.ID) error

+ type TokenRequestIterator struct

+ func (t *TokenRequestIterator) Close()

+ func (t *TokenRequestIterator) Next() (*driver.TokenRequestRecord, error)

+ type TokenTransaction struct

+ func (t *TokenTransaction) Commit() error

+ func (t *TokenTransaction) Delete(ctx context.Context, tokenID token.ID, deletedBy string) error

+ func (t *TokenTransaction) GetToken(ctx context.Context, tokenID token.ID, includeDeleted bool) (*token.Token, []string, error)

+ func (t *TokenTransaction) Rollback() error

+ func (t *TokenTransaction) SetSpendable(ctx context.Context, tokenID token.ID, spendable bool) error

+ func (t *TokenTransaction) SetSpendableBySupportedTokenFormats(ctx context.Context, formats []token.Format) error

+ func (t *TokenTransaction) StoreToken(ctx context.Context, tr driver.TokenRecord, owners []string) error

+ type TransactionDB struct

+ func (db *TransactionDB) AddTransactionEndorsementAck(txID string, endorser token.Identity, sigma []byte) (err error)

+ func (db *TransactionDB) BeginAtomicWrite() (driver.AtomicWrite, error)

+ func (db *TransactionDB) Close() error

+ func (db *TransactionDB) GetSchema() string

+ func (db *TransactionDB) GetStatus(txID string) (driver.TxStatus, string, error)

+ func (db *TransactionDB) GetTokenRequest(txID string) ([]byte, error)

+ func (db *TransactionDB) GetTransactionEndorsementAcks(txID string) (map[string][]byte, error)

+ func (db *TransactionDB) QueryMovements(params driver.QueryMovementsParams) (res []*driver.MovementRecord, err error)

+ func (db *TransactionDB) QueryTokenRequests(params driver.QueryTokenRequestsParams) (driver.TokenRequestIterator, error)

+ func (db *TransactionDB) QueryTransactions(params driver.QueryTransactionsParams) (driver.TransactionIterator, error)

+ func (db *TransactionDB) QueryValidations(params driver.QueryValidationRecordsParams) (driver.ValidationRecordsIterator, error)

+ func (db *TransactionDB) SetStatus(ctx context.Context, txID string, status driver.TxStatus, message string) (err error)

+ type TransactionIterator struct

+ func (t *TransactionIterator) Close()

+ func (t *TransactionIterator) Next() (*driver.TransactionRecord, error)

+ type UnspentTokensInWalletIterator struct

+ func (u *UnspentTokensInWalletIterator) Close()

+ func (u *UnspentTokensInWalletIterator) Next() (*token.UnspentTokenInWallet, error)

+ type UnspentTokensIterator struct

+ func (u *UnspentTokensIterator) Close()

+ func (u *UnspentTokensIterator) Next() (*token.UnspentToken, error)

+ type Update struct

+ func NewUpdate(table string) *Update

+ func (u *Update) Compile() (string, error)

+ func (u *Update) Set(rows string) *Update

+ func (u *Update) Where(where string) *Update

+ type ValidationRecordsIterator struct

+ func (t *ValidationRecordsIterator) Close()

+ func (t *ValidationRecordsIterator) Next() (*driver.ValidationRecord, error)

+ type WalletDB struct

+ func (db *WalletDB) GetSchema() string

+ func (db *WalletDB) GetWalletID(identity token.Identity, roleID int) (driver.WalletID, error)

+ func (db *WalletDB) GetWalletIDs(roleID int) ([]driver.WalletID, error)

+ func (db *WalletDB) IdentityExists(identity token.Identity, wID driver.WalletID, roleID int) bool

+ func (db *WalletDB) LoadMeta(identity token.Identity, wID driver.WalletID, roleID int) ([]byte, error)

+ func (db *WalletDB) StoreIdentity(identity token.Identity, eID string, wID driver.WalletID, roleID int, ...) error

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