Documentation
¶
Index ¶
Constants ¶
View Source
const ( AttributeEnvironmentDefault = "default" AttributePlatformGeneric = "Generic" AttributePlatformEC2 = "AWS::EC2" AttributePlatformEKS = "AWS::EKS" AttributePlatformK8S = "K8s" )
View Source
const IP_PORT_PATTERN = `^(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}):(\d+)$`
Variables ¶
View Source
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
View Source
var GenericInheritedAttributes = map[string]string{ semconv.AttributeDeploymentEnvironment: attr.AWSLocalEnvironment, attr.ResourceDetectionHostName: common.AttributeHost, }
Functions ¶
func NewAttributesResolver ¶
func NewAttributesResolver(resolvers []appsignalsconfig.Resolver, logger *zap.Logger) *attributesResolver
create a new attributes resolver
Types ¶
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 (*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 ¶
TimedDeleter deletes a key after a specified delay.
func (*TimedDeleter) DeleteWithDelay ¶
func (td *TimedDeleter) DeleteWithDelay(m *sync.Map, key interface{})
Source Files
Click to show internal directories.
Click to hide internal directories.