substreams

package
v1.13.0 Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2026 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewToolsStoreSizeCmd

func NewToolsStoreSizeCmd(logger *zap.Logger) *cobra.Command

func NewToolsSubstreamsCmd

func NewToolsSubstreamsCmd[B firecore.Block](chain *firecore.Chain[B], logger *zap.Logger) *cobra.Command

Types

type StoreSizeQuerier

type StoreSizeQuerier interface {
	// GetStoreSizes returns both total compressed size and latest file's uncompressed size
	GetStoreSizes(ctx context.Context, path string) (*StoreSizes, error)
}

StoreSizeQuerier provides an interface for getting the total size of files in a storage location. This is structured to be easily portable back to dstore.

func NewStoreSizeQuerier

func NewStoreSizeQuerier(storeURL string) (StoreSizeQuerier, error)

NewStoreSizeQuerier creates an appropriate size querier based on the storage URL

type StoreSizes

type StoreSizes struct {
	TotalCompressed  int64  // Total size of all files (compressed)
	LiveUncompressed *int64 // Uncompressed size from latest file metadata (nil if not available)
	LiveCompressed   int64  // Compressed size of latest file only
	LatestFile       string // Name of the latest file
}

StoreSizes contains the compressed (total) and uncompressed (live) sizes

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL