firehose_reader

package
v1.9.11 Latest Latest
Warning

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

 Go to latest Published: Jun 13, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

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 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, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.