otlp

Documentation

Index

• Constants
• func FormatResourceLog(id string, inputs []string) Element
• func GroupByContainer(id string, inputs []string) Element
• func GroupByHost(id string, inputs []string) Element
• func GroupBySource(id string, inputs []string) Element
• func MakeGroupBys(fields ...string) string
• func New(id string, o obs.OutputSpec, inputs []string, secrets observability.Secrets, ...) []Element
• func RouteBySource(id string, inputs []string) Element
• func TransformAuditHost(id string, inputs []string) Element
• func TransformAuditKube(id string, inputs []string) Element
• func TransformAuditOpenshift(id string, inputs []string) Element
• func TransformAuditOvn(id string, inputs []string) Element
• func TransformContainer(id string, inputs []string) Element
• func TransformJournal(id string, inputs []string) Element
• type Otlp
  • func Output(id string, o obs.OutputSpec, inputs []string, secrets observability.Secrets, ...) *Otlp
  • func (p Otlp) Name() string
  • func (p *Otlp) SetCompression(algo string)
  • func (p Otlp) Template() string
• type Reduce
  • func (r Reduce) Name() string
  • func (r Reduce) Template() string

Constants

const (
	BaseResourceAttributes = `` /* 645-byte string literal not displayed */

	ContainerResourceAttributes = `` /* 611-byte string literal not displayed */

	LogRecord = `` /* 241-byte string literal not displayed */

	LogRecordSeverity = `
r.severityText = .level
`
	BodyFromMessage = `` /* 165-byte string literal not displayed */

	BodyFromInternal = `
# Create body from internal message
r.body = {"stringValue": to_string!(get!(.,["_internal","message"]))}
`
	APILogAttributes = `` /* 1640-byte string literal not displayed */

	LogAttributes          = ``
	ContainerLogAttributes = `` /* 183-byte string literal not displayed */

	NodeResourceAttributes = `` /* 443-byte string literal not displayed */

	NodeLogAttributes = `` /* 491-byte string literal not displayed */

	FinalGrouping = `` /* 259-byte string literal not displayed */

	FinalGroupingContainers = `` /* 443-byte string literal not displayed */

	// The (M)inimum (V)iable (P)roduct Labels (MVP)
	BackwardCompatBaseResourceAttributes = `` /* 396-byte string literal not displayed */

	BackwardCompatContainerResourceAttributes = `` /* 384-byte string literal not displayed */

)

VRL for OTLP transforms by route

Functions

func FormatResourceLog

func FormatResourceLog(id string, inputs []string) Element

FormatResourceLog Drops everything except resource.attributes and scopeLogs.logRecords

func GroupByContainer

func GroupByContainer(id string, inputs []string) Element

func GroupByHost

func GroupByHost(id string, inputs []string) Element

func GroupBySource

func GroupBySource(id string, inputs []string) Element

func MakeGroupBys

func MakeGroupBys(fields ...string) string

func New

func New(id string, o obs.OutputSpec, inputs []string, secrets observability.Secrets, strategy common.ConfigStrategy, op Options) []Element

func RouteBySource

func RouteBySource(id string, inputs []string) Element

func TransformAuditHost

func TransformAuditHost(id string, inputs []string) Element

func TransformAuditKube

func TransformAuditKube(id string, inputs []string) Element

func TransformAuditOpenshift

func TransformAuditOpenshift(id string, inputs []string) Element

func TransformAuditOvn

func TransformAuditOvn(id string, inputs []string) Element

func TransformContainer

func TransformContainer(id string, inputs []string) Element

func TransformJournal

func TransformJournal(id string, inputs []string) Element

Types

type Otlp

type Otlp struct {
	ComponentID      string
	Inputs           string
	URI              string
	common.RootMixin //TODO: remove??
}

func Output

func Output(id string, o obs.OutputSpec, inputs []string, secrets observability.Secrets, op Options) *Otlp

func (Otlp) Name

func (p Otlp) Name() string

func (*Otlp) SetCompression

func (p *Otlp) SetCompression(algo string)

TODO: test this for otlp

func (Otlp) Template

func (p Otlp) Template() string

type Reduce

type Reduce struct {
	ComponentID string
	Desc        string
	Inputs      string
	GroupBy     string
	MaxEvents   string
}

func (Reduce) Name

func (r Reduce) Name() string

func (Reduce) Template

func (r Reduce) Template() string