Documentation
¶
Index ¶
- func NewParallelListenerManagerProvider[V comparable](provider driver.ListenerManagerProvider[V]) *parallelListenerManagerProvider[V]
- func NewPublicParamsFetcher(fetcher Fetcher, namespace string) *publicParamsFetcher
- type AcceptTxInDBFilterProvider
- type AcceptTxInDBsFilter
- type Configuration
- type Fetcher
- type FinalityListener
- type TokenManagementServiceProvider
- type TransactionFilterProvider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewParallelListenerManagerProvider ¶
func NewParallelListenerManagerProvider[V comparable](provider driver.ListenerManagerProvider[V]) *parallelListenerManagerProvider[V]
func NewPublicParamsFetcher ¶
Types ¶
type AcceptTxInDBFilterProvider ¶
type AcceptTxInDBFilterProvider struct {
// contains filtered or unexported fields
}
AcceptTxInDBFilterProvider provides instances of AcceptTxInDBsFilter based on the transaction db and audit db for a given TMS
func NewAcceptTxInDBFilterProvider ¶
func NewAcceptTxInDBFilterProvider(ttxDBProvider *ttxdb.Manager, auditDBProvider *auditdb.Manager) *AcceptTxInDBFilterProvider
func (*AcceptTxInDBFilterProvider) New ¶
func (p *AcceptTxInDBFilterProvider) New(tmsID token3.TMSID) (*AcceptTxInDBsFilter, error)
type AcceptTxInDBsFilter ¶
type AcceptTxInDBsFilter struct {
// contains filtered or unexported fields
}
AcceptTxInDBsFilter uses the transaction db and the audit db to decide if a given transaction needs to be further processed by the token-sdk upon a network event about its finality
type Configuration ¶
type Configuration interface { // LookupNamespace searches for a TMS configuration that matches the given network and channel, and // return its namespace. // If no matching configuration is found, an error is returned. // If multiple matching configurations are found, an error is returned. LookupNamespace(network, channel string) (string, error) ConfigurationFor(network, channel, namespace string) (config.Configuration, error) }
Configuration models the configuration provider
type FinalityListener ¶
type FinalityListener struct {
// contains filtered or unexported fields
}
func NewFinalityListener ¶
func NewFinalityListener(logger logging.Logger, tmsProvider TokenManagementServiceProvider, tmsID token.TMSID, ttxDB transactionDB, tokens *tokens.Tokens, tracer trace.Tracer) *FinalityListener
type TokenManagementServiceProvider ¶
type TokenManagementServiceProvider interface {
GetManagementService(opts ...token.ServiceOption) (*token.ManagementService, error)
}
type TransactionFilterProvider ¶
type TransactionFilterProvider[F driver2.TransactionFilter] interface { New(tmsID token3.TMSID) (F, error) }
Directories
¶
Path | Synopsis |
---|---|
rws
|
|
translator/mock
Code generated by counterfeiter.
|
Code generated by counterfeiter. |
Click to show internal directories.
Click to hide internal directories.