simple

type Cache interface {
	Get(key string) (interface{}, bool)
	Add(key string, value interface{})
}

type Locker interface {
	Lock(ctx context.Context, id *token2.ID, txID string, reclaim bool) (string, error)
	// UnlockIDs unlocks the passed IDS. It returns the list of tokens that were not locked in the first place among
	// those passed.
	UnlockIDs(ctx context.Context, ids ...*token2.ID) []*token2.ID
	UnlockByTxID(ctx context.Context, txID string)
	IsLocked(id *token2.ID) bool
}

type LockerProvider interface {
	New(network, channel, namespace string) (Locker, error)
}

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

type NewQueryEngineFunc func() QueryService

type QueryService interface {
	UnspentTokensIterator(ctx context.Context) (*token.UnspentTokensIterator, error)
	UnspentTokensIteratorBy(ctx context.Context, id string, tokenType token2.Type) (driver.UnspentTokensIterator, error)
	GetTokens(ctx context.Context, inputs ...*token2.ID) ([]*token2.Token, error)
}

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