preprocess

Documentation

Index

• func NewGasComputation(economicsFee process.FeeHandler) (*gasComputation, error)
• func NewIntermediateResultsProcessor(hasher hashing.Hasher, marshalizer marshal.Marshalizer, ...) (*intermediateResultsProcessor, error)
• func NewMiniBlocksCompaction(economicsFee process.FeeHandler, shardCoordinator sharding.Coordinator, ...) (*miniBlocksCompaction, 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 NewGasComputation

func NewGasComputation(
	economicsFee process.FeeHandler,
) (*gasComputation, error)

NewGasComputation creates a new object which computes the gas consumption

func NewIntermediateResultsProcessor

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

NewIntermediateResultsProcessor creates a new intermediate results processor

func NewMiniBlocksCompaction

func NewMiniBlocksCompaction(
	economicsFee process.FeeHandler,
	shardCoordinator sharding.Coordinator,
	gasHandler process.GasHandler,
) (*miniBlocksCompaction, error)

NewMiniBlocksCompaction creates a new mini blocks compaction object

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),
	gasHandler process.GasHandler,
) (*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),
	gasHandler process.GasHandler,
) (*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,
	miniBlocksCompacter process.MiniBlocksCompacter,
	gasHandler process.GasHandler,
) (*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