processor

package

Go to main page

Versions in this module

v0

v0.4.0

Jul 29, 2020

Changes in this version

+ type BalanceStorageHandler struct

+ func NewBalanceStorageHandler(logger *logger.Logger, reconciler *reconciler.Reconciler, reconcile bool, ...) *BalanceStorageHandler

+ 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) AddInterestingAddress(address string)

+ func (h *BalanceStorageHelper) Asserter() *asserter.Asserter

+ func (h *BalanceStorageHelper) ExemptFunc() parser.ExemptOperation

+ type BroadcastStorageHandler struct

+ func NewBroadcastStorageHandler(config *configuration.Configuration, counterStorage *storage.CounterStorage, ...) *BroadcastStorageHandler

+ func (h *BroadcastStorageHandler) BroadcastFailed(ctx context.Context, transactionIdentifier *types.TransactionIdentifier, ...) error

+ func (h *BroadcastStorageHandler) TransactionConfirmed(ctx context.Context, blockIdentifier *types.BlockIdentifier, ...) error

+ func (h *BroadcastStorageHandler) TransactionStale(ctx context.Context, transactionIdentifier *types.TransactionIdentifier) error

+ type BroadcastStorageHelper struct

+ func NewBroadcastStorageHelper(network *types.NetworkIdentifier, blockStorage *storage.BlockStorage, ...) *BroadcastStorageHelper

+ func (h *BroadcastStorageHelper) AtTip(ctx context.Context, tipDelay int64) (bool, error)

+ func (h *BroadcastStorageHelper) BroadcastTransaction(ctx context.Context, networkTransaction string) (*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 ConstructorHandler struct

+ func NewConstructorHandler(balanceStorageHelper *BalanceStorageHelper, ...) *ConstructorHandler

+ func (h *ConstructorHandler) AddressCreated(ctx context.Context, address string) error

+ func (h *ConstructorHandler) TransactionCreated(ctx context.Context, sender string, ...) error

+ type ConstructorHelper struct

+ func NewConstructorHelper(offlineFetcher *fetcher.Fetcher, onlineFetcher *fetcher.Fetcher, ...) *ConstructorHelper

+ func (c *ConstructorHelper) AccountBalance(ctx context.Context, accountIdentifier *types.AccountIdentifier, ...) (*big.Int, error)

+ func (c *ConstructorHelper) AllAddresses(ctx context.Context) ([]string, error)

+ func (c *ConstructorHelper) AllBroadcasts(ctx context.Context) ([]*storage.Broadcast, error)

+ func (c *ConstructorHelper) Broadcast(ctx context.Context, sender string, intent []*types.Operation, ...) error

+ func (c *ConstructorHelper) ClearBroadcasts(ctx context.Context) ([]*storage.Broadcast, error)

+ func (c *ConstructorHelper) CoinBalance(ctx context.Context, accountIdentifier *types.AccountIdentifier, ...) (*big.Int, *types.CoinIdentifier, error)

+ func (c *ConstructorHelper) Combine(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (string, error)

+ func (c *ConstructorHelper) Derive(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (string, map[string]interface{}, error)

+ func (c *ConstructorHelper) Hash(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (*types.TransactionIdentifier, error)

+ func (c *ConstructorHelper) LockedAddresses(ctx context.Context) ([]string, error)

+ func (c *ConstructorHelper) Metadata(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (map[string]interface{}, error)

+ func (c *ConstructorHelper) Parse(ctx context.Context, networkIdentifier *types.NetworkIdentifier, signed bool, ...) ([]*types.Operation, []string, map[string]interface{}, error)

+ func (c *ConstructorHelper) Payloads(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (string, []*types.SigningPayload, error)

+ func (c *ConstructorHelper) Preprocess(ctx context.Context, networkIdentifier *types.NetworkIdentifier, ...) (map[string]interface{}, error)

+ func (c *ConstructorHelper) RandomAmount(min *big.Int, max *big.Int) *big.Int

+ func (c *ConstructorHelper) Sign(ctx context.Context, payloads []*types.SigningPayload) ([]*types.Signature, error)

+ func (c *ConstructorHelper) StoreKey(ctx context.Context, address string, keyPair *keys.KeyPair) error

v0.3.1

Jul 16, 2020

v0.3.0

Jul 16, 2020

v0.2.5

Jul 13, 2020

v0.2.4

May 30, 2020

v0.2.3

May 20, 2020

Changes in this version

type ReconcilerHandler

+ ActiveFailureBlock *types.BlockIdentifier

+ InactiveFailure *reconciler.AccountCurrency

+ InactiveFailureBlock *types.BlockIdentifier

v0.2.2

May 15, 2020

v0.2.1

May 13, 2020

Changes in this version

type ReconcilerHandler

+ func (h *ReconcilerHandler) NewAccountSeen(ctx context.Context, account *types.AccountIdentifier, ...) error

v0.2.0

May 8, 2020

Changes in this version

+ type BlockStorageHelper struct

+ func NewBlockStorageHelper(network *types.NetworkIdentifier, fetcher *fetcher.Fetcher, ...) *BlockStorageHelper

+ func (h *BlockStorageHelper) AccountBalance(ctx context.Context, account *types.AccountIdentifier, ...) (*types.Amount, error)

+ func (h *BlockStorageHelper) Asserter() *asserter.Asserter

+ func (h *BlockStorageHelper) ExemptFunc() parser.ExemptOperation

+ type ReconcilerHandler struct

+ func NewReconcilerHandler(cancel context.CancelFunc, logger *logger.Logger, ...) *ReconcilerHandler

+ func (h *ReconcilerHandler) ReconciliationFailed(ctx context.Context, reconciliationType string, ...) error

+ func (h *ReconcilerHandler) ReconciliationSucceeded(ctx context.Context, reconciliationType string, ...) error

+ type ReconcilerHelper struct

+ func NewReconcilerHelper(storage *storage.BlockStorage) *ReconcilerHelper

+ func (h *ReconcilerHelper) AccountBalance(ctx context.Context, account *types.AccountIdentifier, ...) (*types.Amount, *types.BlockIdentifier, error)

+ func (h *ReconcilerHelper) BlockExists(ctx context.Context, block *types.BlockIdentifier) (bool, error)

+ func (h *ReconcilerHelper) CurrentBlock(ctx context.Context) (*types.BlockIdentifier, error)

+ type SyncerHandler struct

+ func NewSyncerHandler(storage *storage.BlockStorage, logger *logger.Logger, ...) *SyncerHandler

+ func (h *SyncerHandler) BlockAdded(ctx context.Context, block *types.Block) error

+ func (h *SyncerHandler) BlockRemoved(ctx context.Context, blockIdentifier *types.BlockIdentifier) error

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