Versions in this module Expand all Collapse all v0 v0.4.0 Jan 6, 2025 Changes in this version + func NewFinalityListenerManagerProvider[V comparable](tracerProvider trace.TracerProvider) *finalityListenerManagerProvider[V] + type AggregatedTransactionFilter struct + func NewAggregatedTransactionFilter() *AggregatedTransactionFilter + func (f *AggregatedTransactionFilter) Accept(txID string, env []byte) (bool, error) + func (f *AggregatedTransactionFilter) Add(filter driver.TransactionFilter) + type FinalityManager struct + func NewFinalityManager[V comparable](listenerManager driver.ListenerManager[V], logger Logger, vault Vault[V], ...) *FinalityManager[V] + func (c *FinalityManager[V]) AddListener(txID driver.TxID, toAdd driver.FinalityListener[V]) error + func (c *FinalityManager[V]) Post(event driver.FinalityEvent[V]) + func (c *FinalityManager[V]) RemoveListener(txID driver.TxID, toRemove driver.FinalityListener[V]) + func (c *FinalityManager[V]) Run(context context.Context) + type Logger interface + Debugf func(template string, args ...interface{}) + Errorf func(template string, args ...interface{}) + Infof func(template string, args ...interface{}) + Warnf func(template string, args ...interface{}) + type Vault interface + Statuses func(ids ...string) ([]driver.TxValidationStatus[V], error)
Go to main page