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 LockSleepTimeout + const LockValidTxEvictionTimeout + const NumTokensPerWallet + const SelectQuantity + const SelectorNumRetries + const SelectorTimeout + const TokenQuantityPrecision + const TokenType + const TxID + func NewEnhancedManager(manager token2.SelectorManager, tokenDB driver.TokenDB) *enhancedManager + func TestInsufficientTokensManyReplicas(t *testing.T, replicas []EnhancedManager) + func TestInsufficientTokensOneReplica(t *testing.T, replica EnhancedManager) + func TestSufficientTokensBigDenominationsManyReplicas(t *testing.T, replicas []EnhancedManager) + func TestSufficientTokensBigDenominationsOneReplica(t *testing.T, replica EnhancedManager) + func TestSufficientTokensManyReplicas(t *testing.T, replicas []EnhancedManager) + func TestSufficientTokensOneReplica(t *testing.T, replica EnhancedManager) + type EnhancedManager interface + TokenSum func() (token.Quantity, error) + UpdateTokens func(spentTokens []*token.ID, addedTokens []token.UnspentToken) error + type MockIterator struct + func (m *MockIterator) Close() + func (m *MockIterator) Next() (*token2.UnspentToken, error) + type MockQueryService struct + func NewMockQueryService() *MockQueryService + func (q *MockQueryService) Add(key string, t *token2.UnspentToken) + func (q *MockQueryService) GetStatus(txID string) (token.TxStatus, string, error) + func (q *MockQueryService) GetTokens(inputs ...*token2.ID) ([]*token2.Token, error) + func (q *MockQueryService) GetUnspentToken(tokenID *token2.ID) *token2.UnspentToken + func (q *MockQueryService) GetUnspentTokens(inputs ...*token2.ID) ([]*token2.UnspentToken, error) + func (q *MockQueryService) SpendableTokensIteratorBy(ctx context.Context, walletID string, typ token2.Type) (driver.SpendableTokensIterator, error) + func (q *MockQueryService) UnspentTokensIterator() (*token.UnspentTokensIterator, error) + func (q *MockQueryService) UnspentTokensIteratorBy(_ context.Context, walletID string, _ token2.Type) (driver.UnspentTokensIterator, error) + func (q *MockQueryService) WarmupCache(walletID, tokenType string) + type MockVault struct + func (m *MockVault) GetStatus(txID string) (ttxdb.TxStatus, string, error) + type NoLock struct + func (n *NoLock) IsLocked(id *token2.ID) bool + func (n *NoLock) Lock(id *token2.ID, txID string, reclaim bool) (string, error) + func (n *NoLock) UnlockByTxID(txID string) + func (n *NoLock) UnlockIDs(id ...*token2.ID) []*token2.ID + type TokenFilter struct + Wallet []byte + WalletID string + func (c *TokenFilter) ContainsToken(token *token2.UnspentToken) bool + func (c *TokenFilter) ID() string
Go to main page