otlp

Documentation

Index

• func Convert(entries []*entry.Entry) pdata.Logs
• type HTTPClientConfig
  • func NewHTTPClientConfig() HTTPClientConfig
  • func (c *HTTPClientConfig) UnmarshalJSON(data []byte) error
  • func (c *HTTPClientConfig) UnmarshalYAML(unmarshal func(interface{}) error) error
• type OTLPOutput
  • func (o *OTLPOutput) Process(ctx context.Context, entry *entry.Entry) error
  • func (o *OTLPOutput) ProcessMulti(ctx context.Context, entries []*entry.Entry) error
  • func (o *OTLPOutput) Start() error
  • func (o *OTLPOutput) Stop() error
• type OTLPOutputConfig
  • func NewOTLPOutputConfig(operatorID string) *OTLPOutputConfig
  • func (c OTLPOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Functions

func Convert

func Convert(entries []*entry.Entry) pdata.Logs

Convert converts a slice of entries to pdata.Logs format

Types

type HTTPClientConfig

type HTTPClientConfig struct {
	confighttp.HTTPClientSettings
}

HTTPClientConfig makes confighttp.HTTPClientSettings marshallable with json and yaml

func NewHTTPClientConfig

func NewHTTPClientConfig() HTTPClientConfig

NewHTTPClientConfig creates a new default config

func (*HTTPClientConfig) UnmarshalJSON

func (c *HTTPClientConfig) UnmarshalJSON(data []byte) error

UnmarshalJSON will unmarshal json into a HTTPClientConfig struct

func (*HTTPClientConfig) UnmarshalYAML

func (c *HTTPClientConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML will unmarshal json into a HTTPClientConfig struct

type OTLPOutput

type OTLPOutput struct {
	helper.OutputOperator
	// contains filtered or unexported fields
}

OTLPOutput is an operator that sends entries to the OTLP recevier

func (*OTLPOutput) Process

func (o *OTLPOutput) Process(ctx context.Context, entry *entry.Entry) error

Process adds an entry to the output's buffer

func (*OTLPOutput) ProcessMulti

func (o *OTLPOutput) ProcessMulti(ctx context.Context, entries []*entry.Entry) error

ProcessMulti will send a chunk of entries

func (*OTLPOutput) Start

func (o *OTLPOutput) Start() error

Start flushing entries

func (*OTLPOutput) Stop

func (o *OTLPOutput) Stop() error

Stop tells the OTLPOutput to stop gracefully

type OTLPOutputConfig

type OTLPOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`
	BufferConfig        buffer.Config  `json:"buffer" yaml:"buffer"`
	FlusherConfig       flusher.Config `json:"flusher" yaml:"flusher"`
	HTTPClientConfig    `yaml:",inline"`
}

OTLPOutputConfig is the configuration of a OTLPOutput operator

func NewOTLPOutputConfig

func NewOTLPOutputConfig(operatorID string) *OTLPOutputConfig

NewOTLPOutputConfig creates a new elastic output config with default values

func (OTLPOutputConfig) Build

func (c OTLPOutputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a new OTLPOutput