component

package module

Go to main page

Versions in this module

v0

v0.98.0

Apr 10, 2024

Changes in this version

type Type

+ func (t Type) MarshalText() ([]byte, error)

v0.97.0

Mar 25, 2024

v0.96.0

Mar 4, 2024

v0.95.0

Feb 20, 2024

v0.94.1

Feb 7, 2024

v0.94.0

Feb 6, 2024

Changes in this version

type ID

+ func MustNewID(typeVal string) ID

+ func MustNewIDWithName(typeVal string, nameVal string) ID

type Type

+ func MustNewType(strType string) Type

+ func NewType(ty string) (Type, error)

+ func (t Type) String() string

v0.93.0

Jan 24, 2024

v0.92.0

Jan 9, 2024

Changes in this version

type TelemetrySettings

+ ReportStatus func(*StatusEvent)

v0.91.0

Dec 11, 2023

Changes in this version

type TelemetrySettings

+ ReportComponentStatus StatusFunc

v0.90.1

Dec 1, 2023

v0.90.0

Nov 27, 2023

v0.89.0

Nov 14, 2023

Changes in this version

type Kind

+ func (k Kind) String() string

v0.88.0

Oct 23, 2023

v0.87.0

Oct 10, 2023

Changes in this version

+ func StatusIsError(status Status) bool

+ type InstanceID struct

+ ID ID

+ Kind Kind

+ PipelineIDs map[ID]struct{}

+ type Status int32

+ const StatusFatalError

+ const StatusNone

+ const StatusOK

+ const StatusPermanentError

+ const StatusRecoverableError

+ const StatusStarting

+ const StatusStopped

+ const StatusStopping

+ func AggregateStatus(eventMap map[K]*StatusEvent) Status

+ func (s Status) String() string

+ type StatusEvent struct

+ func AggregateStatusEvent(eventMap map[K]*StatusEvent) *StatusEvent

+ func NewFatalErrorEvent(err error) *StatusEvent

+ func NewPermanentErrorEvent(err error) *StatusEvent

+ func NewRecoverableErrorEvent(err error) *StatusEvent

+ func NewStatusEvent(status Status) *StatusEvent

+ func (ev *StatusEvent) Err() error

+ func (ev *StatusEvent) Status() Status

+ func (ev *StatusEvent) Timestamp() time.Time

+ type StatusFunc func(*StatusEvent) error

+ type TelemetrySettingsBase struct

+ Logger *zap.Logger

+ MeterProvider metric.MeterProvider

+ MetricsLevel configtelemetry.Level

+ ReportComponentStatus T

+ Resource pcommon.Resource

+ TracerProvider trace.TracerProvider

v0.86.0

Sep 25, 2023

v0.85.0

Sep 11, 2023

v0.84.0

Aug 29, 2023

v0.83.0

Aug 14, 2023

v0.82.0

Jul 26, 2023

v0.81.0

Jul 4, 2023

v0.80.0

Jun 20, 2023

v0.79.0

Jun 5, 2023

v0.78.2

May 23, 2023

v0.78.1

May 22, 2023

v0.78.0

May 22, 2023

v0.77.0

May 8, 2023

Changes in this version

type TelemetrySettings

+ Resource pcommon.Resource

v0.76.1

Apr 26, 2023

v0.76.0

Apr 25, 2023

retracted

v0.75.0

Apr 3, 2023

v0.74.0

Mar 20, 2023

v0.73.0

Mar 7, 2023

v0.72.0

Feb 22, 2023

v0.71.0

Feb 8, 2023

v0.70.0

Jan 23, 2023

v0.69.1

Jan 12, 2023

v0.69.0

Jan 9, 2023

retracted

v0.68.0

Dec 19, 2022

v0.67.0

Dec 9, 2022

Changes in this version

+ func UnmarshalConfig(conf *confmap.Conf, intoCfg Config) error

type Config

+ ID func() ID

+ SetIDName func(idName string)

+ type CreateDefaultConfigFunc func() Config

+ func (f CreateDefaultConfigFunc) CreateDefaultConfig() Config

