worker

Dec 2, 2025

Changes in this version

type Config

+ Env string

+ InfluxWriter InfluxWriter

+ SlackWebhookURL string

+ SolanaRPCClient LedgerRPCClient

+ TwoZOracleClient twozoracle.TwoZOracleClient

+ TwoZOracleInterval time.Duration

+ type InfluxWriter interface

+ Errors func() <-chan error

+ Flush func()

+ WriteRecord func(string)

Sep 2, 2025

Changes in this version

type Config

+ InternetLatencyCollectorPK solana.PublicKey

type TelemetryProgramClient

+ GetInternetLatencySamples func(ctx context.Context, dataProviderName string, ...) (*telemetry.InternetLatencySamples, error)

Aug 28, 2025

Changes in this version

+ const MetricLabelCommit

+ const MetricLabelDate

+ const MetricLabelErrorType

+ const MetricLabelVersion

+ const MetricNameBuildInfo

+ const MetricNameErrors

+ var MetricBuildInfo = promauto.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ var MetricErrors = promauto.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ type Config struct

+ Interval time.Duration

+ LedgerRPCClient LedgerRPCClient

+ Logger *slog.Logger

+ Serviceability ServiceabilityClient

+ Telemetry TelemetryProgramClient

+ func (c *Config) Validate() error

+ type LedgerRPCClient interface

+ GetEpochInfo func(ctx context.Context, commitment solanarpc.CommitmentType) (*solanarpc.GetEpochInfoResult, error)

+ type ServiceabilityClient interface

+ GetProgramData func(context.Context) (*serviceability.ProgramData, error)

+ type TelemetryProgramClient interface

+ GetDeviceLatencySamples func(ctx context.Context, ...) (*telemetry.DeviceLatencySamples, error)

+ type Watcher interface

+ Name func() string

+ Run func(ctx context.Context) error

+ type Worker struct

+ func New(cfg *Config) (*Worker, error)

+ func (w *Worker) Run(ctx context.Context) error