cometbft_v37

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	BlocksyncChannel = byte(0x40)
)

Variables

This section is empty.

Functions

func CometLogger 

func CometLogger() (logger log.Logger)

func CreateAndStartEventBus 

func CreateAndStartEventBus() (*cometTypes.EventBus, error)

func CreateAndStartProxyAppConns 

func CreateAndStartProxyAppConns(config *Config) (proxy.AppConns, error)

func CreateEvidenceReactor 

func CreateEvidenceReactor(config *Config, stateStore sm.Store, blockStore *store.BlockStore) (*evidence.Reactor, *evidence.Pool, error)

func CreateMempool 

func CreateMempool(config *Config, proxyApp proxy.AppConns, state sm.State) mempl.Mempool

func CreateSwitch 

func CreateSwitch(config *Config,
	transport p2p.Transport,
	bcReactor p2p.Reactor,
	nodeInfo p2p.NodeInfo,
	nodeKey *p2p.NodeKey,
	logger cometLog.Logger) *p2p.Switch

func DefaultDBProvider 

func DefaultDBProvider(ctx *DBContext) (dbm.DB, error)

func DoHandshake 

func DoHandshake(
	stateStore sm.Store,
	state sm.State,
	blockStore sm.BlockStore,
	genDoc *GenesisDoc,
	eventBus cometTypes.BlockEventPublisher,
	proxyApp proxy.AppConns,
) error

func GetBlockstoreDBs 

func GetBlockstoreDBs(config *Config) (dbm.DB, *store.BlockStore, error)

func GetStateDBs 

func GetStateDBs(config *Config) (dbm.DB, state.Store, error)

func LoadConfig 

func LoadConfig(homePath string) (*cfg.Config, error)

func MakeNodeInfo 

func MakeNodeInfo(
	config *Config,
	nodeKey *p2p.NodeKey,
	genDoc *GenesisDoc,
) (p2p.NodeInfo, error)

Types

type Block 

type Block = cometTypes.Block

type BlockchainReactor 

type BlockchainReactor struct {
	p2p.BaseReactor
	// contains filtered or unexported fields
}

func NewBlockchainReactor 

func NewBlockchainReactor(block *Block, nextBlock *Block) *BlockchainReactor

func (*BlockchainReactor) GetChannels 

func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor

func (*BlockchainReactor) ReceiveEnvelope 

func (bcR *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope)

type Config 

type Config = cometCfg.Config

type DBContext 

type DBContext struct {
	ID     string
	Config *Config
}

type Engine 

type Engine struct {
	// contains filtered or unexported fields
}

func (*Engine) ApplyBlock 

func (engine *Engine) ApplyBlock(runtime string, value []byte) error

func (*Engine) ApplyFirstBlockOverP2P 

func (engine *Engine) ApplyFirstBlockOverP2P(runtime string, value, nextValue []byte) error

func (*Engine) ApplySnapshotChunk 

func (engine *Engine) ApplySnapshotChunk(chunkIndex uint32, value []byte) (string, error)

func (*Engine) BootstrapState 

func (engine *Engine) BootstrapState(value []byte) error

func (*Engine) CloseDBs 

func (engine *Engine) CloseDBs() error

func (*Engine) DoHandshake 

func (engine *Engine) DoHandshake() error

func (*Engine) GetAppHeight 

func (engine *Engine) GetAppHeight() (int64, error)

func (*Engine) GetBaseHeight 

func (engine *Engine) GetBaseHeight() int64

func (*Engine) GetBlock 

func (engine *Engine) GetBlock(height int64) ([]byte, error)

func (*Engine) GetChainId 

func (engine *Engine) GetChainId() (string, error)

func (*Engine) GetContinuationHeight 

func (engine *Engine) GetContinuationHeight() (int64, error)

func (*Engine) GetGenesisHeight 

func (engine *Engine) GetGenesisHeight() (int64, error)

func (*Engine) GetGenesisPath 

func (engine *Engine) GetGenesisPath() string

func (*Engine) GetHeight 

func (engine *Engine) GetHeight() int64

func (*Engine) GetHomePath 

func (engine *Engine) GetHomePath() string

func (*Engine) GetMetrics 

func (engine *Engine) GetMetrics() ([]byte, error)

func (*Engine) GetName 

func (engine *Engine) GetName() string

func (*Engine) GetProxyAppAddress 

func (engine *Engine) GetProxyAppAddress() string

func (*Engine) GetSeenCommit 

func (engine *Engine) GetSeenCommit(height int64) ([]byte, error)

func (*Engine) GetSnapshotChunk 

func (engine *Engine) GetSnapshotChunk(height, format, chunk int64) ([]byte, error)

func (*Engine) GetSnapshots 

func (engine *Engine) GetSnapshots() ([]byte, error)

func (*Engine) GetState 

func (engine *Engine) GetState(height int64) ([]byte, error)

func (*Engine) IsSnapshotAvailable 

func (engine *Engine) IsSnapshotAvailable(height int64) (bool, error)

func (*Engine) OfferSnapshot 

func (engine *Engine) OfferSnapshot(value []byte) (string, uint32, error)

func (*Engine) OpenDBs 

func (engine *Engine) OpenDBs(homePath string) error

func (*Engine) PruneBlocks 

func (engine *Engine) PruneBlocks(toHeight int64) error

func (*Engine) ResetAll 

func (engine *Engine) ResetAll(homePath string, keepAddrBook bool) error

func (*Engine) StartProxyApp 

func (engine *Engine) StartProxyApp() error

func (*Engine) StopProxyApp 

func (engine *Engine) StopProxyApp() error

type GenesisDoc 

type GenesisDoc = cometTypes.GenesisDoc

type KsyncCometLogger 

type KsyncCometLogger struct {
	// contains filtered or unexported fields
}

func (KsyncCometLogger) Debug 

func (l KsyncCometLogger) Debug(msg string, keyvals ...interface{})

func (KsyncCometLogger) Error 

func (l KsyncCometLogger) Error(msg string, keyvals ...interface{})

func (KsyncCometLogger) Info 

func (l KsyncCometLogger) Info(msg string, keyvals ...interface{})

func (KsyncCometLogger) With 

func (l KsyncCometLogger) With(keyvals ...interface{}) (logger log.Logger)

type LightBlock 

type LightBlock = cometTypes.LightBlock

type Snapshot 

type Snapshot = abciTypes.Snapshot

type TendermintBsyncBundle 

type TendermintBsyncBundle = []TendermintBsyncDataItem

type TendermintBsyncDataItem 

type TendermintBsyncDataItem struct {
	Key   string `json:"key"`
	Value *Block `json:"value"`
}

type TendermintBundle 

type TendermintBundle = []TendermintDataItem

type TendermintDataItem 

type TendermintDataItem struct {
	Key   string          `json:"key"`
	Value TendermintValue `json:"value"`
}

type TendermintSsyncBundle 

type TendermintSsyncBundle = []TendermintSsyncDataItem

type TendermintSsyncDataItem 

type TendermintSsyncDataItem struct {
	Key   string `json:"key"`
	Value struct {
		Snapshot   *abciTypes.Snapshot `json:"snapshot"`
		Block      *Block              `json:"block"`
		SeenCommit *cometTypes.Commit  `json:"seenCommit"`
		State      *cometState.State   `json:"state"`
		ChunkIndex uint32              `json:"chunkIndex"`
		Chunk      []byte              `json:"chunk"`
	} `json:"value"`
}

type TendermintValue 

type TendermintValue struct {
	Block struct {
		Block *Block `json:"block"`
	} `json:"block"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.