resolver

Documentation

Index

• Constants
• Variables
• func NewAttributesResolver(resolvers []appsignalsconfig.Resolver, logger *zap.Logger) *attributesResolver
• type Deleter
• type PodWatcher
  • func NewPodWatcher(logger *zap.Logger, informer cache.SharedIndexInformer, deleter Deleter) *PodWatcher
  • func (p *PodWatcher) Run(stopCh chan struct{})
  • func (p *PodWatcher) WaitForCacheSync(stopCh chan struct{})
• type ServiceToWorkloadMapper
  • func NewServiceToWorkloadMapper(serviceAndNamespaceToSelectors, workloadAndNamespaceToLabels, ... *sync.Map, ...) *ServiceToWorkloadMapper
  • func (m *ServiceToWorkloadMapper) MapServiceToWorkload()
  • func (m *ServiceToWorkloadMapper) Start(stopCh chan struct{})
• type ServiceWatcher
  • func NewServiceWatcher(logger *zap.Logger, informer cache.SharedIndexInformer, deleter Deleter) *ServiceWatcher
  • func (s *ServiceWatcher) Run(stopCh chan struct{})
  • func (s *ServiceWatcher) WaitForCacheSync(stopCh chan struct{})
• type TimedDeleter
  • func (td *TimedDeleter) DeleteWithDelay(m *sync.Map, key interface{})

Constants

const AttributePlatformGeneric = "Generic"

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

Variables

var DefaultHostedInAttributeMap = map[string]string{
	semconv.AttributeK8SNamespaceName: attr.HostedInK8SNamespace,
}

var DefaultHostedInAttributes = map[string]string{
	attr.AWSHostedInEnvironment: attr.HostedInEnvironment,
}

Functions

func NewAttributesResolver

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

create a new attributes resolver

Types

type Deleter

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

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

type PodWatcher

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

func NewPodWatcher

func NewPodWatcher(logger *zap.Logger, informer cache.SharedIndexInformer, deleter Deleter) *PodWatcher

func (*PodWatcher) Run

func (p *PodWatcher) Run(stopCh chan struct{})

func (*PodWatcher) WaitForCacheSync

func (p *PodWatcher) WaitForCacheSync(stopCh chan struct{})

type ServiceToWorkloadMapper

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

func NewServiceToWorkloadMapper

func NewServiceToWorkloadMapper(serviceAndNamespaceToSelectors, workloadAndNamespaceToLabels, serviceToWorkload *sync.Map, logger *zap.Logger, deleter Deleter) *ServiceToWorkloadMapper

func (*ServiceToWorkloadMapper) MapServiceToWorkload

func (m *ServiceToWorkloadMapper) MapServiceToWorkload()

func (*ServiceToWorkloadMapper) Start

func (m *ServiceToWorkloadMapper) Start(stopCh chan struct{})

type ServiceWatcher

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

func NewServiceWatcher

func NewServiceWatcher(logger *zap.Logger, informer cache.SharedIndexInformer, deleter Deleter) *ServiceWatcher

func (*ServiceWatcher) Run

func (s *ServiceWatcher) Run(stopCh chan struct{})

func (*ServiceWatcher) WaitForCacheSync

func (s *ServiceWatcher) WaitForCacheSync(stopCh chan struct{})

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 interface{})