sampling

Documentation

Index

• func NewSamplingDataProvider(opts ...SamplingDataProviderOption) *samplingDataProvider
• type SamplingDataProviderOption
  • func WithSampledSpanCustomizer(customizer sampledSpanCustomizerFunc) SamplingDataProviderOption
• type SamplingTestValidator
  • func NewSamplingValidator(senderName string, receiverName string, provider *samplingDataProvider, ...) *SamplingTestValidator
  • func (v *SamplingTestValidator) RecordResults(tc *testbed.TestCase)
  • func (v *SamplingTestValidator) Validate(tc *testbed.TestCase)
• type TraceAssertionFailure

Functions

func NewSamplingDataProvider

func NewSamplingDataProvider(opts ...SamplingDataProviderOption) *samplingDataProvider

NewSamplingDataProvider creates a new instance of samplingDataProvider

Types

type SamplingDataProviderOption

type SamplingDataProviderOption func(t *samplingDataProvider)

SamplingDataProviderOption defines a PollutedDataProvider option.

func WithSampledSpanCustomizer

func WithSampledSpanCustomizer(customizer sampledSpanCustomizerFunc) SamplingDataProviderOption

WithSampledSpanCustomizer allows you to customize the spans that are sampled. The function passed as parameter will be called for each span that should be sampled. The idea is that you can use this to control the attributes and properties of a span so that they are filtered by the Tail sampling processor. For example, to add specific properties to the spans that should be sampled:

WithSampledSpanCustomizer(func (span ptrace.Span) {
    pan.Attributes().PutStr("key", "valuefoo")
})

type SamplingTestValidator

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

SamplingTestValidator implements TestCaseValidator for test suites using CorrectnessResults for summarizing results.

func NewSamplingValidator

func NewSamplingValidator(senderName string, receiverName string, provider *samplingDataProvider, t *testing.T) *SamplingTestValidator

func (*SamplingTestValidator) RecordResults

func (v *SamplingTestValidator) RecordResults(tc *testbed.TestCase)

func (*SamplingTestValidator) Validate

func (v *SamplingTestValidator) Validate(tc *testbed.TestCase)

type TraceAssertionFailure

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