worker

type Config struct {
	Logger                     *slog.Logger
	LedgerRPCClient            LedgerRPCClient
	SolanaRPCClient            LedgerRPCClient
	Serviceability             ServiceabilityClient
	Telemetry                  TelemetryProgramClient
	InternetLatencyCollectorPK solana.PublicKey
	Interval                   time.Duration
	SlackWebhookURL            string
	TwoZOracleClient           twozoracle.TwoZOracleClient
	TwoZOracleInterval         time.Duration
	InfluxWriter               InfluxWriter
	Env                        string
}

type InfluxWriter interface {
	Errors() <-chan error
	WriteRecord(string)
	Flush()
}

type LedgerRPCClient interface {
	GetEpochInfo(ctx context.Context, commitment solanarpc.CommitmentType) (*solanarpc.GetEpochInfoResult, error)
}

type ServiceabilityClient interface {
	GetProgramData(context.Context) (*serviceability.ProgramData, error)
}

type TelemetryProgramClient interface {
	GetDeviceLatencySamples(ctx context.Context, originDevicePubKey, targetDevicePubKey, linkPubKey solana.PublicKey, epoch uint64) (*telemetry.DeviceLatencySamples, error)
	GetInternetLatencySamples(ctx context.Context, dataProviderName string, originExchangePubKey, targetExchangePubKey, linkPubKey solana.PublicKey, epoch uint64) (*telemetry.InternetLatencySamples, error)
}

type Watcher interface {
	Name() string
	Run(ctx context.Context) error
}

type Worker struct {
	// contains filtered or unexported fields
}