celestiacore

package module
v2.0.3 Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2024 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func CreateAndStartEventBus 

func CreateAndStartEventBus() (*tmTypes.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 CreateMempoolAndMempoolReactor 

func CreateMempoolAndMempoolReactor(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 tmLog.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 tmTypes.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 KsyncLogger 

func KsyncLogger(moduleName string) zerolog.Logger

func LoadConfig 

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

func LogFormatter 

func LogFormatter(keyvals ...interface{}) zerolog.Logger

func MakeNodeInfo 

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

func TmLogger 

func TmLogger() (logger log.Logger)

Types

type Block 

type Block = tmTypes.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) Receive 

func (bcR *BlockchainReactor) Receive(chID byte, src p2p.Peer, msgBytes []byte)

type CelestiaCoreEngine 

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

func (*CelestiaCoreEngine) ApplyBlock 

func (cc *CelestiaCoreEngine) ApplyBlock(runtime string, value []byte) error

func (*CelestiaCoreEngine) ApplyFirstBlockOverP2P 

func (cc *CelestiaCoreEngine) ApplyFirstBlockOverP2P(runtime string, value, nextValue []byte) error

func (*CelestiaCoreEngine) ApplySnapshotChunk 

func (cc *CelestiaCoreEngine) ApplySnapshotChunk(chunkIndex uint32, value []byte) (string, error)

func (*CelestiaCoreEngine) BootstrapState 

func (cc *CelestiaCoreEngine) BootstrapState(value []byte) error

func (*CelestiaCoreEngine) CloseDBs 

func (cc *CelestiaCoreEngine) CloseDBs() error

func (*CelestiaCoreEngine) DoHandshake 

func (cc *CelestiaCoreEngine) DoHandshake() error

func (*CelestiaCoreEngine) GetAppHeight 

func (cc *CelestiaCoreEngine) GetAppHeight() (int64, error)

func (*CelestiaCoreEngine) GetBaseHeight 

func (cc *CelestiaCoreEngine) GetBaseHeight() int64

func (*CelestiaCoreEngine) GetBlock 

func (cc *CelestiaCoreEngine) GetBlock(height int64) ([]byte, error)

func (*CelestiaCoreEngine) GetChainId 

func (cc *CelestiaCoreEngine) GetChainId() (string, error)

func (*CelestiaCoreEngine) GetContinuationHeight 

func (cc *CelestiaCoreEngine) GetContinuationHeight() (int64, error)

func (*CelestiaCoreEngine) GetGenesisHeight 

func (cc *CelestiaCoreEngine) GetGenesisHeight() (int64, error)

func (*CelestiaCoreEngine) GetGenesisPath 

func (cc *CelestiaCoreEngine) GetGenesisPath() string

func (*CelestiaCoreEngine) GetHeight 

func (cc *CelestiaCoreEngine) GetHeight() int64

func (*CelestiaCoreEngine) GetHomePath 

func (cc *CelestiaCoreEngine) GetHomePath() string

func (*CelestiaCoreEngine) GetMetrics 

func (cc *CelestiaCoreEngine) GetMetrics() ([]byte, error)

func (*CelestiaCoreEngine) GetName 

func (cc *CelestiaCoreEngine) GetName() string

func (*CelestiaCoreEngine) GetProxyAppAddress 

func (cc *CelestiaCoreEngine) GetProxyAppAddress() string

func (*CelestiaCoreEngine) GetSeenCommit 

func (cc *CelestiaCoreEngine) GetSeenCommit(height int64) ([]byte, error)

func (*CelestiaCoreEngine) GetSnapshotChunk 

func (cc *CelestiaCoreEngine) GetSnapshotChunk(height, format, chunk int64) ([]byte, error)

func (*CelestiaCoreEngine) GetSnapshots 

func (cc *CelestiaCoreEngine) GetSnapshots() ([]byte, error)

func (*CelestiaCoreEngine) GetState 

func (cc *CelestiaCoreEngine) GetState(height int64) ([]byte, error)

func (*CelestiaCoreEngine) IsSnapshotAvailable 

func (cc *CelestiaCoreEngine) IsSnapshotAvailable(height int64) (bool, error)

func (*CelestiaCoreEngine) OfferSnapshot 

func (cc *CelestiaCoreEngine) OfferSnapshot(value []byte) (string, uint32, error)

func (*CelestiaCoreEngine) OpenDBs 

func (cc *CelestiaCoreEngine) OpenDBs(homePath string) error

func (*CelestiaCoreEngine) PruneBlocks 

func (cc *CelestiaCoreEngine) PruneBlocks(toHeight int64) error

func (*CelestiaCoreEngine) ResetAll 

func (cc *CelestiaCoreEngine) ResetAll(homePath string, keepAddrBook bool) error

func (*CelestiaCoreEngine) StartProxyApp 

func (cc *CelestiaCoreEngine) StartProxyApp() error

func (*CelestiaCoreEngine) StopProxyApp 

func (cc *CelestiaCoreEngine) StopProxyApp() error

type Config 

type Config = tmCfg.Config

type DBContext 

type DBContext struct {
	ID     string
	Config *Config
}

type GenesisDoc 

type GenesisDoc = tmTypes.GenesisDoc

type KsyncTmLogger 

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

func (KsyncTmLogger) Debug 

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

func (KsyncTmLogger) Error 

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

func (KsyncTmLogger) Info 

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

func (KsyncTmLogger) With 

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

type LightBlock 

type LightBlock = tmTypes.LightBlock

type Metrics 

type Metrics struct {
	LatestBlockHash     string    `json:"latest_block_hash"`
	LatestAppHash       string    `json:"latest_app_hash"`
	LatestBlockHeight   int64     `json:"latest_block_height"`
	LatestBlockTime     time.Time `json:"latest_block_time"`
	EarliestBlockHash   string    `json:"earliest_block_hash"`
	EarliestAppHash     string    `json:"earliest_app_hash"`
	EarliestBlockHeight int64     `json:"earliest_block_height"`
	EarliestBlockTime   time.Time `json:"earliest_block_time"`
	CatchingUp          bool      `json:"catching_up"`
}

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 *tmTypes.Commit     `json:"seenCommit"`
		State      *tmState.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.