lokireceiver

README

Loki Receiver

Status
Stability	alpha: logs
Distributions	contrib, sumo
Issues
Code Owners	@mar4uk, @jpkrohling

The Loki receiver implements the Loki push api as specified here. It allows Promtail instances to specify the open telemetry collector as their lokiAddress.

This receiver runs HTTP and GRPC servers to ingest log entries in Loki format.

Getting Started

The settings are:

• endpoint (required, default = 0.0.0.0:3500 for HTTP protocol, 0.0.0.0:3600 gRPC protocol): host:port to which the receiver is going to receive data.
• use_incoming_timestamp (optional, default = false) if set true the timestamp from Loki log entry is used

Example:

receivers:
  loki:
    protocols:
      http:
      grpc:
    use_incoming_timestamp: true

Documentation

Index

• Constants
• func NewFactory() receiver.Factory
• type Config
  • func (cfg *Config) Unmarshal(conf *confmap.Conf) error
  • func (cfg *Config) Validate() error
• type Protocols

Constants

const ErrAtLeastOneEntryFailedToProcess = "at least one entry in the push request failed to process"

Functions

func NewFactory

func NewFactory() receiver.Factory

NewFactory return a new receiver.Factory for loki receiver.

Types

type Config

type Config struct {
	// Protocols is the configuration for the supported protocols, currently gRPC and HTTP (Proto and JSON).
	Protocols     `mapstructure:"protocols"`
	KeepTimestamp bool `mapstructure:"use_incoming_timestamp"`
}

Config defines configuration for the lokireceiver receiver.

func (*Config) Unmarshal

func (cfg *Config) Unmarshal(conf *confmap.Conf) error

Unmarshal a confmap.Conf into the config struct.

func (*Config) Validate

func (cfg *Config) Validate() error

Validate checks the receiver configuration is valid

type Protocols

type Protocols struct {
	GRPC *configgrpc.GRPCServerSettings `mapstructure:"grpc"`
	HTTP *confighttp.HTTPServerSettings `mapstructure:"http"`
}

Protocols is the configuration for the supported protocols.