testutils

package

v0.5.0 Latest Latest Go to latest Published: Jul 17, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hyperledger-labs/fabric-token-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewEnhancedManager(manager token2.SelectorManager, tokenDB driver.TokenStore) *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
type MockIterator
- func (m *MockIterator) Close()
- func (m *MockIterator) Next() (*token2.UnspentToken, error)
type MockQueryService
- func NewMockQueryService() *MockQueryService
- func (q *MockQueryService) Add(key string, t *token2.UnspentToken)
- func (q *MockQueryService) GetStatus(ctx context.Context, txID string) (token.TxStatus, string, error)
- func (q *MockQueryService) GetTokens(ctx context.Context, inputs ...*token2.ID) ([]*token2.Token, error)
- func (q *MockQueryService) GetUnspentToken(_ context.Context, tokenID *token2.ID) *token2.UnspentToken
- func (q *MockQueryService) GetUnspentTokens(_ context.Context, 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(context.Context) (*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
- func (m *MockVault) GetStatus(ctx context.Context, txID string) (ttxdb.TxStatus, string, error)
type NoLock
- func (n *NoLock) IsLocked(id *token2.ID) bool
- func (n *NoLock) Lock(ctx context.Context, id *token2.ID, txID string, reclaim bool) (string, error)
- func (n *NoLock) UnlockByTxID(ctx context.Context, txID string)
- func (n *NoLock) UnlockIDs(ctx context.Context, ids ...*token2.ID) []*token2.ID
type TokenFilter
- func (c *TokenFilter) ContainsToken(token *token2.UnspentToken) bool
- func (c *TokenFilter) ID() string

Constants ¶

View Source

const (
	NumTokensPerWallet         = 1000000
	TokenQuantityPrecision     = 64
	SelectQuantity             = "100"
	TxID                       = "someTxID"
	TokenType                  = "USD"
	SelectorNumRetries         = 3
	SelectorTimeout            = 5 * time.Second
	LockSleepTimeout           = 2 * time.Second
	LockValidTxEvictionTimeout = 5 * time.Minute
)

Variables ¶

This section is empty.

Functions ¶

func NewEnhancedManager ¶

func NewEnhancedManager(manager token2.SelectorManager, tokenDB driver.TokenStore) *enhancedManager

func TestInsufficientTokensManyReplicas ¶

func TestInsufficientTokensManyReplicas(t *testing.T, replicas []EnhancedManager)

func TestInsufficientTokensOneReplica ¶

func TestInsufficientTokensOneReplica(t *testing.T, replica EnhancedManager)

func TestSufficientTokensBigDenominationsManyReplicas ¶

func TestSufficientTokensBigDenominationsManyReplicas(t *testing.T, replicas []EnhancedManager)

func TestSufficientTokensBigDenominationsOneReplica ¶

func TestSufficientTokensBigDenominationsOneReplica(t *testing.T, replica EnhancedManager)

func TestSufficientTokensManyReplicas ¶

func TestSufficientTokensManyReplicas(t *testing.T, replicas []EnhancedManager)

func TestSufficientTokensOneReplica ¶

func TestSufficientTokensOneReplica(t *testing.T, replica EnhancedManager)

Types ¶

type EnhancedManager ¶

type EnhancedManager interface {
	token2.SelectorManager
	TokenSum() (token.Quantity, error)
	UpdateTokens(spentTokens []*token.ID, addedTokens []token.UnspentToken) error
}

type MockIterator ¶

type MockIterator struct {
	// contains filtered or unexported fields
}

func (*MockIterator) Close ¶

func (m *MockIterator) Close()

func (*MockIterator) Next ¶

func (m *MockIterator) Next() (*token2.UnspentToken, error)

type MockQueryService ¶

type MockQueryService struct {
	// contains filtered or unexported fields
}

func NewMockQueryService ¶

func NewMockQueryService() *MockQueryService

func (*MockQueryService) Add ¶

func (q *MockQueryService) Add(key string, t *token2.UnspentToken)

func (*MockQueryService) GetStatus ¶

func (q *MockQueryService) GetStatus(ctx context.Context, txID string) (token.TxStatus, string, error)

func (*MockQueryService) GetTokens ¶

func (q *MockQueryService) GetTokens(ctx context.Context, inputs ...*token2.ID) ([]*token2.Token, error)

func (*MockQueryService) GetUnspentToken ¶

func (q *MockQueryService) GetUnspentToken(_ context.Context, tokenID *token2.ID) *token2.UnspentToken

func (*MockQueryService) GetUnspentTokens ¶

func (q *MockQueryService) GetUnspentTokens(_ context.Context, inputs ...*token2.ID) ([]*token2.UnspentToken, error)

func (*MockQueryService) SpendableTokensIteratorBy ¶

func (q *MockQueryService) SpendableTokensIteratorBy(ctx context.Context, walletID string, typ token2.Type) (driver.SpendableTokensIterator, error)

func (*MockQueryService) UnspentTokensIterator ¶

func (q *MockQueryService) UnspentTokensIterator(context.Context) (*token.UnspentTokensIterator, error)

func (*MockQueryService) UnspentTokensIteratorBy ¶

func (q *MockQueryService) UnspentTokensIteratorBy(_ context.Context, walletID string, _ token2.Type) (driver.UnspentTokensIterator, error)

func (*MockQueryService) WarmupCache ¶

func (q *MockQueryService) WarmupCache(walletID, tokenType string)

type MockVault ¶

type MockVault struct {
}

func (*MockVault) GetStatus ¶

func (m *MockVault) GetStatus(ctx context.Context, txID string) (ttxdb.TxStatus, string, error)

type NoLock ¶

type NoLock struct {
}

func (*NoLock) IsLocked ¶

func (n *NoLock) IsLocked(id *token2.ID) bool

func (*NoLock) Lock ¶

func (n *NoLock) Lock(ctx context.Context, id *token2.ID, txID string, reclaim bool) (string, error)

func (*NoLock) UnlockByTxID ¶

func (n *NoLock) UnlockByTxID(ctx context.Context, txID string)

func (*NoLock) UnlockIDs ¶

func (n *NoLock) UnlockIDs(ctx context.Context, ids ...*token2.ID) []*token2.ID

type TokenFilter ¶

type TokenFilter struct {
	Wallet   []byte
	WalletID string
}

func (*TokenFilter) ContainsToken ¶

func (c *TokenFilter) ContainsToken(token *token2.UnspentToken) bool

func (*TokenFilter) ID ¶

func (c *TokenFilter) ID() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL