Versions in this module Expand all Collapse all v1 v1.0.0 Jan 6, 2023 Changes in this version + const DeliverTxsExecModeParallel + const DeliverTxsExecModeSerial + const FEEDBACK_LEN + const FlagApplyBlockPprofTime + const FlagDeliverTxsExecMode + const FlagEnableConcurrency + const MAXCHAN_LEN + const MAX_WAIT_TIME_SECONDS + const MetricsSubsystem + const QUIT_SIG + var ApplyBlockPprofTime = -1 + var EmptyGenerateWatchDataF = func() ([]byte, error) + var HomeDir = "" + var IgnoreSmbCheck bool = false + var ModuleCodec *amino.Codec + func ExecCommitBlock(appConnConsensus proxy.AppConnConsensus, block *types.Block, logger log.Logger, ...) ([]byte, error) + func LoadConsensusParams(db dbm.DB, height int64) (types.ConsensusParams, error) + func LoadValidators(db dbm.DB, height int64) (*types.ValidatorSet, error) + func MakeGenesisDocFromFile(genDocFile string) (*types.GenesisDoc, error) + func MedianTime(commit *types.Commit, validators *types.ValidatorSet) time.Time + func PprofEnd(height int, f *os.File, startTime time.Time) + func PprofStart() (*os.File, time.Time) + func PruneStates(db dbm.DB, from int64, to int64) error + func SaveABCIResponses(db dbm.DB, height int64, abciResponses *ABCIResponses) + func SaveState(db dbm.DB, state State) + func SetEvmWatchDataManager(manager WatchDataManager) + func SetIgnoreSmbCheck(check bool) + func SetWasmWatchDataManager(manager WatchDataManager) + func TxPostCheck(state State) mempl.PostCheckFunc + func TxPreCheck(state State) mempl.PreCheckFunc + func VerifyEvidence(stateDB dbm.DB, state State, evidence types.Evidence) error + type ABCIResponses struct + BeginBlock *abci.ResponseBeginBlock + DeliverTxs []*abci.ResponseDeliverTx + EndBlock *abci.ResponseEndBlock + func LoadABCIResponses(db dbm.DB, height int64) (*ABCIResponses, error) + func NewABCIResponses(block *types.Block) *ABCIResponses + func (arz *ABCIResponses) Bytes() []byte + func (arz *ABCIResponses) ResultsHash() []byte + func (arz *ABCIResponses) UnmarshalFromAmino(cdc *amino.Codec, data []byte) error + func (arz ABCIResponses) AminoSize(cdc *amino.Codec) int + func (arz ABCIResponses) MarshalAminoTo(cdc *amino.Codec, buf *bytes.Buffer) error + func (arz ABCIResponses) MarshalToAmino(cdc *amino.Codec) ([]byte, error) + type BlockExecutor struct + func NewBlockExecutor(db dbm.DB, logger log.Logger, proxyApp proxy.AppConnConsensus, ...) *BlockExecutor + func (blockExec *BlockExecutor) ApplyBlock(state State, blockID types.BlockID, block *types.Block) (State, int64, error) + func (blockExec *BlockExecutor) ApplyBlockWithTrace(state State, blockID types.BlockID, block *types.Block) (State, int64, error) + func (blockExec *BlockExecutor) CreateProposalBlock(height int64, state State, commit *types.Commit, proposerAddr []byte) (*types.Block, *types.PartSet) + func (blockExec *BlockExecutor) DB() dbm.DB + func (blockExec *BlockExecutor) FireBlockTimeEvents(height, blockTime int64, address types.Address) + func (blockExec *BlockExecutor) InitPrerun() + func (blockExec *BlockExecutor) NotifyPrerun(block *types.Block) + func (blockExec *BlockExecutor) SaveABCIResponsesAsync(height int64, responses *ABCIResponses) + func (blockExec *BlockExecutor) SaveStateAsync(state State) + func (blockExec *BlockExecutor) SetEventBus(eventBus types.BlockEventPublisher) + func (blockExec *BlockExecutor) SetIsAsyncSaveDB(isAsyncSaveDB bool) + func (blockExec *BlockExecutor) SetIsFastSyncing(isSyncing bool) + func (blockExec *BlockExecutor) SetIsNullIndexer(isNullIndexer bool) + func (blockExec *BlockExecutor) Stop() + func (blockExec *BlockExecutor) ValidateBlock(state State, block *types.Block) error + type BlockExecutorOption func(executor *BlockExecutor) + func BlockExecutorWithMetrics(metrics *Metrics) BlockExecutorOption + type BlockStore interface + Base func() int64 + DeleteBlocksFromTop func(height int64) (uint64, error) + Height func() int64 + LoadBlock func(height int64) *types.Block + LoadBlockByHash func(hash []byte) *types.Block + LoadBlockCommit func(height int64) *types.Commit + LoadBlockMeta func(height int64) *types.BlockMeta + LoadBlockPart func(height int64, index int) *types.Part + LoadSeenCommit func(height int64) *types.Commit + PruneBlocks func(height int64) (uint64, error) + SaveBlock func(block *types.Block, blockParts *types.PartSet, seenCommit *types.Commit) + Size func() int64 + type ConsensusParamsInfo struct + ConsensusParams types.ConsensusParams + LastHeightChanged int64 + func (params ConsensusParamsInfo) Bytes() []byte + type DeliverTxsExecMode int + type DeltaContext struct + type DeltaInfo struct + type EmptyWatchDataManager struct + func (e EmptyWatchDataManager) ApplyWatchData(interface{}) + func (e EmptyWatchDataManager) CreateWatchDataGenerator() func() ([]byte, error) + func (e EmptyWatchDataManager) UnmarshalWatchData([]byte) (interface{}, error) + type ErrAppBlockHeightTooHigh struct + AppHeight int64 + CoreHeight int64 + func (e ErrAppBlockHeightTooHigh) Error() string + type ErrAppBlockHeightTooLow struct + AppHeight int64 + StoreBase int64 + func (e ErrAppBlockHeightTooLow) Error() string + type ErrBlockHashMismatch struct + AppHash []byte + CoreHash []byte + Height int64 + func (e ErrBlockHashMismatch) Error() string + type ErrInvalidBlock error + type ErrLastStateMismatch struct + App []byte + Core []byte + Height int64 + func (e ErrLastStateMismatch) Error() string + type ErrNoABCIResponsesForHeight struct + Height int64 + func (e ErrNoABCIResponsesForHeight) Error() string + type ErrNoConsensusParamsForHeight struct + Height int64 + func (e ErrNoConsensusParamsForHeight) Error() string + type ErrNoValSetForHeight struct + Height int64 + func (e ErrNoValSetForHeight) Error() string + type ErrProxyAppConn error + type ErrStateMismatch struct + Expected *State + Got *State + func (e ErrStateMismatch) Error() string + type ErrUnknownBlock struct + Height int64 + func (e ErrUnknownBlock) Error() string + type EvidencePool interface + AddEvidence func(types.Evidence) error + IsCommitted func(types.Evidence) bool + PendingEvidence func(int64) []types.Evidence + Update func(*types.Block, State) + type Metrics struct + AbciTime metrics.Gauge + BlockProcessingTime metrics.Histogram + CommitTime metrics.Gauge + IntervalTime metrics.Gauge + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics + type MockEvidencePool struct + func (m MockEvidencePool) AddEvidence(types.Evidence) error + func (m MockEvidencePool) IsCommitted(types.Evidence) bool + func (m MockEvidencePool) PendingEvidence(int64) []types.Evidence + func (m MockEvidencePool) Update(*types.Block, State) + type State struct + AppHash []byte + ChainID string + ConsensusParams types.ConsensusParams + LastBlockHeight int64 + LastBlockID types.BlockID + LastBlockTime time.Time + LastHeightConsensusParamsChanged int64 + LastHeightValidatorsChanged int64 + LastResultsHash []byte + LastValidators *types.ValidatorSet + NextValidators *types.ValidatorSet + Validators *types.ValidatorSet + Version Version + func LoadState(db dbm.DB) State + func LoadStateFromDBOrGenesisDoc(stateDB dbm.DB, genesisDoc *types.GenesisDoc) (State, error) + func LoadStateFromDBOrGenesisFile(stateDB dbm.DB, genesisFilePath string) (State, error) + func MakeGenesisState(genDoc *types.GenesisDoc) (State, error) + func MakeGenesisStateFromFile(genDocFile string) (State, error) + func (state *State) String() string + func (state State) Bytes() []byte + func (state State) Copy() State + func (state State) Equals(state2 State) bool + func (state State) IsEmpty() bool + func (state State) MakeBlock(height int64, txs []types.Tx, commit *types.Commit, evidence []types.Evidence, ...) (*types.Block, *types.PartSet) + type ValidatorsInfo struct + LastHeightChanged int64 + ValidatorSet *types.ValidatorSet + func (valInfo *ValidatorsInfo) Bytes() []byte + type Version struct + Consensus version.Consensus + Software string + func GetStateVersion(h int64) Version + func (v Version) IsUpgraded() bool + func (v Version) UpgradeToIBCVersion() Version + type WatchDataManager interface + ApplyWatchData func(interface{}) + CreateWatchDataGenerator func() func() ([]byte, error) + UnmarshalWatchData func([]byte) (interface{}, error)
Go to main page