eks

package

v1.10.15 Latest Latest Go to latest Published: Jun 20, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/canva/amazon-kinesis-streams-for-fluent-bit

Links

Open Source Insights

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)
type EnricherConfiguration
- func WithMetricServer(ms *metricserver.MetricServer) EnricherConfiguration
type EnricherMetric
type LogType

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v1.10.15

func (e *Enricher) AddDropCount()

func (*Enricher) AddRecordCount ¶ added in v1.10.15

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 ¶ added in v1.10.15

type EnricherConfiguration func(*Enricher) error

func WithMetricServer ¶ added in v1.10.15

func WithMetricServer(ms *metricserver.MetricServer) EnricherConfiguration

type EnricherMetric ¶ added in v1.10.15

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

type LogType ¶ added in v1.10.15

type LogType int

const (
	TYPE_EMPTY LogType = iota + 1
	TYPE_APPLICATION
	TYPE_HOST
)

Log type

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL