blackbox

Documentation

Index

• Constants
• func EmitMeasuredMetrics(sourceId string, ingressClient logcache_v1.IngressClient, ...)
• func MagicMetricNames() []string
• func NewIngressClient(grpcAddr string, opts ...grpc.DialOption) logcache_v1.IngressClient
• func StartEmittingTestMetrics(sourceId string, emissionInterval time.Duration, ...)
• type QueryableClient
  • func NewGrpcEgressClient(grpcAddr string, opts ...grpc.DialOption) QueryableClient
  • func NewHttpEgressClient(httpAddr, uaaAddr, uaaClientId, uaaClientSecret string, skipTLSVerify bool) QueryableClient
• type ReliabilityCalculator
  • func (rc ReliabilityCalculator) Calculate(client QueryableClient) (float64, error)
  • func (rc ReliabilityCalculator) CountMetricPoints(metricName string, client QueryableClient) (uint64, error)
  • func (rc ReliabilityCalculator) ExpectedSamples() float64

Constants

const (
	MAGIC_METRIC_NAME = "blackbox_test_metric"
	TEN_MINUTES       = int64(600)
)

Functions

func EmitMeasuredMetrics

func EmitMeasuredMetrics(sourceId string, ingressClient logcache_v1.IngressClient, logCache QueryableClient, metrics map[string]float64)

func MagicMetricNames

func MagicMetricNames() []string

func NewIngressClient

func NewIngressClient(grpcAddr string, opts ...grpc.DialOption) logcache_v1.IngressClient

func StartEmittingTestMetrics

func StartEmittingTestMetrics(sourceId string, emissionInterval time.Duration, ingressClient logcache_v1.IngressClient)

Types

type QueryableClient

type QueryableClient interface {
	PromQL(context.Context, string, ...logcache_client.PromQLOption) (*logcache_v1.PromQL_InstantQueryResult, error)
	LogCacheVMUptime(ctx context.Context) (int64, error)
}

func NewGrpcEgressClient

func NewGrpcEgressClient(grpcAddr string, opts ...grpc.DialOption) QueryableClient

func NewHttpEgressClient

func NewHttpEgressClient(httpAddr, uaaAddr, uaaClientId, uaaClientSecret string, skipTLSVerify bool) QueryableClient

type ReliabilityCalculator

type ReliabilityCalculator struct {
	SampleInterval   time.Duration
	WindowInterval   time.Duration
	WindowLag        time.Duration
	EmissionInterval time.Duration
	SourceId         string
	InfoLogger       *log.Logger
	ErrorLogger      *log.Logger
}

func (ReliabilityCalculator) Calculate

func (rc ReliabilityCalculator) Calculate(client QueryableClient) (float64, error)

func (ReliabilityCalculator) CountMetricPoints

func (rc ReliabilityCalculator) CountMetricPoints(metricName string, client QueryableClient) (uint64, error)

func (ReliabilityCalculator) ExpectedSamples

func (rc ReliabilityCalculator) ExpectedSamples() float64