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 GOOSToOSType(goos string) string
• func IsEmptyResource(res pdata.Resource) bool
• func MergeResource(to, from pdata.Resource, overrideTo bool)
• func MergeSchemaURL(currentSchemaURL string, newSchemaURL string) string
• 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) (resource pdata.Resource, schemaURL string, err error)
• type ResourceProviderFactory
  • func NewProviderFactory(detectors map[DetectorType]DetectorFactory) *ResourceProviderFactory
  • func (f *ResourceProviderFactory) CreateResourceProvider(params component.ProcessorCreateSettings, timeout time.Duration, ...) (*ResourceProvider, error)

Functions

func AttributesToMap

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

func GOOSToOSType

func GOOSToOSType(goos string) string

GOOSToOSType maps a runtime.GOOS-like value to os.type style.

func IsEmptyResource

func IsEmptyResource(res pdata.Resource) bool

func MergeResource

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

func MergeSchemaURL

func MergeSchemaURL(currentSchemaURL string, newSchemaURL string) string

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) (resource pdata.Resource, schemaURL string, err error)
}

type DetectorConfig

type DetectorConfig interface{}

type DetectorFactory

type DetectorFactory func(component.ProcessorCreateSettings, 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) (resource pdata.Resource, schemaURL string, err 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.ProcessorCreateSettings,
	timeout time.Duration,
	detectorConfigs ResourceDetectorConfig,
	detectorTypes ...DetectorType) (*ResourceProvider, error)