data

type Circuit struct {
	Code         string `json:"code"`
	OriginDevice Device `json:"origin_device"`
	TargetDevice Device `json:"target_device"`
	Link         Link   `json:"link"`
}

type CircuitLatenciesWithHeader struct {
	Header  *telemetry.DeviceLatencySamplesHeader
	Samples []datastats.CircuitLatencySample
}

type CircuitSummary struct {
	Circuit         string `json:"circuit"`
	LinkType        string `json:"link_type"`
	ContributorCode string `json:"contributor_code"`

	stats.CircuitLatencyStat `json:",inline"`
	CommittedRTT             float64 `json:"committed_rtt"`
	CommittedJitter          float64 `json:"committed_jitter"`

	// Committed RTT and jitter deltas calculated as: committed - measured
	// Positive values mean the measured values are greater than the committed values.
	CommittedRTTDelta    float64 `json:"committed_rtt_delta"`
	CommittedJitterDelta float64 `json:"committed_jitter_delta"`

	// Committed RTT and jitter change ratios calcuated as: committed - measured / committed
	// Positive values mean the measured values are greater than the committed values.
	CommittedRTTChangeRatio    float64 `json:"committed_rtt_change_ratio"`
	CommittedJitterChangeRatio float64 `json:"committed_jitter_change_ratio"`
}

type Device struct {
	PK       solana.PublicKey `json:"pk"`
	Code     string           `json:"code"`
	Location Location         `json:"location"`
}

type EpochRange struct {
	From uint64
	To   uint64
}

type GetCircuitLatenciesConfig struct {
	Epochs    *EpochRange
	Time      *TimeRange
	Interval  time.Duration
	MaxPoints uint64
	Unit      Unit
	Circuit   string
}

type GetSummaryForCircuitsConfig struct {
	Epochs   *EpochRange
	Time     *TimeRange
	Unit     Unit
	Circuits []string
}

type Link struct {
	PK              solana.PublicKey `json:"pk"`
	Code            string           `json:"code"`
	LinkType        string           `json:"link_type"`
	ContributorCode string           `json:"contributor_code"`

	// Committed RTT and jitter are in microseconds.
	CommittedRTT    float64 `json:"committed_rtt"`
	CommittedJitter float64 `json:"committed_jitter"`
}

type Location struct {
	PK        solana.PublicKey `json:"pk"`
	Name      string           `json:"name"`
	Country   string           `json:"country"`
	Latitude  float64          `json:"latitude"`
	Longitude float64          `json:"longitude"`
}

type Provider interface {
	GetCircuits(ctx context.Context) ([]Circuit, error)
	GetCircuitLatencies(ctx context.Context, cfg GetCircuitLatenciesConfig) ([]stats.CircuitLatencyStat, error)
	GetSummaryForCircuits(ctx context.Context, cfg GetSummaryForCircuitsConfig) ([]CircuitSummary, error)
}

type ProviderConfig struct {
	Logger               *slog.Logger
	ServiceabilityClient ServiceabilityClient
	TelemetryClient      TelemetryClient
	EpochFinder          epoch.Finder

	CircuitsCacheTTL               time.Duration
	HistoricEpochLatenciesCacheTTL time.Duration
	CurrentEpochLatenciesCacheTTL  time.Duration
	GetCircuitLatenciesPoolSize    int
}

type Server struct {
	Mux *http.ServeMux
	// contains filtered or unexported fields
}

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

type TelemetryClient interface {
	GetDeviceLatencySamples(ctx context.Context, originDevicePubKey, targetDevicePubKey, linkPubKey solana.PublicKey, epoch uint64) (*telemetry.DeviceLatencySamples, error)
}

type TimeRange struct {
	From time.Time
	To   time.Time
}

type Unit string