process

Documentation

Index

• func NewHyperBlockProcessor(args *HyperBlockProcessorArgs) (*hyperBlockProcessor, error)
• type AlteredAccountsHandler
• type EpochStartInfoHandler
• type HyperBlockProcessorArgs
• type LogHandler
• type ReceiptHandler
• type ShardBlocksHandler
• type TransactionHandler

Functions

func NewHyperBlockProcessor

func NewHyperBlockProcessor(args *HyperBlockProcessorArgs) (*hyperBlockProcessor, error)

NewHyperBlockProcessor will create a new instance of an hyper block processor

Types

type AlteredAccountsHandler

type AlteredAccountsHandler interface {
	ProcessAccounts(apiAlteredAccounts []*outport.AlteredAccount) ([]*schema.AccountBalanceUpdate, error)
}

AlteredAccountsHandler defines what an account processor shall do

type EpochStartInfoHandler

type EpochStartInfoHandler interface {
	ProcessEpochStartInfo(apiEpochInfo *api.EpochStartInfo) (*schema.EpochStartInfo, error)
}

EpochStartInfoHandler defines what epoch start info processor shall do

type HyperBlockProcessorArgs

type HyperBlockProcessorArgs struct {
	TransactionHandler    TransactionHandler
	ShardBlockHandler     ShardBlocksHandler
	EpochStartInfoHandler EpochStartInfoHandler
}

HyperBlockProcessorArgs holds all input dependencies required by hyper block processor in order to create a new hyper block processor

type LogHandler

type LogHandler interface {
	ProcessLog(log *transaction.ApiLogs) *schema.Log
}

LogHandler defines what a log processor shall do

type ReceiptHandler

type ReceiptHandler interface {
	ProcessReceipt(apiReceipt *transaction.ApiReceipt) (*schema.Receipt, error)
}

ReceiptHandler defines what a receipt processor shall do

type ShardBlocksHandler

type ShardBlocksHandler interface {
	ProcessShardBlocks(apiBlocks []*api.NotarizedBlock) ([]*schema.ShardBlocks, error)
}

ShardBlocksHandler defines what shard blocks processor shall do

type TransactionHandler

type TransactionHandler interface {
	ProcessTransactions(apiTransactions []*transaction.ApiTransactionResult) ([]*schema.Transaction, error)
}

TransactionHandler defines what a transaction processor shall do