eks

README

EKS enricher

This EKS enricher follows the Standardize Tagging documentation.

Static Tags

Static tags are tags that do not change during runtime. These values are parsed as environment variables in mappings.go.

These are the following tags that are being enriched:

Resource

• cloud.partition
• cloud.account.id
• cloud.account.name
• cloud.region
• cloud.account.function
• organization
• cloud.provider
• cloud.platform

Kubernetes

• cluster.name

Dropping logs

EKS enricher is dropping logs if log field is empty.

Missing Kubernetes Metadata

Refer to this investigation.

EKS enricher is currently mitigating this issue by adding container_name with _missing_metadata.

Documentation

Index

• type Enricher
  • func NewEnricher(cfgs ...EnricherConfiguration) (*Enricher, error)
  • func (e *Enricher) AddDropCount()
  • func (e *Enricher) AddRecordCount(record map[interface{}]interface{}, logType LogType)
  • func (e *Enricher) EnrichRecord(r map[interface{}]interface{}, t time.Time) map[interface{}]interface{}
• type EnricherConfiguration
  • func WithMetricServer(ms *metricserver.MetricServer) EnricherConfiguration
• type EnricherMetric
• type LogType

Types

type Enricher

type Enricher struct {
	CloudAccountId            string `env:"CLOUD_ACCOUNT_ID,required"`
	CloudAccountName          string `env:"CLOUD_ACCOUNT_NAME,required"`
	CloudRegion               string `env:"CLOUD_REGION,required"`
	K8sClusterName            string `env:"K8S_CLUSTER_NAME,required"`
	K8sNodeName               string `env:"K8S_NODE_NAME,required"`
	CloudPartition            string `env:"CLOUD_PARTITION,required"`
	CloudAccountGroupFunction string `env:"CLOUD_ACCOUNT_GROUP_FUNCTION,required"`
	Organization              string `env:"ORGANIZATION,required"`
	CloudProvider             string `env:"CLOUD_PROVIDER,required"`
	CloudPlatform             string `env:"CLOUD_PLATFORM,required"`
	// contains filtered or unexported fields
}

func NewEnricher

func NewEnricher(cfgs ...EnricherConfiguration) (*Enricher, error)

NewEnricher returns a enricher with env vars being parsed. These env vars are derived from mappings.go.

func (*Enricher) AddDropCount

func (e *Enricher) AddDropCount()

func (*Enricher) AddRecordCount

func (e *Enricher) AddRecordCount(record map[interface{}]interface{}, logType LogType)

func (*Enricher) EnrichRecord

func (e *Enricher) EnrichRecord(r map[interface{}]interface{}, t time.Time) map[interface{}]interface{}

type EnricherConfiguration

type EnricherConfiguration func(*Enricher) error

func WithMetricServer

func WithMetricServer(ms *metricserver.MetricServer) EnricherConfiguration

type EnricherMetric

type EnricherMetric struct {
	// contains filtered or unexported fields
}

type LogType

type LogType int

const (
	TYPE_EMPTY LogType = iota + 1
	TYPE_APPLICATION
	TYPE_HOST
)

Log type