type ExporterCreateSettings

+ ID ID

type ExtensionCreateSettings

+ ID ID

type Factory

+ CreateDefaultConfig func() Config

type Kind

+ const KindConnector

type ProcessorCreateSettings

+ ID ID

type ReceiverCreateSettings

+ ID ID

v0.66.0

Nov 21, 2022

v0.65.0

Nov 21, 2022

Changes in this version

+ const StabilityLevelInDevelopment

+ var ErrDataTypeIsNotSupported = errors.New("telemetry type is not supported")

+ var ErrNilNextConsumer = errors.New("nil next Consumer")

+ func MakeExporterFactoryMap(factories ...ExporterFactory) (map[Type]ExporterFactory, error)

+ func MakeExtensionFactoryMap(factories ...ExtensionFactory) (map[Type]ExtensionFactory, error)

+ func MakeProcessorFactoryMap(factories ...ProcessorFactory) (map[Type]ProcessorFactory, error)

+ func MakeReceiverFactoryMap(factories ...ReceiverFactory) (map[Type]ReceiverFactory, error)

+ func UnmarshalExporterConfig(conf *confmap.Conf, cfg ExporterConfig) error

+ func UnmarshalExtensionConfig(conf *confmap.Conf, cfg ExtensionConfig) error

+ func UnmarshalProcessorConfig(conf *confmap.Conf, cfg ProcessorConfig) error

+ func UnmarshalReceiverConfig(conf *confmap.Conf, cfg ReceiverConfig) error

+ func ValidateConfig(cfg Config) error

+ type BuildInfo struct

+ Command string

+ Description string

+ Version string

+ func NewDefaultBuildInfo() BuildInfo

+ type Component interface

+ Shutdown func(ctx context.Context) error

+ Start func(ctx context.Context, host Host) error

+ type Config interface

+ Validate func() error

+ type ConfigValidator interface

+ Validate func() error

+ type CreateExtensionFunc func(context.Context, ExtensionCreateSettings, ExtensionConfig) (Extension, error)

+ func (f CreateExtensionFunc) CreateExtension(ctx context.Context, set ExtensionCreateSettings, cfg ExtensionConfig) (Extension, error)

+ type CreateLogsExporterFunc func(context.Context, ExporterCreateSettings, ExporterConfig) (LogsExporter, error)

