Documentation
¶
Index ¶
- Constants
- 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
- type BlockchainReactor
- type Config
- type DBContext
- type GenesisDoc
- type KsyncTmLogger
- type LightBlock
- type Metrics
- type Snapshot
- type TendermintBsyncBundle
- type TendermintBsyncDataItem
- type TendermintBundle
- type TendermintDataItem
- type TendermintSsyncBundle
- type TendermintSsyncDataItem
- type TendermintValue
- type TmEngine
- func (tm *TmEngine) ApplyBlock(runtime string, value []byte) error
- func (tm *TmEngine) ApplyFirstBlockOverP2P(runtime string, value, nextValue []byte) error
- func (tm *TmEngine) ApplySnapshotChunk(chunkIndex uint32, value []byte) (string, error)
- func (tm *TmEngine) BootstrapState(value []byte) error
- func (tm *TmEngine) CloseDBs() error
- func (tm *TmEngine) DoHandshake() error
- func (tm *TmEngine) GetAppHeight() (int64, error)
- func (tm *TmEngine) GetBaseHeight() int64
- func (tm *TmEngine) GetBlock(height int64) ([]byte, error)
- func (tm *TmEngine) GetChainId() (string, error)
- func (tm *TmEngine) GetContinuationHeight() (int64, error)
- func (tm *TmEngine) GetGenesisHeight() (int64, error)
- func (tm *TmEngine) GetGenesisPath() string
- func (tm *TmEngine) GetHeight() int64
- func (tm *TmEngine) GetHomePath() string
- func (tm *TmEngine) GetMetrics() ([]byte, error)
- func (tm *TmEngine) GetName() string
- func (tm *TmEngine) GetProxyAppAddress() string
- func (tm *TmEngine) GetSeenCommit(height int64) ([]byte, error)
- func (tm *TmEngine) GetSnapshotChunk(height, format, chunk int64) ([]byte, error)
- func (tm *TmEngine) GetSnapshots() ([]byte, error)
- func (tm *TmEngine) GetState(height int64) ([]byte, error)
- func (tm *TmEngine) IsSnapshotAvailable(height int64) (bool, error)
- func (tm *TmEngine) OfferSnapshot(value []byte) (string, uint32, error)
- func (tm *TmEngine) OpenDBs(homePath string) error
- func (tm *TmEngine) PruneBlocks(toHeight int64) error
- func (tm *TmEngine) ResetAll(homePath string, keepAddrBook bool) error
- func (tm *TmEngine) StartProxyApp() error
- func (tm *TmEngine) StopProxyApp() error
Constants ¶
View Source
const (
BlockchainChannel = byte(0x40)
)
Variables ¶
This section is empty.
Functions ¶
func CreateAndStartEventBus ¶
func CreateEvidenceReactor ¶
func CreateSwitch ¶
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 KsyncLogger ¶
func LogFormatter ¶
func MakeNodeInfo ¶
Types ¶
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
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 TendermintBsyncBundle ¶
type TendermintBsyncBundle = []TendermintBsyncDataItem
type TendermintBsyncDataItem ¶
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"` }
type TmEngine ¶
type TmEngine struct {
// contains filtered or unexported fields
}
func (*TmEngine) ApplyFirstBlockOverP2P ¶
func (*TmEngine) ApplySnapshotChunk ¶
func (*TmEngine) BootstrapState ¶
func (*TmEngine) DoHandshake ¶
func (*TmEngine) GetAppHeight ¶
func (*TmEngine) GetBaseHeight ¶
func (*TmEngine) GetChainId ¶
func (*TmEngine) GetContinuationHeight ¶
func (*TmEngine) GetGenesisHeight ¶
func (*TmEngine) GetGenesisPath ¶
func (*TmEngine) GetHomePath ¶
func (*TmEngine) GetMetrics ¶
func (*TmEngine) GetProxyAppAddress ¶
func (*TmEngine) GetSnapshotChunk ¶
func (*TmEngine) GetSnapshots ¶
func (*TmEngine) IsSnapshotAvailable ¶
func (*TmEngine) OfferSnapshot ¶
func (*TmEngine) PruneBlocks ¶
func (*TmEngine) StartProxyApp ¶
func (*TmEngine) StopProxyApp ¶
Click to show internal directories.
Click to hide internal directories.