Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cometdump

package module

Go to main page

Versions in this module

v0

v0.2.2

Sep 25, 2025

Changes in this version

+ type Chunk struct

+ FromHeight int64

+ ToHeight int64

type Store

+ func (s *Store) Chunks() []Chunk

v0.2.1

Sep 25, 2025

Changes in this version

+ type BlockRecord struct

+ Block *cmtypes.Block

+ BlockID cmtypes.BlockID

+ BlockResultsAppHash []byte

+ ConsensusParamUpdates *cmtproto.ConsensusParams

+ FinalizeBlockEvents []abcitypes.Event

+ TxResults []*abcitypes.ExecTxResult

+ ValidatorUpdates []abcitypes.ValidatorUpdate

+ func BlockRecordFromRPCResults(block *coretypes.ResultBlock, blockResults *coretypes.ResultBlockResults) *BlockRecord

+ func (b *BlockRecord) DecodeMsgpack(dec *msgpack.Decoder) error

+ func (b *BlockRecord) EncodeMsgpack(enc *msgpack.Encoder) error

+ func (b *BlockRecord) ToResultBlock() *coretypes.ResultBlock

+ func (b *BlockRecord) ToResultBlockResults() *coretypes.ResultBlockResults

+ type NoNodesAvailableForRangeError struct

+ func (e *NoNodesAvailableForRangeError) Error() string

+ func (e *NoNodesAvailableForRangeError) Range() (int64, int64)

+ type OpenOptions struct

+ Logger *slog.Logger

+ Path string

+ func DefaultOpenOptions(path string) OpenOptions

+ func (o OpenOptions) WithLogger(logger *slog.Logger) OpenOptions

+ type RPCServer struct

+ func NewRPCServer(store *Store) *RPCServer

+ func (server *RPCServer) Block(_ *rpctypes.Context, heightPtr *int64) (*coretypes.ResultBlock, error)

+ func (server *RPCServer) BlockResults(_ *rpctypes.Context, heightPtr *int64) (*coretypes.ResultBlockResults, error)

+ func (server *RPCServer) BlockchainInfo(_ *rpctypes.Context, minHeight, maxHeight int64) (*coretypes.ResultBlockchainInfo, error)

+ func (server *RPCServer) GetRoutes() rpccore.RoutesMap

+ func (server *RPCServer) Header(_ *rpctypes.Context, heightPtr *int64) (*coretypes.ResultHeader, error)

+ type Store struct

+ func Open(opts OpenOptions) (*Store, error)

+ func (s *Store) BlockAt(height int64) (*BlockRecord, error)

+ func (s *Store) Blocks(args ...int64) iter.Seq2[*BlockRecord, error]

+ func (s *Store) Normalize(chunkSize int64) error

+ func (s *Store) Sync(ctx context.Context, opts SyncOptions) error

+ func (s *Store) VerifyIntegrity(checksumFile string) error

+ type SyncOptions struct

+ BaseHeight int64

+ ChunkSize int

+ ExpandRemotes bool

+ FetchSize int

+ Logger *slog.Logger

+ NumWorkers int

+ OutputChan chan<- *BlockRecord

+ ProgressBar *mpb.Progress

+ Remotes []string

+ TargetHeight int64

+ UseLatestVersion bool

+ VersionConstraint *semver.Constraints

+ func DefaultSyncOptions(remotes ...string) SyncOptions

+ func (opts SyncOptions) WithBaseHeight(height int64) SyncOptions

+ func (opts SyncOptions) WithChunkSize(size int) SyncOptions

+ func (opts SyncOptions) WithExpandRemotes(expand bool) SyncOptions

+ func (opts SyncOptions) WithFetchSize(size int) SyncOptions

+ func (opts SyncOptions) WithLogger(logger *slog.Logger) SyncOptions

+ func (opts SyncOptions) WithNumWorkers(num int) SyncOptions

+ func (opts SyncOptions) WithOutputChan(outputChan chan<- *BlockRecord) SyncOptions

+ func (opts SyncOptions) WithProgressBar(pBar *mpb.Progress) SyncOptions

+ func (opts SyncOptions) WithTargetHeight(height int64) SyncOptions

+ func (opts SyncOptions) WithUseLatestVersion(useLatest bool) SyncOptions

+ func (opts SyncOptions) WithVersionConstraint(constraint string) SyncOptions

v0.2.0-alpha

Jul 13, 2025

v0.1.0-alpha

Jul 12, 2025