Files
475c5c013f feat: added signoz tail sampler (#111)
* feat: added signoz tail sampler

* chore: fixed test cases for signoz sampler

* chore: fixed test cases from upstream tail sampler

* chore: added test coverate for default eval in tailsampler

* Update processor/signoztailsampler/internal/sampling/always_unsample.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* Update processor/signoztailsampler/README.md

Co-authored-by: Srikanth Chekuri <[email protected]>

* fix: fixed issue with root polity in tail sampler

* chore: added documentation for tail based sampler

* chore: removed self-ref in tail policy structure

* chore: added config test for tail sampler

* feat: added priority based evaluation

* fix: added validations for config

* Update processor/signoztailsampler/factory.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* Update processor/signoztailsampler/evaluator.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* Update processor/signoztailsampler/evaluator.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* Update processor/signoztailsampler/config.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* chore: addreessed some review comments

* chore: added stats view again

* Update processor/signoztailsampler/evaluator.go

Co-authored-by: Srikanth Chekuri <[email protected]>

* fix: go version, tests & API usage

* chore: fix lint

* chore: actually fix lint

* chore: hopefully last fix

---------

Co-authored-by: mindhash <[email protected]>
Co-authored-by: Srikanth Chekuri <[email protected]>
2023-06-03 06:25:54 +00:00

26 lines
614 B
Go

package sampling
import (
"go.opentelemetry.io/collector/pdata/pcommon"
"go.uber.org/zap"
)
type neverSample struct {
logger *zap.Logger
}
var _ PolicyEvaluator = (*neverSample)(nil)
// NewNeverSample creates a policy evaluator the samples all traces.
func NewNeverSample(logger *zap.Logger) PolicyEvaluator {
return &neverSample{
logger: logger,
}
}
// Evaluate looks at the trace data and returns a corresponding SamplingDecision.
func (aus *neverSample) Evaluate(pcommon.TraceID, *TraceData) (Decision, error) {
aus.logger.Debug("Evaluating spans in never-sample filter")
return NotSampled, nil
}