internal

Documentation

Overview

Package internal contains an interface for detecting resource information, and a provider to merge the resources returned by a slice of custom detectors.

Index

• func AttributesToMap(am pdata.AttributeMap) map[string]interface{}
• func IsEmptyResource(res pdata.Resource) bool
• func MergeResource(to, from pdata.Resource, overrideTo bool)
• func NewAttributeMap(mp map[string]interface{}) pdata.AttributeMap
• func NewResource(mp map[string]interface{}) pdata.Resource
• func UnwrapAttribute(v pdata.AttributeValue) interface{}
• type Detector
• type DetectorConfig
• type DetectorFactory
• type DetectorType
• type ResourceDetectorConfig
• type ResourceProvider
  • func NewResourceProvider(logger *zap.Logger, timeout time.Duration, detectors ...Detector) *ResourceProvider
  • func (p *ResourceProvider) Get(ctx context.Context) (pdata.Resource, error)
• type ResourceProviderFactory
  • func NewProviderFactory(detectors map[DetectorType]DetectorFactory) *ResourceProviderFactory
  • func (f *ResourceProviderFactory) CreateResourceProvider(params component.ProcessorCreateParams, timeout time.Duration, ...) (*ResourceProvider, error)

Functions

func AttributesToMap

func AttributesToMap(am pdata.AttributeMap) map[string]interface{}

func IsEmptyResource

func IsEmptyResource(res pdata.Resource) bool

func MergeResource

func MergeResource(to, from pdata.Resource, overrideTo bool)

func NewAttributeMap

func NewAttributeMap(mp map[string]interface{}) pdata.AttributeMap

func NewResource

func NewResource(mp map[string]interface{}) pdata.Resource

func UnwrapAttribute

func UnwrapAttribute(v pdata.AttributeValue) interface{}

Types

type Detector

type Detector interface {
	Detect(ctx context.Context) (pdata.Resource, error)
}

type DetectorConfig

type DetectorConfig interface{}

type DetectorFactory

type DetectorFactory func(component.ProcessorCreateParams, DetectorConfig) (Detector, error)

type DetectorType

type DetectorType string

type ResourceDetectorConfig

type ResourceDetectorConfig interface {
	GetConfigFromType(DetectorType) DetectorConfig
}

type ResourceProvider

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

func NewResourceProvider

func NewResourceProvider(logger *zap.Logger, timeout time.Duration, detectors ...Detector) *ResourceProvider

func (*ResourceProvider) Get

func (p *ResourceProvider) Get(ctx context.Context) (pdata.Resource, error)

type ResourceProviderFactory

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

func NewProviderFactory

func NewProviderFactory(detectors map[DetectorType]DetectorFactory) *ResourceProviderFactory

func (*ResourceProviderFactory) CreateResourceProvider

func (f *ResourceProviderFactory) CreateResourceProvider(
	params component.ProcessorCreateParams,
	timeout time.Duration,
	detectorConfigs ResourceDetectorConfig,
	detectorTypes ...DetectorType) (*ResourceProvider, error)