testutil

Documentation

Index

• Variables
• func BoolValueRefs() (*bool, *bool)
• func CheckAttributes(t *testing.T, attrs []*commonV1.KeyValue, ...) *commonV1.AnyValue
• func CheckCounterMetricIsGreaterThen(value float64, families map[string]*promdto.MetricFamily, metrics ...string) error
• func CheckCounterMetricIsZero(families map[string]*promdto.MetricFamily, metrics ...string) error
• func CheckPayload(t *testing.T, payload *commonV1.AnyValue, encoding string)
• func CheckResource(t *testing.T, res *resourceV1.Resource, hubbleResp *observer.GetFlowsResponse)
• func GetFlowSamples(t *testing.T, path string) []*observer.GetFlowsResponse
• func GetMetricFamilies(ctx context.Context, t *testing.T, url string) map[string]*promdto.MetricFamily
• func IsEOF(err error) bool
• func RunOpenTelemtryCollector(ctx context.Context, t *testing.T, configPath string, fatal chan<- error, ...)
• func WaitForServer(ctx context.Context, logf func(format string, args ...interface{}), ...)
• type TLSPaths

Variables

var RunMockHubble = mockHubbleObeserver.Run

Functions

func BoolValueRefs

func BoolValueRefs() (*bool, *bool)

func CheckAttributes

func CheckAttributes(t *testing.T, attrs []*commonV1.KeyValue, encodingOptions common.EncodingOptions) *commonV1.AnyValue

func CheckCounterMetricIsGreaterThen

func CheckCounterMetricIsGreaterThen(value float64, families map[string]*promdto.MetricFamily, metrics ...string) error

func CheckCounterMetricIsZero

func CheckCounterMetricIsZero(families map[string]*promdto.MetricFamily, metrics ...string) error

func CheckPayload

func CheckPayload(t *testing.T, payload *commonV1.AnyValue, encoding string)

func CheckResource

func CheckResource(t *testing.T, res *resourceV1.Resource, hubbleResp *observer.GetFlowsResponse)

func GetFlowSamples

func GetFlowSamples(t *testing.T, path string) []*observer.GetFlowsResponse

func GetMetricFamilies

func GetMetricFamilies(ctx context.Context, t *testing.T, url string) map[string]*promdto.MetricFamily

func IsEOF

func IsEOF(err error) bool

func RunOpenTelemtryCollector

func RunOpenTelemtryCollector(ctx context.Context, t *testing.T, configPath string, fatal chan<- error, extraReceiverFactories ...component.ReceiverFactory)

func WaitForServer

func WaitForServer(ctx context.Context, logf func(format string, args ...interface{}), address string)

Types

type TLSPaths

type TLSPaths = mockHubbleObeserver.TLSPaths