firehose_reader

package

v1.13.0 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/firehose-core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type App
- func New(config Config, testModeComparator *mindreader.TestModeComparator, ...) *App
- func (a *App) IsReady() bool
- func (a *App) Run() error
type Config
type FirehoseConfig

Constants ¶

View Source

const HeadDriftServiceName = "reader_node_firehose"

Variables ¶

View Source

var AppReadiness = metrics.NewAppReadiness(HeadDriftServiceName)

View Source

var BlockWriteCount = metrics.NewCounter("block_write_count", "The number of blocks written by the Firehose reader to one-block store")

View Source

var HeadBlockNumber = metrics.NewHeadBlockNumber(HeadDriftServiceName)

View Source

var HeadBlockRelativeTime = metrics.NewHeadBlockRelativeTime(HeadDriftServiceName)

View Source

var HeadBlockTimeDrift = metrics.NewHeadTimeDrift(HeadDriftServiceName)

Functions ¶

This section is empty.

Types ¶

type App ¶

type App struct {
	*shutter.Shutter
	// contains filtered or unexported fields
}

func New ¶

func New(config Config, testModeComparator *mindreader.TestModeComparator, zlogger *zap.Logger, tracer logging.Tracer) *App

func (*App) IsReady ¶

func (a *App) IsReady() bool

func (*App) Run ¶

func (a *App) Run() error

type Config ¶

type Config struct {
	GRPCAddr            string
	OneBlocksStoreURL   string
	OneBlockSuffix      string
	StartBlockNum       uint64
	StopBlockNum        uint64
	ReadinessMaxLatency time.Duration
	StateFile           string
	FirehoseConfig      FirehoseConfig
}

type FirehoseConfig ¶

type FirehoseConfig struct {
	ApiKey        string
	ApiToken      string
	Endpoint      string
	Compression   string
	PlaintextConn bool
	InsecureConn  bool
}

Source Files ¶

View all Source files

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