preprocess

Documentation

Index

• func NewGasComputation(economicsFee process.FeeHandler) (*gasComputation, 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)
• type BlockTracker
• type SortedTransactionsProvider

Functions

func NewGasComputation

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

NewGasComputation creates a new object which computes the gas consumption

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,
	economicsFee process.FeeHandler,
) (*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,
	blockTracker BlockTracker,
	blockType block.Type,
) (*transactions, error)

NewTransactionPreprocessor creates a new transaction preprocessor object

Types

type BlockTracker

type BlockTracker interface {
	IsShardStuck(shardID uint32) bool
	IsInterfaceNil() bool
}

BlockTracker defines the functionality for node to track the blocks which are received from network

type SortedTransactionsProvider

type SortedTransactionsProvider interface {
	GetSortedTransactions() ([]data.TransactionHandler, [][]byte)
	IsInterfaceNil() bool
}

SortedTransactionsProvider defines the public API of the transactions cache