preprocess

Documentation

Index

• func NewIntermediateResultsProcessor(hasher hashing.Hasher, marshalizer marshal.Marshalizer, ...) (*intermediateResultsProcessor, error)
• func NewRewardTxHandler(address process.SpecialAddressHandler, hasher hashing.Hasher, ...) (*rewardsHandler, error)
• func NewRewardTxPreprocessor(rewardTxDataPool dataRetriever.ShardedDataCacherNotifier, ...) (*rewardTxPreprocessor, error)
• func NewSmartContractResultPreprocessor(scrDataPool dataRetriever.ShardedDataCacherNotifier, ...) (*smartContractResults, error)
• func NewTransactionPreprocessor(txDataPool dataRetriever.ShardedDataCacherNotifier, ...) (*transactions, error)
• func SortTxByNonce(txShardPool storage.Cacher) ([]*transaction.Transaction, [][]byte, error)

Functions

func NewIntermediateResultsProcessor

func NewIntermediateResultsProcessor(
	hasher hashing.Hasher,
	marshalizer marshal.Marshalizer,
	coordinator sharding.Coordinator,
	adrConv state.AddressConverter,
	store dataRetriever.StorageService,
	blockType block.Type,
) (*intermediateResultsProcessor, error)

NewIntermediateResultsProcessor creates a new intermediate results processor

func NewRewardTxHandler

func NewRewardTxHandler(
	address process.SpecialAddressHandler,
	hasher hashing.Hasher,
	marshalizer marshal.Marshalizer,
	shardCoordinator sharding.Coordinator,
	adrConv state.AddressConverter,
	store dataRetriever.StorageService,
	rewardTxPool dataRetriever.ShardedDataCacherNotifier,
	economicsRewards process.RewardsHandler,
) (*rewardsHandler, error)

NewRewardTxHandler constructor for the reward transaction handler

func NewRewardTxPreprocessor

func NewRewardTxPreprocessor(
	rewardTxDataPool dataRetriever.ShardedDataCacherNotifier,
	store dataRetriever.StorageService,
	hasher hashing.Hasher,
	marshalizer marshal.Marshalizer,
	rewardProcessor process.RewardTransactionProcessor,
	rewardProducer process.InternalTransactionProducer,
	shardCoordinator sharding.Coordinator,
	accounts state.AccountsAdapter,
	onRequestRewardTransaction func(shardID uint32, txHashes [][]byte),
) (*rewardTxPreprocessor, error)

NewRewardTxPreprocessor creates a new reward transaction preprocessor object

func NewSmartContractResultPreprocessor

func NewSmartContractResultPreprocessor(
	scrDataPool dataRetriever.ShardedDataCacherNotifier,
	store dataRetriever.StorageService,
	hasher hashing.Hasher,
	marshalizer marshal.Marshalizer,
	scrProcessor process.SmartContractResultProcessor,
	shardCoordinator sharding.Coordinator,
	accounts state.AccountsAdapter,
	onRequestSmartContractResult func(shardID uint32, txHashes [][]byte),
) (*smartContractResults, error)

NewSmartContractResultPreprocessor creates a new smartContractResult preprocessor object

func NewTransactionPreprocessor

func NewTransactionPreprocessor(
	txDataPool dataRetriever.ShardedDataCacherNotifier,
	store dataRetriever.StorageService,
	hasher hashing.Hasher,
	marshalizer marshal.Marshalizer,
	txProcessor process.TransactionProcessor,
	shardCoordinator sharding.Coordinator,
	accounts state.AccountsAdapter,
	onRequestTransaction func(shardID uint32, txHashes [][]byte),
	economicsFee process.FeeHandler,
) (*transactions, error)

NewTransactionPreprocessor creates a new transaction preprocessor object

func SortTxByNonce

func SortTxByNonce(txShardPool storage.Cacher) ([]*transaction.Transaction, [][]byte, error)

SortTxByNonce sort transactions according to nonces