ttxdb

package

Go to main page

Versions in this module

v0

v0.5.0

Jul 17, 2025

Changes in this version

+ type PageTransactionsIterator = cdriver.PageIterator[*TransactionRecord]

+ type Pagination = cdriver.Pagination

+ type StoreService struct

+ func (d *StoreService) AddTransactionEndorsementAck(ctx context.Context, txID string, id token.Identity, sigma []byte) error

+ func (d *StoreService) AppendTransactionRecord(ctx context.Context, req *token.Request) error

+ func (d *StoreService) AppendValidationRecord(ctx context.Context, txID string, tokenRequest []byte, meta map[string][]byte, ...) error

+ func (d *StoreService) GetStatus(ctx context.Context, txID string) (TxStatus, string, error)

+ func (d *StoreService) GetTokenRequest(ctx context.Context, txID string) ([]byte, error)

+ func (d *StoreService) GetTransactionEndorsementAcks(ctx context.Context, txID string) (map[string][]byte, error)

+ func (d *StoreService) SetStatus(ctx context.Context, txID string, status driver.TxStatus, message string) error

+ func (d *StoreService) TokenRequests(ctx context.Context, params QueryTokenRequestsParams) (driver.TokenRequestIterator, error)

+ func (d *StoreService) Transactions(ctx context.Context, params QueryTransactionsParams, pagination Pagination) (*PageTransactionsIterator, error)

+ func (d *StoreService) ValidationRecords(ctx context.Context, params QueryValidationRecordsParams) (*ValidationRecordsIterator, error)

+ type StoreServiceManager db.StoreServiceManager[*StoreService]

+ func NewStoreServiceManager(cp cdriver.ConfigService, drivers multiplexed.Driver) StoreServiceManager

v0.4.0

Jan 7, 2025

Changes in this version

+ var TxStatusMessage = driver.TxStatusMessage

+ type Cache interface

+ Add func(key string, value []byte)

+ Delete func(key string)

+ Get func(key string) ([]byte, bool)

type DB

+ func GetByTMSId(sp token.ServiceProvider, tmsID token.TMSID) (*DB, error)

+ func (d *DB) AddTransactionEndorsementAck(txID string, id token.Identity, sigma []byte) error

+ func (d *DB) GetTransactionEndorsementAcks(txID string) (map[string][]byte, error)

+ func (d *DB) TokenRequests(params QueryTokenRequestsParams) (driver.TokenRequestIterator, error)

+ func (d *DB) Transactions(params QueryTransactionsParams) (driver.TransactionIterator, error)

+ func (d *DB) ValidationRecords(params QueryValidationRecordsParams) (*ValidationRecordsIterator, error)

+ type Holder = db.DriverHolder[*DB, driver.TokenTransactionDB, driver.TTXDBDriver]

+ func NewHolder(drivers []db.NamedDriver[driver.TTXDBDriver]) *Holder

type MovementRecord

+ func Movements(record *token.AuditRecord, created time.Time) (mv []MovementRecord, err error)

+ type QueryTokenRequestsParams = driver.QueryTokenRequestsParams

type TransactionRecord

+ func TransactionRecords(record *token.AuditRecord, timestamp time.Time) (txs []TransactionRecord, err error)

v0.3.0

Oct 5, 2023

Changes in this version

+ const Unknown

type DB

+ func (db *DB) AppendValidationRecord(txID string, tr []byte, meta map[string][]byte) error

+ func (db *DB) GetStatus(txID string) (TxStatus, error)

+ func (db *DB) GetTokenRequest(txID string) ([]byte, error)

type QueryExecutor

+ func (qe *QueryExecutor) ValidationRecords(params QueryValidationRecordsParams) (*ValidationRecordsIterator, error)

+ type QueryValidationRecordsParams = driver.QueryValidationRecordsParams

+ type ValidationRecord = driver.ValidationRecord

+ type ValidationRecordsIterator struct

+ func (t *ValidationRecordsIterator) Close()

+ func (t *ValidationRecordsIterator) Next() (*ValidationRecord, error)

v0.2.0

Dec 7, 2022

Changes in this version

type DB

+ func (db *DB) ReleaseLocks(anchor string)

v0.1.0

Nov 16, 2022

Changes in this version

+ const PersistenceTypeConfigKey

+ func Drivers() []string

+ func Register(name string, driver driver.Driver)

+ type ActionType = driver.ActionType

+ const Issue

+ const Redeem

+ const Transfer

+ type DB struct

+ func Get(sp view2.ServiceProvider, w Wallet) *DB

+ func (db *DB) AcquireLocks(eIDs ...string) error

+ func (db *DB) Append(req *token.Request) error

+ func (db *DB) AppendTransactionRecord(req *token.Request) error

+ func (db *DB) NewQueryExecutor() *QueryExecutor

+ func (db *DB) SetStatus(txID string, status TxStatus) error

+ func (db *DB) Unlock(eIDs ...string)

+ type HoldingsFilter struct

+ func (f *HoldingsFilter) ByEnrollmentId(id string) *HoldingsFilter

+ func (f *HoldingsFilter) ByType(tokenType string) *HoldingsFilter

+ func (f *HoldingsFilter) Execute() (*HoldingsFilter, error)

+ func (f *HoldingsFilter) Sum() *big.Int

+ type Manager struct

+ func NewManager(sp view2.ServiceProvider, driver string) *Manager

+ func (cm *Manager) DB(w Wallet) (*DB, error)

+ type MovementRecord = driver.MovementRecord

+ type PaymentsFilter struct

+ func (f *PaymentsFilter) ByEnrollmentId(id string) *PaymentsFilter

+ func (f *PaymentsFilter) ByType(tokenType string) *PaymentsFilter

+ func (f *PaymentsFilter) Execute() (*PaymentsFilter, error)

+ func (f *PaymentsFilter) Last(num int) *PaymentsFilter

+ func (f *PaymentsFilter) Sum() *big.Int

+ type QueryExecutor struct

+ func (qe *QueryExecutor) Done()

+ func (qe *QueryExecutor) NewHoldingsFilter() *HoldingsFilter

+ func (qe *QueryExecutor) NewPaymentsFilter() *PaymentsFilter

+ func (qe *QueryExecutor) Transactions(params QueryTransactionsParams) (*TransactionIterator, error)

+ type QueryTransactionsParams = driver.QueryTransactionsParams

+ type TransactionIterator struct

+ func (t *TransactionIterator) Close()

+ func (t *TransactionIterator) Next() (*TransactionRecord, error)

+ type TransactionRecord = driver.TransactionRecord

+ type TxStatus = driver.TxStatus

+ const Confirmed

+ const Deleted

+ const Pending

+ type Wallet interface

+ ID func() string

+ TMS func() *token.ManagementService

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