Documentation
¶
Index ¶
- Constants
- Variables
- func NewProvider(cfg *ProviderConfig) (*provider, error)
- type Circuit
- type CircuitLatenciesWithHeader
- type Device
- type EpochRange
- type GetCircuitLatenciesConfig
- type Link
- type Location
- type Provider
- type ProviderConfig
- type Server
- type ServiceabilityClient
- type TelemetryClient
- type TimeRange
- type Unit
Constants ¶
View Source
const (
DefaultMaxPoints = 1000
)
Variables ¶
View Source
var (
ErrInvalidEnvironment = fmt.Errorf("invalid environment")
)
Functions ¶
func NewProvider ¶
func NewProvider(cfg *ProviderConfig) (*provider, error)
Types ¶
type CircuitLatenciesWithHeader ¶
type CircuitLatenciesWithHeader struct {
Header *telemetry.DeviceLatencySamplesHeader
Samples []datastats.CircuitLatencySample
}
type EpochRange ¶
func (*EpochRange) String ¶
func (e *EpochRange) String() string
type Provider ¶
type Provider interface {
GetCircuits(ctx context.Context) ([]Circuit, error)
GetCircuitLatencies(ctx context.Context, cfg GetCircuitLatenciesConfig) ([]stats.CircuitLatencyStat, error)
}
type ProviderConfig ¶
type ProviderConfig struct {
Logger *slog.Logger
ServiceabilityClient ServiceabilityClient
TelemetryClient TelemetryClient
EpochFinder epoch.Finder
CircuitsCacheTTL time.Duration
HistoricEpochLatenciesCacheTTL time.Duration
CurrentEpochLatenciesCacheTTL time.Duration
GetCircuitLatenciesPoolSize int
}
func (*ProviderConfig) Validate ¶
func (c *ProviderConfig) Validate() error
type ServiceabilityClient ¶
type ServiceabilityClient interface {
GetProgramData(ctx context.Context) (*serviceability.ProgramData, error)
}
type TelemetryClient ¶
Click to show internal directories.
Click to hide internal directories.