auditor

package

Go to main page

Versions in this module

v0

v0.5.0

Jul 17, 2025

Changes in this version

+ type Service struct

+ func (a *Service) Append(ctx context.Context, tx Transaction) error

+ func (a *Service) Audit(ctx context.Context, tx Transaction) (*token.InputStream, *token.OutputStream, error)

+ func (a *Service) Check(ctx context.Context) ([]string, error)

+ func (a *Service) GetStatus(ctx context.Context, txID string) (TxStatus, string, error)

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

+ func (a *Service) Release(ctx context.Context, tx Transaction)

+ func (a *Service) SetStatus(ctx context.Context, txID string, status db.TxStatus, message string) error

+ func (a *Service) Validate(ctx context.Context, request *token.Request) error

+ type ServiceManager struct

+ func NewServiceManager(networkProvider NetworkProvider, auditStoreServiceManager StoreServiceManager, ...) *ServiceManager

+ func (cm *ServiceManager) Auditor(tmsID token.TMSID) (*Service, error)

+ func (cm *ServiceManager) RestoreTMS(tmsID token.TMSID) error

+ type StoreServiceManager db.StoreServiceManager[*auditdb.StoreService]

+ type TokensServiceManager db.ServiceManager[*tokens.Service]

v0.4.0

Jan 7, 2025

Changes in this version

+ var TxStatusMessage = auditdb.TxStatusMessage

+ type AuditDBProvider interface

+ DBByTMSId func(id token.TMSID) (*auditdb.DB, error)

type Auditor

+ func GetByTMSID(sp token.ServiceProvider, tmsID token.TMSID) *Auditor

+ func (a *Auditor) Check(context context.Context) ([]string, error)

+ type CheckService interface

+ Check func(context context.Context) ([]string, error)

+ type CheckServiceProvider interface

+ CheckService func(id token.TMSID, adb *auditdb.DB, tdb *tokens.Tokens) (CheckService, error)

type Manager

+ func (cm *Manager) RestoreTMS(tmsID token.TMSID) error

+ type NetworkProvider interface

+ GetNetwork func(network string, channel string) (*network.Network, error)

+ type TokenDBProvider interface

+ Tokens func(id token.TMSID) (*tokens.Tokens, error)

+ type TokenManagementServiceProvider interface

+ GetManagementService func(opts ...token.ServiceOption) (*token.ManagementService, error)

type Transaction

+ Namespace func() string

v0.3.0

Oct 5, 2023

Changes in this version

type Auditor

+ func (a *Auditor) GetStatus(txID string) (TxStatus, error)

+ func (a *Auditor) GetTokenRequest(txID string) ([]byte, error)

v0.2.0

Dec 7, 2022

Changes in this version

type Auditor

+ func (a *Auditor) Release(tx Transaction)

v0.1.0

Nov 16, 2022

Changes in this version

+ const Confirmed

+ const Deleted

+ const Pending

+ type Auditor struct

+ func Get(sp view.ServiceProvider, w *token.AuditorWallet) *Auditor

+ func New(sp view.ServiceProvider, w *token.AuditorWallet) *Auditor

+ func (a *Auditor) Append(tx Transaction) error

+ func (a *Auditor) Audit(request *token.Request) (*token.InputStream, *token.OutputStream, error)

+ func (a *Auditor) NewQueryExecutor() *QueryExecutor

+ func (a *Auditor) SetStatus(txID string, status TxStatus) error

+ func (a *Auditor) Validate(request *token.Request) error

+ type Entry struct

+ TMSID token.TMSID

+ WalletID string

+ type KVS interface

+ Exists func(id string) bool

+ Get func(id string, state interface{}) error

+ Put func(id string, state interface{}) error

+ type Manager struct

+ func NewManager(sp view.ServiceProvider, kvs KVS) *Manager

+ func (cm *Manager) Auditor(w *token.AuditorWallet) (*Auditor, error)

+ func (cm *Manager) Restore() error

+ type QueryExecutor struct

+ func (a *QueryExecutor) Done()

+ func (a *QueryExecutor) NewHoldingsFilter() *ttxdb.HoldingsFilter

+ func (a *QueryExecutor) NewPaymentsFilter() *ttxdb.PaymentsFilter

+ type Transaction interface

+ Channel func() string

+ ID func() string

+ Network func() string

+ Request func() *token.Request

+ type TxStatus = ttxdb.TxStatus

+ type TxStatusChangesListener struct

+ func (t *TxStatusChangesListener) OnStatusChange(txID string, status int) error

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