+ func (f CreateLogsExporterFunc) CreateLogsExporter(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (LogsExporter, error)

+ type CreateLogsProcessorFunc func(context.Context, ProcessorCreateSettings, ProcessorConfig, consumer.Logs) (LogsProcessor, error)

+ func (f CreateLogsProcessorFunc) CreateLogsProcessor(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (LogsProcessor, error)

+ type CreateLogsReceiverFunc func(context.Context, ReceiverCreateSettings, ReceiverConfig, consumer.Logs) (LogsReceiver, error)

+ func (f CreateLogsReceiverFunc) CreateLogsReceiver(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (LogsReceiver, error)

+ type CreateMetricsExporterFunc func(context.Context, ExporterCreateSettings, ExporterConfig) (MetricsExporter, error)

+ func (f CreateMetricsExporterFunc) CreateMetricsExporter(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (MetricsExporter, error)

+ type CreateMetricsProcessorFunc func(context.Context, ProcessorCreateSettings, ProcessorConfig, consumer.Metrics) (MetricsProcessor, error)

+ func (f CreateMetricsProcessorFunc) CreateMetricsProcessor(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (MetricsProcessor, error)

+ type CreateMetricsReceiverFunc func(context.Context, ReceiverCreateSettings, ReceiverConfig, consumer.Metrics) (MetricsReceiver, error)

+ func (f CreateMetricsReceiverFunc) CreateMetricsReceiver(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (MetricsReceiver, error)

+ type CreateTracesExporterFunc func(context.Context, ExporterCreateSettings, ExporterConfig) (TracesExporter, error)

+ func (f CreateTracesExporterFunc) CreateTracesExporter(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (TracesExporter, error)

+ type CreateTracesProcessorFunc func(context.Context, ProcessorCreateSettings, ProcessorConfig, consumer.Traces) (TracesProcessor, error)

+ func (f CreateTracesProcessorFunc) CreateTracesProcessor(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (TracesProcessor, error)

+ type CreateTracesReceiverFunc func(context.Context, ReceiverCreateSettings, ReceiverConfig, consumer.Traces) (TracesReceiver, error)

+ func (f CreateTracesReceiverFunc) CreateTracesReceiver(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (TracesReceiver, error)

+ type DataType = Type

+ const DataTypeLogs

+ const DataTypeMetrics

+ const DataTypeTraces

+ type Exporter = Component

+ type ExporterConfig interface

+ type ExporterCreateDefaultConfigFunc func() ExporterConfig

+ func (f ExporterCreateDefaultConfigFunc) CreateDefaultConfig() ExporterConfig

+ type ExporterCreateSettings struct

+ BuildInfo BuildInfo

+ type ExporterFactory interface

+ CreateDefaultConfig func() ExporterConfig

+ CreateLogsExporter func(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (LogsExporter, error)

+ CreateMetricsExporter func(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (MetricsExporter, error)

+ CreateTracesExporter func(ctx context.Context, set ExporterCreateSettings, cfg ExporterConfig) (TracesExporter, error)

+ LogsExporterStability func() StabilityLevel

+ MetricsExporterStability func() StabilityLevel

+ TracesExporterStability func() StabilityLevel

+ func NewExporterFactory(cfgType Type, createDefaultConfig ExporterCreateDefaultConfigFunc, ...) ExporterFactory

+ type ExporterFactoryOption interface

+ func WithLogsExporter(createLogsExporter CreateLogsExporterFunc, sl StabilityLevel) ExporterFactoryOption

+ func WithMetricsExporter(createMetricsExporter CreateMetricsExporterFunc, sl StabilityLevel) ExporterFactoryOption

+ func WithTracesExporter(createTracesExporter CreateTracesExporterFunc, sl StabilityLevel) ExporterFactoryOption

+ type Extension = Component

+ type ExtensionConfig interface

+ type ExtensionCreateDefaultConfigFunc func() ExtensionConfig

+ func (f ExtensionCreateDefaultConfigFunc) CreateDefaultConfig() ExtensionConfig

+ type ExtensionCreateSettings struct

+ BuildInfo BuildInfo

+ type ExtensionFactory interface

+ CreateDefaultConfig func() ExtensionConfig

+ CreateExtension func(ctx context.Context, set ExtensionCreateSettings, cfg ExtensionConfig) (Extension, error)

+ ExtensionStability func() StabilityLevel

+ func NewExtensionFactory(cfgType Type, createDefaultConfig ExtensionCreateDefaultConfigFunc, ...) ExtensionFactory

+ type Factories struct

+ Exporters map[Type]ExporterFactory

+ Extensions map[Type]ExtensionFactory

+ Processors map[Type]ProcessorFactory

+ Receivers map[Type]ReceiverFactory

+ type Factory interface

+ Type func() Type

+ type Host interface

+ GetExporters func() map[DataType]map[ID]Component

+ GetExtensions func() map[ID]Component

+ GetFactory func(kind Kind, componentType Type) Factory

+ ReportFatalError func(err error)

+ type ID struct

+ func NewID(typeVal Type) ID

+ func NewIDWithName(typeVal Type, nameVal string) ID

+ func (id *ID) UnmarshalText(text []byte) error

+ func (id ID) MarshalText() (text []byte, err error)

+ func (id ID) Name() string

+ func (id ID) String() string

+ func (id ID) Type() Type

+ type Kind int

+ const KindExporter

+ const KindExtension

+ const KindProcessor

+ const KindReceiver

+ type LogsExporter interface

+ type LogsProcessor interface

+ type LogsReceiver interface

+ type MetricsExporter interface

+ type MetricsProcessor interface

+ type MetricsReceiver interface

+ type PipelineWatcher interface

+ NotReady func() error

+ Ready func() error

+ type Processor = Component

+ type ProcessorConfig interface

+ type ProcessorCreateDefaultConfigFunc func() ProcessorConfig

+ func (f ProcessorCreateDefaultConfigFunc) CreateDefaultConfig() ProcessorConfig

+ type ProcessorCreateSettings struct

+ BuildInfo BuildInfo

+ type ProcessorFactory interface

+ CreateDefaultConfig func() ProcessorConfig

+ CreateLogsProcessor func(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (LogsProcessor, error)

+ CreateMetricsProcessor func(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (MetricsProcessor, error)

+ CreateTracesProcessor func(ctx context.Context, set ProcessorCreateSettings, cfg ProcessorConfig, ...) (TracesProcessor, error)

+ LogsProcessorStability func() StabilityLevel

+ MetricsProcessorStability func() StabilityLevel

+ TracesProcessorStability func() StabilityLevel

+ func NewProcessorFactory(cfgType Type, createDefaultConfig ProcessorCreateDefaultConfigFunc, ...) ProcessorFactory

+ type ProcessorFactoryOption interface

+ func WithLogsProcessor(createLogsProcessor CreateLogsProcessorFunc, sl StabilityLevel) ProcessorFactoryOption

+ func WithMetricsProcessor(createMetricsProcessor CreateMetricsProcessorFunc, sl StabilityLevel) ProcessorFactoryOption

+ func WithTracesProcessor(createTracesProcessor CreateTracesProcessorFunc, sl StabilityLevel) ProcessorFactoryOption

+ type Receiver = Component

+ type ReceiverConfig interface

+ type ReceiverCreateDefaultConfigFunc func() ReceiverConfig

+ func (f ReceiverCreateDefaultConfigFunc) CreateDefaultConfig() ReceiverConfig

+ type ReceiverCreateSettings struct

+ BuildInfo BuildInfo

+ type ReceiverFactory interface

+ CreateDefaultConfig func() ReceiverConfig

+ CreateLogsReceiver func(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (LogsReceiver, error)

+ CreateMetricsReceiver func(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (MetricsReceiver, error)

+ CreateTracesReceiver func(ctx context.Context, set ReceiverCreateSettings, cfg ReceiverConfig, ...) (TracesReceiver, error)

+ LogsReceiverStability func() StabilityLevel

+ MetricsReceiverStability func() StabilityLevel

+ TracesReceiverStability func() StabilityLevel

+ func NewReceiverFactory(cfgType Type, createDefaultConfig ReceiverCreateDefaultConfigFunc, ...) ReceiverFactory

+ type ReceiverFactoryOption interface

+ func WithLogsReceiver(createLogsReceiver CreateLogsReceiverFunc, sl StabilityLevel) ReceiverFactoryOption

+ func WithMetricsReceiver(createMetricsReceiver CreateMetricsReceiverFunc, sl StabilityLevel) ReceiverFactoryOption

+ func WithTracesReceiver(createTracesReceiver CreateTracesReceiverFunc, sl StabilityLevel) ReceiverFactoryOption

+ type ShutdownFunc func(context.Context) error

+ func (f ShutdownFunc) Shutdown(ctx context.Context) error

+ type StabilityLevel int

+ const StabilityLevelAlpha

+ const StabilityLevelBeta

+ const StabilityLevelDeprecated

+ const StabilityLevelDevelopment

+ const StabilityLevelStable

+ const StabilityLevelUndefined

+ const StabilityLevelUnmaintained

+ func (sl StabilityLevel) LogMessage() string

+ func (sl StabilityLevel) String() string

+ type StartFunc func(context.Context, Host) error

+ func (f StartFunc) Start(ctx context.Context, host Host) error

+ type TelemetrySettings struct

+ Logger *zap.Logger

+ MeterProvider metric.MeterProvider

+ MetricsLevel configtelemetry.Level

+ TracerProvider trace.TracerProvider

+ type TracesExporter interface

+ type TracesProcessor interface

+ type TracesReceiver interface

+ type Type string

Other modules containing this package

go.opentelemetry.io/collector

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL