Versions in this module Expand all Collapse all v0 v0.4.0 Jan 7, 2025 Changes in this version + const AddToken + const DeleteToken + func NewTransaction(notifier events.Publisher, tx *tokendb.Transaction, tmsID token.TMSID) (*transaction, error) + func WrapMetadataWithType(typ driver.Type, id driver.Metadata) (driver.Metadata, error) + func WrapWithType(typ driver.Type, id driver.Token) (driver.Token, error) + type Cache interface + Add func(key string, value *CacheEntry) + Delete func(key string) + Get func(key string) (*CacheEntry, bool) + type CacheEntry struct + Request *token.Request + ToAppend []TokenToAppend + ToSpend []*token2.ID + type DBProvider interface + DBByTMSId func(id token.TMSID) (*tokendb.DB, error) + type DBStorage struct + func NewDBStorage(notifier events.Publisher, tokenDB *tokendb.DB, tmsID token.TMSID) (*DBStorage, error) + func (d *DBStorage) NewTransaction() (*transaction, error) + func (d *DBStorage) StorePublicParams(raw []byte) error + func (d *DBStorage) TransactionExists(ctx context.Context, id string) (bool, error) + type Flags struct + Auditor bool + Issuer bool + Mine bool + type GetTMSProviderFunc = func() *token.ManagementServiceProvider + type Manager struct + func GetProvider(sp token.ServiceProvider) (*Manager, error) + func NewManager(tmsProvider TMSProvider, dbManager DBProvider, notifier events.Publisher) *Manager + func (cm *Manager) Tokens(tmsID token.TMSID) (*Tokens, error) + type MetaData interface + GetToken func(raw []byte) (*token2.Token, token.Identity, []byte, error) + SpentTokenID func() []*token2.ID + type TMSProvider interface + GetManagementService func(opts ...token.ServiceOption) (*token.ManagementService, error) + type TokenMessage struct + Index uint64 + TMSID token.TMSID + TokenType token2.Type + TxID string + WalletID string + type TokenProcessorEvent struct + func NewTokenProcessorEvent(topic string, message *TokenMessage) *TokenProcessorEvent + func (t *TokenProcessorEvent) Message() interface{} + func (t *TokenProcessorEvent) Topic() string + type TokenToAppend struct + type Tokens struct + RequestsCache Cache + Storage *DBStorage + TMSProvider TMSProvider + func GetService(sp token.ServiceProvider, tmsID token.TMSID) (*Tokens, error) + func (t *Tokens) Append(ctx context.Context, tmsID token.TMSID, txID string, request *token.Request) (err error) + func (t *Tokens) AppendRaw(ctx context.Context, tmsID token.TMSID, txID string, requestRaw []byte) (err error) + func (t *Tokens) AppendTransaction(ctx context.Context, tx Transaction) (err error) + func (t *Tokens) CacheRequest(tmsID token.TMSID, request *token.Request) error + func (t *Tokens) DeleteToken(deletedBy string, ids ...*token2.ID) (err error) + func (t *Tokens) GetCachedTokenRequest(txID string) *token.Request + func (t *Tokens) SetSpendableBySupportedTokenTypes(types []token2.Format) error + func (t *Tokens) SetSpendableFlag(value bool, ids ...*token2.ID) error + func (t *Tokens) SetSupportedTokenTypes(tokenTypes []token2.Format) error + func (t *Tokens) StorePublicParams(raw []byte) error + type Transaction interface + Channel func() string + ID func() string + Namespace func() string + Network func() string + Request func() *token.Request + type TypedMetadata struct + Metadata driver.Metadata + Type driver.Type + func UnmarshalTypedMetadata(metadata driver.Metadata) (*TypedMetadata, error) + func (i TypedMetadata) Bytes() ([]byte, error) + type TypedToken struct + Token driver.Token + Type driver.Type + func UnmarshalTypedToken(token driver.Token) (*TypedToken, error) + func (i TypedToken) Bytes() ([]byte, error)
Go to main page