Versions in this module Expand all Collapse all v0 v0.1.0 Feb 9, 2024 Changes in this version + const BlocksyncChannel + func CometLogger() (logger log.Logger) + func CreateAndStartEventBus() (*cometTypes.EventBus, error) + func CreateAndStartProxyAppConns(config *Config) (proxy.AppConns, error) + func CreateEvidenceReactor(config *Config, stateStore sm.Store, blockStore *store.BlockStore) (*evidence.Reactor, *evidence.Pool, error) + func CreateMempool(config *Config, proxyApp proxy.AppConns, state sm.State) mempl.Mempool + func CreateSwitch(config *Config, transport p2p.Transport, bcReactor p2p.Reactor, ...) *p2p.Switch + func DefaultDBProvider(ctx *DBContext) (dbm.DB, error) + func DoHandshake(stateStore sm.Store, state sm.State, blockStore sm.BlockStore, ...) error + func GetBlockstoreDBs(config *Config) (dbm.DB, *store.BlockStore, error) + func GetStateDBs(config *Config) (dbm.DB, state.Store, error) + func KsyncLogger(moduleName string) zerolog.Logger + func LoadConfig(homePath string) (*cfg.Config, error) + func LogFormatter(keyvals ...interface{}) zerolog.Logger + func MakeNodeInfo(config *Config, nodeKey *p2p.NodeKey, genDoc *GenesisDoc) (p2p.NodeInfo, error) + type Block = cometTypes.Block + type BlockchainReactor struct + func NewBlockchainReactor(block *Block, nextBlock *Block) *BlockchainReactor + func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor + func (bcR *BlockchainReactor) ReceiveEnvelope(e p2p.Envelope) + type CometEngine struct + func (comet *CometEngine) ApplyBlock(runtime string, value []byte) error + func (comet *CometEngine) ApplyFirstBlockOverP2P(runtime string, value, nextValue []byte) error + func (comet *CometEngine) ApplySnapshotChunk(chunkIndex uint32, value []byte) (string, error) + func (comet *CometEngine) BootstrapState(value []byte) error + func (comet *CometEngine) CloseDBs() error + func (comet *CometEngine) DoHandshake() error + func (comet *CometEngine) GetAppHeight() (int64, error) + func (comet *CometEngine) GetBaseHeight() int64 + func (comet *CometEngine) GetBlock(height int64) ([]byte, error) + func (comet *CometEngine) GetChainId() (string, error) + func (comet *CometEngine) GetContinuationHeight() (int64, error) + func (comet *CometEngine) GetGenesisHeight() (int64, error) + func (comet *CometEngine) GetGenesisPath() string + func (comet *CometEngine) GetHeight() int64 + func (comet *CometEngine) GetHomePath() string + func (comet *CometEngine) GetMetrics() ([]byte, error) + func (comet *CometEngine) GetName() string + func (comet *CometEngine) GetProxyAppAddress() string + func (comet *CometEngine) GetSeenCommit(height int64) ([]byte, error) + func (comet *CometEngine) GetSnapshotChunk(height, format, chunk int64) ([]byte, error) + func (comet *CometEngine) GetSnapshots() ([]byte, error) + func (comet *CometEngine) GetState(height int64) ([]byte, error) + func (comet *CometEngine) IsSnapshotAvailable(height int64) (bool, error) + func (comet *CometEngine) OfferSnapshot(value []byte) (string, uint32, error) + func (comet *CometEngine) OpenDBs(homePath string) error + func (comet *CometEngine) PruneBlocks(toHeight int64) error + func (comet *CometEngine) ResetAll(homePath string, keepAddrBook bool) error + func (comet *CometEngine) StartProxyApp() error + func (comet *CometEngine) StopProxyApp() error + type Config = cometCfg.Config + type DBContext struct + Config *Config + ID string + type GenesisDoc = cometTypes.GenesisDoc + type KsyncCometLogger struct + func (l KsyncCometLogger) Debug(msg string, keyvals ...interface{}) + func (l KsyncCometLogger) Error(msg string, keyvals ...interface{}) + func (l KsyncCometLogger) Info(msg string, keyvals ...interface{}) + func (l KsyncCometLogger) With(keyvals ...interface{}) (logger log.Logger) + type LightBlock = cometTypes.LightBlock + type Metrics struct + CatchingUp bool + EarliestAppHash string + EarliestBlockHash string + EarliestBlockHeight int64 + EarliestBlockTime time.Time + LatestAppHash string + LatestBlockHash string + LatestBlockHeight int64 + LatestBlockTime time.Time + type Snapshot = abciTypes.Snapshot + type TendermintBsyncBundle = []TendermintBsyncDataItem + type TendermintBsyncDataItem struct + Key string + Value *Block + type TendermintBundle = []TendermintDataItem + type TendermintDataItem struct + Key string + Value TendermintValue + type TendermintSsyncBundle = []TendermintSsyncDataItem + type TendermintSsyncDataItem struct + Key string + Value struct{ ... } + type TendermintValue struct + Block struct{ ... } Other modules containing this package github.com/KYVENetwork/ksync