data

type Circuit struct {
	Code           string   `json:"code"`
	OriginExchange Exchange `json:"origin_exchange"`
	TargetExchange Exchange `json:"target_exchange"`
}

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

type EpochRange struct {
	From uint64
	To   uint64
}

type Exchange struct {
	PK        solana.PublicKey `json:"pk"`
	Code      string           `json:"code"`
	Name      string           `json:"name"`
	Latitude  float64          `json:"latitude"`
	Longitude float64          `json:"longitude"`
}

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

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

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

	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 {
	GetInternetLatencySamples(ctx context.Context, dataProvider string, originExchangePK, targetExchangePK solana.PublicKey, agentPK solana.PublicKey, epoch uint64) (*telemetry.InternetLatencySamples, error)
}

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

type Unit string