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 pcommon.Map) map[string]interface{}
• func ClientFromContext(ctx context.Context) (*http.Client, error)
• func ContextWithClient(ctx context.Context, client *http.Client) context.Context
• func IsEmptyResource(res pcommon.Resource) bool
• func MergeResource(to, from pcommon.Resource, overrideTo bool)
• func MergeSchemaURL(currentSchemaURL string, newSchemaURL string) string
• func NewAttributeMap(mp map[string]interface{}) pcommon.Map
• func NewResource(mp map[string]interface{}) pcommon.Resource
• func UnwrapAttribute(v pcommon.Value) interface{}
• type Detector
• type DetectorConfig
• type DetectorFactory
• type DetectorType
• type ResourceDetectorConfig
• type ResourceProvider
  • func NewResourceProvider(logger *zap.Logger, timeout time.Duration, ...) *ResourceProvider
  • func (p *ResourceProvider) Get(ctx context.Context, client *http.Client) (resource pcommon.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 pcommon.Map) map[string]interface{}

func ClientFromContext

func ClientFromContext(ctx context.Context) (*http.Client, error)

ClientFromContext attempts to extract an *http.Client from the provided context.Context.

func ContextWithClient

func ContextWithClient(ctx context.Context, client *http.Client) context.Context

ContextWithClient returns a new context.Context with the provided *http.Client stored as a value.

func IsEmptyResource

func IsEmptyResource(res pcommon.Resource) bool

func MergeResource

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

func MergeSchemaURL

func MergeSchemaURL(currentSchemaURL string, newSchemaURL string) string

func NewAttributeMap

func NewAttributeMap(mp map[string]interface{}) pcommon.Map

func NewResource

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

func UnwrapAttribute

func UnwrapAttribute(v pcommon.Value) interface{}

Types

type Detector

type Detector interface {
	Detect(ctx context.Context) (resource pcommon.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, attributesToKeep map[string]struct{}, detectors ...Detector) *ResourceProvider

func (*ResourceProvider) Get

func (p *ResourceProvider) Get(ctx context.Context, client *http.Client) (resource pcommon.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,
	attributes []string,
	detectorConfigs ResourceDetectorConfig,
	detectorTypes ...DetectorType) (*ResourceProvider, error)