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 + const Cached + const Eager + const Lazy + const Listener + const Mixed + const NoBackoff + func NewFetcherProvider(dbManager *tokendb.Manager, notifierManager *tokendb.NotifierManager, ...) *fetcherProvider + func NewLazyFetcher(tokenDB TokenDB) *lazyFetcher + func NewManager(fetcher tokenFetcher, locker Locker, precision uint64, backoff time.Duration, ...) *manager + func NewSelector(logger logging.Logger, tokenDB tokenFetcher, lockDB tokenLocker, ...) *selector + func NewSherdSelector(txID transaction.ID, fetcher tokenFetcher, lockDB Locker, precision uint64, ...) tokenSelectorUnlocker + func NewStubbornSelector(logger logging.Logger, tokenDB tokenFetcher, lockDB tokenLocker, ...) *stubbornSelector + type FetcherProvider interface + GetFetcher func(tmsID token.TMSID) (tokenFetcher, error) + type FetcherStrategy string + type Iterator interface + Next func() V + type Locker interface + Cleanup func(leaseExpiry time.Duration) error + Lock func(tokenID *token2.ID, consumerTxID transaction.ID) error + UnlockByTxID func(consumerTxID transaction.ID) error + type Metrics struct + UnspentTokensInvocations metrics.Counter + type SelectorService struct + func NewService(fetcherProvider FetcherProvider, tokenLockDBManager *tokenlockdb.Manager, ...) *SelectorService + func (s *SelectorService) SelectorManager(tms *token.ManagementService) (token.SelectorManager, error) + type TokenDB interface + SpendableTokensIteratorBy func(ctx context.Context, walletID string, typ token2.Type) (driver.SpendableTokensIterator, error)
Go to main page