resolver

Documentation

Index

• Constants
• Variables
• type AttributesResolver
  • func NewAttributesResolver(resolvers []appsignalsconfig.Resolver, logger *zap.Logger) *AttributesResolver
  • func (r *AttributesResolver) Process(attributes, resourceAttributes pcommon.Map, _ bool) error
  • func (r *AttributesResolver) Stop(ctx context.Context) error
• type Deleter
• type TimedDeleter
  • func (td *TimedDeleter) DeleteWithDelay(m *sync.Map, key any)

Constants

const (
	AttributeEnvironmentDefault = "default"

	AttributePlatformGeneric = "Generic"
	AttributePlatformEC2     = "AWS::EC2"
	AttributePlatformEKS     = "AWS::EKS"
	AttributePlatformECS     = "AWS::ECS"
	AttributePlatformK8S     = "K8s"
)

const IP_PORT_PATTERN = `^(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}):(\d+)$` //nolint: revive

Variables

var DefaultInheritedAttributes = map[string]string{
	semconv.AttributeDeploymentEnvironment: attr.AWSLocalEnvironment,
	attr.ResourceDetectionASG:              common.AttributeEC2AutoScalingGroup,
	attr.ResourceDetectionHostID:           common.AttributeEC2InstanceID,
	attr.ResourceDetectionHostName:         common.AttributeHost,
}

DefaultInheritedAttributes is an allow-list that also renames attributes from the resource detection processor

var GenericInheritedAttributes = map[string]string{
	semconv.AttributeDeploymentEnvironment: attr.AWSLocalEnvironment,
	attr.ResourceDetectionHostName:         common.AttributeHost,
}

Types

type AttributesResolver

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

func NewAttributesResolver

func NewAttributesResolver(resolvers []appsignalsconfig.Resolver, logger *zap.Logger) *AttributesResolver

create a new attributes resolver

func (*AttributesResolver) Process

func (r *AttributesResolver) Process(attributes, resourceAttributes pcommon.Map, _ bool) error

Process the attributes

func (*AttributesResolver) Stop

func (r *AttributesResolver) Stop(ctx context.Context) error

type Deleter

type Deleter interface {
	DeleteWithDelay(m *sync.Map, key any)
}

Deleter represents a type that can delete a key from a map after a certain delay.

type TimedDeleter

type TimedDeleter struct {
	Delay time.Duration
}

TimedDeleter deletes a key after a specified delay.

func (*TimedDeleter) DeleteWithDelay

func (td *TimedDeleter) DeleteWithDelay(m *sync.Map, key any)