Function NewSpanFilter

pkg/spanfilter/spanfilter.go:20–59

NewSpanFilter returns a SpanFilter that will filter spans based on the given filter policies.

(filterPolicies []config.FilterPolicy)

// NewSpanFilter returns a SpanFilter that will filter spans based on the given filter policies.
func NewSpanFilter(filterPolicies []config.FilterPolicy) (*SpanFilter, error) {
	sf := new(SpanFilter)
	for _, policy := range filterPolicies {
		err := config.ValidateFilterPolicy(policy)
		if err != nil {
			return nil, err
		}

		include, err := getSplitPolicy(policy.Include)
		if err != nil {
			return nil, err
		}

		if include != nil {
			sf.include = append(sf.include, include)
			sf.hasInclude = true
		}

		includeAny, err := getSplitPolicy(policy.IncludeAny)
		if err != nil {
			return nil, err
		}

		if includeAny != nil {
			sf.includeAny = append(sf.includeAny, includeAny)
			sf.hasIncludeAny = true
		}

		exclude, err := getSplitPolicy(policy.Exclude)
		if err != nil {
			return nil, err
		}
		if exclude != nil {
			sf.exclude = append(sf.exclude, exclude)
			sf.hasExclude = true
		}
	}

	return sf, nil
}

// ApplyFilterPolicy returns true if the span should be included in the metrics.
func (f *SpanFilter) ApplyFilterPolicy(rs *v1.Resource, span *tracev1.Span) bool {