statussources

Documentation

Index

• Variables
• func MetricsToReceiverIDs(md pmetric.Metrics) (component.ID, observer.EndpointID)
• func NewZapCoreEncoder() zapcore.Encoder
• func ReceiverNameToIDs(record plog.LogRecord) (receiverID component.ID, endpointID observer.EndpointID)
• type Statement
  • func StatementFromZapCoreEntry(encoder zapcore.Encoder, entry zapcore.Entry, fields []zapcore.Field) (*Statement, error)
  • func (s *Statement) ToLogRecord() plog.LogRecord

Variables

var (
	ReceiverCreatorRegexp = regexp.MustCompile(`receiver_creator/`)

	EndpointTargetRegexp = regexp.MustCompile(`{endpoint=[^}]*}/`)
)

Functions

func MetricsToReceiverIDs

func MetricsToReceiverIDs(md pmetric.Metrics) (component.ID, observer.EndpointID)

MetricsToReceiverIDs extracts the identifiers receiver creator created receivers will embed in their attributes

func NewZapCoreEncoder

func NewZapCoreEncoder() zapcore.Encoder

func ReceiverNameToIDs

func ReceiverNameToIDs(record plog.LogRecord) (receiverID component.ID, endpointID observer.EndpointID)

ReceiverNameToIDs parses the zap "name" field value according to outcome of https://github.com/open-telemetry/opentelemetry-collector-contrib/pull/12670 where receiver creator receiver names are of the form `<receiver.type>/<receiver.name>/receiver_creator/<receiver-creator.name>{endpoint="<Endpoint.Target>"}/<Endpoint.ID>`. If receiverName argument is not of this form empty Component and Endpoint IDs are returned.

Types

type Statement

type Statement struct {
	Message    string
	Fields     map[string]any
	Level      string
	Time       time.Time
	LoggerName string
	Caller     zapcore.EntryCaller
	Stack      string
}

Statement models a zapcore.Entry but defined here for usability/maintainability

func StatementFromZapCoreEntry

func StatementFromZapCoreEntry(encoder zapcore.Encoder, entry zapcore.Entry, fields []zapcore.Field) (*Statement, error)

StatementFromZapCoreEntry converts the Entry to a Statement using the provided encoder, which is assumed to be a JSONEncoder (unexpected from zapcore) to obtain the target Fields.

func (*Statement) ToLogRecord

func (s *Statement) ToLogRecord() plog.LogRecord