Versions in this module Expand all Collapse all v0 v0.6.5 Dec 3, 2020 Changes in this version + type BalanceStorageHandler struct + func NewBalanceStorageHandler(logger *logger.Logger, reconciler *reconciler.Reconciler, ...) *BalanceStorageHandler + func (h *BalanceStorageHandler) AccountsReconciled(ctx context.Context, dbTx database.Transaction, count int) error + func (h *BalanceStorageHandler) AccountsSeen(ctx context.Context, dbTx database.Transaction, count int) error + func (h *BalanceStorageHandler) BlockAdded(ctx context.Context, block *types.Block, changes []*parser.BalanceChange) error + func (h *BalanceStorageHandler) BlockRemoved(ctx context.Context, block *types.Block, changes []*parser.BalanceChange) error + type BalanceStorageHelper struct + func NewBalanceStorageHelper(network *types.NetworkIdentifier, fetcher *fetcher.Fetcher, ...) *BalanceStorageHelper + func (h *BalanceStorageHelper) AccountBalance(ctx context.Context, account *types.AccountIdentifier, ...) (*types.Amount, error) + func (h *BalanceStorageHelper) AccountsReconciled(ctx context.Context, dbTx database.Transaction) (*big.Int, error) + func (h *BalanceStorageHelper) AccountsSeen(ctx context.Context, dbTx database.Transaction) (*big.Int, error) + func (h *BalanceStorageHelper) AddInterestingAddress(address string) + func (h *BalanceStorageHelper) Asserter() *asserter.Asserter + func (h *BalanceStorageHelper) BalanceExemptions() []*types.BalanceExemption + func (h *BalanceStorageHelper) ExemptFunc() parser.ExemptOperation + type BroadcastStorageHandler struct + func NewBroadcastStorageHandler(config *configuration.Configuration, counterStorage *modules.CounterStorage, ...) *BroadcastStorageHandler + func (h *BroadcastStorageHandler) BroadcastFailed(ctx context.Context, dbTx database.Transaction, identifier string, ...) error + func (h *BroadcastStorageHandler) TransactionConfirmed(ctx context.Context, dbTx database.Transaction, identifier string, ...) error + func (h *BroadcastStorageHandler) TransactionStale(ctx context.Context, dbTx database.Transaction, identifier string, ...) error + type BroadcastStorageHelper struct + func NewBroadcastStorageHelper(blockStorage *modules.BlockStorage, fetcher *fetcher.Fetcher) *BroadcastStorageHelper + func (h *BroadcastStorageHelper) AtTip(ctx context.Context, tipDelay int64) (bool, error) + func (h *BroadcastStorageHelper) BroadcastTransaction(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (*types.TransactionIdentifier, error) + func (h *BroadcastStorageHelper) CurrentBlockIdentifier(ctx context.Context) (*types.BlockIdentifier, error) + func (h *BroadcastStorageHelper) FindTransaction(ctx context.Context, transactionIdentifier *types.TransactionIdentifier, ...) (*types.BlockIdentifier, *types.Transaction, error) + type CoinStorageHelper struct + func NewCoinStorageHelper(blockStorage *modules.BlockStorage) *CoinStorageHelper + func (c *CoinStorageHelper) CurrentBlockIdentifier(ctx context.Context, transaction database.Transaction) (*types.BlockIdentifier, error) + type CoordinatorHandler struct + func NewCoordinatorHandler(counterStorage *modules.CounterStorage) *CoordinatorHandler + func (h *CoordinatorHandler) TransactionCreated(ctx context.Context, jobIdentifier string, ...) error + type CoordinatorHelper struct + func NewCoordinatorHelper(offlineFetcher *fetcher.Fetcher, onlineFetcher *fetcher.Fetcher, ...) *CoordinatorHelper + func (c *CoordinatorHelper) AllAccounts(ctx context.Context, dbTx database.Transaction) ([]*types.AccountIdentifier, error) + func (c *CoordinatorHelper) AllBroadcasts(ctx context.Context) ([]*modules.Broadcast, error) + func (c *CoordinatorHelper) Balance(ctx context.Context, dbTx database.Transaction, ...) (*types.Amount, error) + func (c *CoordinatorHelper) Broadcast(ctx context.Context, dbTx database.Transaction, identifier string, ...) error + func (c *CoordinatorHelper) BroadcastAll(ctx context.Context) error + func (c *CoordinatorHelper) ClearBroadcasts(ctx context.Context) ([]*modules.Broadcast, error) + func (c *CoordinatorHelper) Coins(ctx context.Context, dbTx database.Transaction, ...) ([]*types.Coin, error) + func (c *CoordinatorHelper) Combine(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (string, error) + func (c *CoordinatorHelper) DatabaseTransaction(ctx context.Context) database.Transaction + func (c *CoordinatorHelper) Derive(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (*types.AccountIdentifier, map[string]interface{}, error) + func (c *CoordinatorHelper) GetKey(ctx context.Context, dbTx database.Transaction, ...) (*keys.KeyPair, error) + func (c *CoordinatorHelper) Hash(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (*types.TransactionIdentifier, error) + func (c *CoordinatorHelper) HeadBlockExists(ctx context.Context) bool + func (c *CoordinatorHelper) LockedAccounts(ctx context.Context, dbTx database.Transaction) ([]*types.AccountIdentifier, error) + func (c *CoordinatorHelper) Metadata(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (map[string]interface{}, []*types.Amount, error) + func (c *CoordinatorHelper) Parse(ctx context.Context, networkIdentifier *types.NetworkIdentifier, signed bool, ...) ([]*types.Operation, []*types.AccountIdentifier, map[string]interface{}, error) + func (c *CoordinatorHelper) Payloads(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (string, []*types.SigningPayload, error) + func (c *CoordinatorHelper) Preprocess(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (map[string]interface{}, []*types.AccountIdentifier, error) + func (c *CoordinatorHelper) Sign(ctx context.Context, payloads []*types.SigningPayload) ([]*types.Signature, error) + func (c *CoordinatorHelper) StoreKey(ctx context.Context, dbTx database.Transaction, ...) error + type ReconcilerHandler struct + ActiveFailureBlock *types.BlockIdentifier + InactiveFailure *types.AccountCurrency + InactiveFailureBlock *types.BlockIdentifier + func NewReconcilerHandler(logger *logger.Logger, counterStorage *modules.CounterStorage, ...) *ReconcilerHandler + func (h *ReconcilerHandler) ReconciliationExempt(ctx context.Context, reconciliationType string, ...) error + func (h *ReconcilerHandler) ReconciliationFailed(ctx context.Context, reconciliationType string, ...) error + func (h *ReconcilerHandler) ReconciliationSkipped(ctx context.Context, reconciliationType string, ...) error + func (h *ReconcilerHandler) ReconciliationSucceeded(ctx context.Context, reconciliationType string, ...) error + func (h *ReconcilerHandler) UpdateCounts(ctx context.Context) error + func (h *ReconcilerHandler) Updater(ctx context.Context) error + type ReconcilerHelper struct + func NewReconcilerHelper(config *configuration.Configuration, network *types.NetworkIdentifier, ...) *ReconcilerHelper + func (h *ReconcilerHelper) CanonicalBlock(ctx context.Context, dbTx database.Transaction, block *types.BlockIdentifier) (bool, error) + func (h *ReconcilerHelper) ComputedBalance(ctx context.Context, dbTx database.Transaction, ...) (*types.Amount, error) + func (h *ReconcilerHelper) CurrentBlock(ctx context.Context, dbTx database.Transaction) (*types.BlockIdentifier, error) + func (h *ReconcilerHelper) DatabaseTransaction(ctx context.Context) database.Transaction + func (h *ReconcilerHelper) IndexAtTip(ctx context.Context, index int64) (bool, error) + func (h *ReconcilerHelper) LiveBalance(ctx context.Context, account *types.AccountIdentifier, ...) (*types.Amount, *types.BlockIdentifier, error) + func (h *ReconcilerHelper) PruneBalances(ctx context.Context, account *types.AccountIdentifier, ...) error
Go to main page