Versions in this module Expand all Collapse all v1 v1.0.1 Sep 18, 2024 v1.0.0 May 17, 2024 Changes in this version + const ChunkChannel + const LightBlockChannel + const MetricsSubsystem + const ParamsChannel + const SnapshotChannel + func GetChunkChannelDescriptor() *p2p.ChannelDescriptor + func GetLightBlockChannelDescriptor() *p2p.ChannelDescriptor + func GetParamsChannelDescriptor() *p2p.ChannelDescriptor + func GetSnapshotChannelDescriptor() *p2p.ChannelDescriptor + type Metricer interface + BackFillBlocksTotal func() int64 + BackFilledBlocks func() int64 + ChunkProcessAvgTime func() time.Duration + SnapshotChunksCount func() int64 + SnapshotChunksTotal func() int64 + SnapshotHeight func() int64 + TotalSnapshots func() int64 + type Metrics struct + BackFillBlocksTotal metrics.Gauge + BackFilledBlocks metrics.Counter + ChunkProcessAvgTime metrics.Gauge + SnapshotChunk metrics.Counter + SnapshotChunkTotal metrics.Gauge + SnapshotHeight metrics.Gauge + TotalSnapshots metrics.Counter + func NopMetrics() *Metrics + func PrometheusMetrics(namespace string, labelsAndValues ...string) *Metrics + type Reactor struct + func NewReactor(chainID string, initialHeight int64, cfg config.StateSyncConfig, ...) *Reactor + func (r *Reactor) BackFillBlocksTotal() int64 + func (r *Reactor) BackFilledBlocks() int64 + func (r *Reactor) Backfill(ctx context.Context, state sm.State) error + func (r *Reactor) ChunkProcessAvgTime() time.Duration + func (r *Reactor) OnStart(ctx context.Context) error + func (r *Reactor) OnStop() + func (r *Reactor) SetChunkChannel(ch *p2p.Channel) + func (r *Reactor) SetLightBlockChannel(ch *p2p.Channel) + func (r *Reactor) SetParamsChannel(ch *p2p.Channel) + func (r *Reactor) SetSnapshotChannel(ch *p2p.Channel) + func (r *Reactor) SnapshotChunksCount() int64 + func (r *Reactor) SnapshotChunksTotal() int64 + func (r *Reactor) SnapshotHeight() int64 + func (r *Reactor) Sync(ctx context.Context) (sm.State, error) + func (r *Reactor) TotalSnapshots() int64
Go to main page