Versions in this module Expand all Collapse all v2 v2.0.3 Feb 13, 2024 v2.0.2 Feb 13, 2024 Changes in this version + const BlockchainChannel + func CreateAndStartEventBus() (*tmTypes.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 CreateMempoolAndMempoolReactor(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) + func TmLogger() (logger log.Logger) + type Block = tmTypes.Block + type BlockchainReactor struct + func NewBlockchainReactor(block *Block, nextBlock *Block) *BlockchainReactor + func (bcR *BlockchainReactor) GetChannels() []*p2p.ChannelDescriptor + func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte) + type CelestiaCoreEngine struct + func (cc *CelestiaCoreEngine) ApplyBlock(runtime string, value []byte) error + func (cc *CelestiaCoreEngine) ApplyFirstBlockOverP2P(runtime string, value, nextValue []byte) error + func (cc *CelestiaCoreEngine) ApplySnapshotChunk(chunkIndex uint32, value []byte) (string, error) + func (cc *CelestiaCoreEngine) BootstrapState(value []byte) error + func (cc *CelestiaCoreEngine) CloseDBs() error + func (cc *CelestiaCoreEngine) DoHandshake() error + func (cc *CelestiaCoreEngine) GetAppHeight() (int64, error) + func (cc *CelestiaCoreEngine) GetBaseHeight() int64 + func (cc *CelestiaCoreEngine) GetBlock(height int64) ([]byte, error) + func (cc *CelestiaCoreEngine) GetChainId() (string, error) + func (cc *CelestiaCoreEngine) GetContinuationHeight() (int64, error) + func (cc *CelestiaCoreEngine) GetGenesisHeight() (int64, error) + func (cc *CelestiaCoreEngine) GetGenesisPath() string + func (cc *CelestiaCoreEngine) GetHeight() int64 + func (cc *CelestiaCoreEngine) GetHomePath() string + func (cc *CelestiaCoreEngine) GetMetrics() ([]byte, error) + func (cc *CelestiaCoreEngine) GetName() string + func (cc *CelestiaCoreEngine) GetProxyAppAddress() string + func (cc *CelestiaCoreEngine) GetSeenCommit(height int64) ([]byte, error) + func (cc *CelestiaCoreEngine) GetSnapshotChunk(height, format, chunk int64) ([]byte, error) + func (cc *CelestiaCoreEngine) GetSnapshots() ([]byte, error) + func (cc *CelestiaCoreEngine) GetState(height int64) ([]byte, error) + func (cc *CelestiaCoreEngine) IsSnapshotAvailable(height int64) (bool, error) + func (cc *CelestiaCoreEngine) OfferSnapshot(value []byte) (string, uint32, error) + func (cc *CelestiaCoreEngine) OpenDBs(homePath string) error + func (cc *CelestiaCoreEngine) PruneBlocks(toHeight int64) error + func (cc *CelestiaCoreEngine) ResetAll(homePath string, keepAddrBook bool) error + func (cc *CelestiaCoreEngine) StartProxyApp() error + func (cc *CelestiaCoreEngine) StopProxyApp() error + type Config = tmCfg.Config + type DBContext struct + Config *Config + ID string + type GenesisDoc = tmTypes.GenesisDoc + type KsyncTmLogger struct + func (l KsyncTmLogger) Debug(msg string, keyvals ...interface{}) + func (l KsyncTmLogger) Error(msg string, keyvals ...interface{}) + func (l KsyncTmLogger) Info(msg string, keyvals ...interface{}) + func (l KsyncTmLogger) With(keyvals ...interface{}) (logger log.Logger) + type LightBlock = tmTypes.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 github.com/KYVENetwork/ksync/engines/celestiacore
Go to main page