func TestAPIServerTracingWithKMSv2(t *testing.T) { … } func TestAPIServerTracingWithEgressSelector(t *testing.T) { … } func TestAPIServerTracing(t *testing.T) { … } type traceServer … func (t *traceServer) Export(ctx context.Context, req *traceservice.ExportTraceServiceRequest) (*traceservice.ExportTraceServiceResponse, error) { … } // resetExpectations is used by a new test scenario to set new expectations for // the test server. func (t *traceServer) resetExpectations(newExpectations traceExpectation) { … } type traceExpectation … // met returns true if all span expectations the server is looking for have // been satisfied. func (t traceExpectation) met() bool { … } // contains returns true if the all spans in the trace expectation contain the // trace ID func (t traceExpectation) contains(checkTID string) bool { … } // update finds all expectations that are met by a span in the // incoming request. func (t traceExpectation) update(req *traceservice.ExportTraceServiceRequest) { … } // updateForSpan updates expectations based on a single incoming span. func (t traceExpectation) updateForSpan(span *tracev1.Span) { … } type spanExpectation … func (s *spanExpectation) contains(tid string) bool { … } type eventExpectation … // matches returns true if all expected events exist in the list of input events. func (e eventExpectation) matches(events []*tracev1.Span_Event) bool { … } type attributeExpectation … // matches returns true if all expected attributes exist in the intput list of attributes. func (a attributeExpectation) matches(attrs []*commonv1.KeyValue) bool { … }
Codebase Browser
kubernetes