spanobfuscation

Documentation

Index

• Constants
• type SpanTagObfuscation
  • func NewObf(ruleConfigs []*TagMatchRuleConfig, next obfsink) (*SpanTagObfuscation, error)
  • func (o *SpanTagObfuscation) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (o *SpanTagObfuscation) AddEvents(ctx context.Context, events []*event.Event) error
  • func (o *SpanTagObfuscation) AddSpans(ctx context.Context, spans []*trace.Span) error
• type SpanTagRemoval
  • func NewRm(ruleConfigs []*TagMatchRuleConfig, next rmsink) (*SpanTagRemoval, error)
  • func (o *SpanTagRemoval) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error
  • func (o *SpanTagRemoval) AddEvents(ctx context.Context, events []*event.Event) error
  • func (o *SpanTagRemoval) AddSpans(ctx context.Context, spans []*trace.Span) error
• type TagMatchRuleConfig

Constants

const OBFUSCATED = "<obfuscated>"

OBFUSCATED is the value to use for obfuscated tags

Types

type SpanTagObfuscation

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

SpanTagObfuscation does a wildcard search for service and operation name, and replaces the given tags from matching spans with the OBFUSCATED const This modifies the objects parsed, so in a concurrent context, you will want to copy the objects sent here first

func NewObf

func NewObf(ruleConfigs []*TagMatchRuleConfig, next obfsink) (*SpanTagObfuscation, error)

NewObf returns you a new SpanTagObfuscation object

func (*SpanTagObfuscation) AddDatapoints

func (o *SpanTagObfuscation) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints is a passthrough

func (*SpanTagObfuscation) AddEvents

func (o *SpanTagObfuscation) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents is a passthrough

func (*SpanTagObfuscation) AddSpans

func (o *SpanTagObfuscation) AddSpans(ctx context.Context, spans []*trace.Span) error

AddSpans maps all rules to all spans and replaces the specified tags with the OBFUSCATED const if the service and operation match. This can be very expensive, and modifies the spans

type SpanTagRemoval

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

SpanTagRemoval does a wildcard search for service and operation name, and removes the given tags from matching spans This modifies the objects parsed, so in a concurrent context, you will want to copy the objects sent here first

func NewRm

func NewRm(ruleConfigs []*TagMatchRuleConfig, next rmsink) (*SpanTagRemoval, error)

NewRm returns you a new SpanTagRemoval object

func (*SpanTagRemoval) AddDatapoints

func (o *SpanTagRemoval) AddDatapoints(ctx context.Context, points []*datapoint.Datapoint) error

AddDatapoints is a passthrough

func (*SpanTagRemoval) AddEvents

func (o *SpanTagRemoval) AddEvents(ctx context.Context, events []*event.Event) error

AddEvents is a passthrough

func (*SpanTagRemoval) AddSpans

func (o *SpanTagRemoval) AddSpans(ctx context.Context, spans []*trace.Span) error

AddSpans maps all rules to all spans and deletes the specified tags if the service and operation match. This can be very expensive, and modifies the spans

type TagMatchRuleConfig

type TagMatchRuleConfig struct {
	Service   *string  `json:",omitempty"`
	Operation *string  `json:",omitempty"`
	Tags      []string `json:",omitempty"`
}

TagMatchRuleConfig describes a wildcard search for a service and operation, along with which specific tags to match Service and Operation can both include "*" for wildcard search, but Tags will only perform an exact text match If Service or Operation are omitted, they will use a default value of "*", to match any service/operation Tags must be present, and cannot be empty