blackbox

type Config struct {
	EmissionInterval time.Duration `env:"EMISSION_INTERVAL, required, report"`
	SampleInterval   time.Duration `env:"SAMPLE_INTERVAL, required, report"`
	WindowInterval   time.Duration `env:"WINDOW_INTERVAL, required, report"`
	WindowLag        time.Duration `env:"WINDOW_LAG, required, report"`
	SourceId         string        `env:"SOURCE_ID, required, report"`

	HealthPort             int    `env:"HEALTH_PORT, report"`
	CfBlackboxEnabled      bool   `env:"CF_BLACKBOX_ENABLED, report"`
	MetricStoreHTTPAddr    string `env:"METRIC_STORE_HTTP_ADDR, required, report"`
	MetricStoreIngressAddr string `env:"METRIC_STORE_INGRESS_ADDR, required, report"`
	UaaAddr                string `env:"UAA_ADDR, report"`
	ClientID               string `env:"CLIENT_ID, report"`
	ClientSecret           string `env:"CLIENT_SECRET"`
	SkipTLSVerify          bool   `env:"SKIP_TLS_VERIFY, report"`

	MetricStoreGrpcAddr   string `env:"METRIC_STORE_GRPC_ADDR, required, report"`
	TLS                   sharedtls.TLS
	MetricStoreMetricsTLS MetricStoreMetricsTLS

	LogLevel string `env:"LOG_LEVEL,                      report"`
}

type MetricStoreMetricsTLS struct {
	CAPath   string `env:"METRIC_STORE_METRICS_CA_PATH, required, report"`
	CertPath string `env:"METRIC_STORE_METRICS_CERT_PATH, required, report"`
	KeyPath  string `env:"METRIC_STORE_METRICS_KEY_PATH, required, report"`
}

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

type PerformanceMetrics struct {
	Latency   time.Duration
	Magnitude int
}

type QueryableClient interface {
	Query(ctx context.Context, query string, ts time.Time) (model.Value, prom_api_client.Warnings, error)
	LabelValues(context.Context, string) (model.LabelValues, api.Warnings, error)
}

type ReliabilityCalculator struct {
	SampleInterval   time.Duration
	WindowInterval   time.Duration
	WindowLag        time.Duration
	EmissionInterval time.Duration
	SourceId         string
	Log              *logger.Logger
	DebugRegistrar   *debug.Registrar
}