Versions in this module Expand all Collapse all v0 v0.5.0 Jul 17, 2025 v0.4.0 Jan 7, 2025 Changes in this version + func NewParallelListenerManagerProvider[V comparable](provider driver.ListenerManagerProvider[V]) *parallelListenerManagerProvider[V] + func NewPublicParamsFetcher(fetcher Fetcher, namespace string) *publicParamsFetcher + type AcceptTxInDBFilterProvider struct + func NewAcceptTxInDBFilterProvider(ttxDBProvider *ttxdb.Manager, auditDBProvider *auditdb.Manager) *AcceptTxInDBFilterProvider + func (p *AcceptTxInDBFilterProvider) New(tmsID token3.TMSID) (*AcceptTxInDBsFilter, error) + type AcceptTxInDBsFilter struct + func (t *AcceptTxInDBsFilter) Accept(txID string, env []byte) (bool, error) + type Configuration interface + ConfigurationFor func(network, channel, namespace string) (config.Configuration, error) + LookupNamespace func(network, channel string) (string, error) + type Fetcher interface + FetchPublicParameters func(namespace string) ([]byte, error) + type FinalityListener struct + func NewFinalityListener(logger logging.Logger, tmsProvider TokenManagementServiceProvider, ...) *FinalityListener + func (t *FinalityListener) OnStatus(ctx context.Context, txID string, status int, message string, ...) + type TokenManagementServiceProvider interface + GetManagementService func(opts ...token.ServiceOption) (*token.ManagementService, error) + type TransactionFilterProvider interface + New func(tmsID token3.TMSID) (F, error)