collector

Documentation

Overview

Package collector handles the OpenTelemetry Collector.

Package collector handles the OpenTelemetry Collector.

Index

• func Annotations(instance v1alpha1.OpenTelemetryCollector) map[string]string
• func Build(params manifests.Params) ([]client.Object, error)
• func ConfigMap(params manifests.Params) *corev1.ConfigMap
• func Container(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector, ...) corev1.Container
• func DaemonSet(params manifests.Params) *appsv1.DaemonSet
• func Deployment(params manifests.Params) *appsv1.Deployment
• func HeadlessService(params manifests.Params) *corev1.Service
• func HorizontalPodAutoscaler(params manifests.Params) client.Object
• func Ingress(params manifests.Params) *networkingv1.Ingress
• func Labels(instance v1alpha1.OpenTelemetryCollector, name string, filterLabels []string) map[string]string
• func MonitoringService(params manifests.Params) *corev1.Service
• func PodAnnotations(instance v1alpha1.OpenTelemetryCollector) map[string]string
• func PodDisruptionBudget(params manifests.Params) client.Object
• func ReplaceConfig(instance v1alpha1.OpenTelemetryCollector) (string, error)
• func Routes(params manifests.Params) []*routev1.Route
• func SelectorLabels(instance v1alpha1.OpenTelemetryCollector) map[string]string
• func Service(params manifests.Params) *corev1.Service
• func ServiceAccount(params manifests.Params) *corev1.ServiceAccount
• func ServiceAccountName(instance v1alpha1.OpenTelemetryCollector) string
• func ServiceMonitor(params manifests.Params) (*monitoringv1.ServiceMonitor, error)
• func StatefulSet(params manifests.Params) *appsv1.StatefulSet
• func VolumeClaimTemplates(otelcol v1alpha1.OpenTelemetryCollector) []corev1.PersistentVolumeClaim
• func Volumes(cfg config.Config, otelcol v1alpha1.OpenTelemetryCollector) []corev1.Volume
• type Config

Functions

func Annotations

func Annotations(instance v1alpha1.OpenTelemetryCollector) map[string]string

Annotations return the annotations for OpenTelemetryCollector pod.

func Build

func Build(params manifests.Params) ([]client.Object, error)

Build creates the manifest for the collector resource.

func ConfigMap

func ConfigMap(params manifests.Params) *corev1.ConfigMap

func Container

func Container(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector, addConfig bool) corev1.Container

Container builds a container for the given collector.

func DaemonSet

func DaemonSet(params manifests.Params) *appsv1.DaemonSet

DaemonSet builds the deployment for the given instance.

func Deployment

func Deployment(params manifests.Params) *appsv1.Deployment

Deployment builds the deployment for the given instance.

func HeadlessService

func HeadlessService(params manifests.Params) *corev1.Service

func HorizontalPodAutoscaler

func HorizontalPodAutoscaler(params manifests.Params) client.Object

func Ingress

func Ingress(params manifests.Params) *networkingv1.Ingress

func Labels

func Labels(instance v1alpha1.OpenTelemetryCollector, name string, filterLabels []string) map[string]string

Labels return the common labels to all objects that are part of a managed OpenTelemetryCollector.

func MonitoringService

func MonitoringService(params manifests.Params) *corev1.Service

func PodAnnotations

func PodAnnotations(instance v1alpha1.OpenTelemetryCollector) map[string]string

PodAnnotations return the spec annotations for OpenTelemetryCollector pod.

func PodDisruptionBudget

func PodDisruptionBudget(params manifests.Params) client.Object

func ReplaceConfig

func ReplaceConfig(instance v1alpha1.OpenTelemetryCollector) (string, error)

func Routes

func Routes(params manifests.Params) []*routev1.Route

func SelectorLabels

func SelectorLabels(instance v1alpha1.OpenTelemetryCollector) map[string]string

SelectorLabels return the common labels to all objects that are part of a managed OpenTelemetryCollector to use as selector. Selector labels are immutable for Deployment, StatefulSet and DaemonSet, therefore, no labels in selector should be expected to be modified for the lifetime of the object.

func Service

func Service(params manifests.Params) *corev1.Service

func ServiceAccount

func ServiceAccount(params manifests.Params) *corev1.ServiceAccount

ServiceAccount returns the service account for the given instance.

func ServiceAccountName

func ServiceAccountName(instance v1alpha1.OpenTelemetryCollector) string

ServiceAccountName returns the name of the existing or self-provisioned service account to use for the given instance.

func ServiceMonitor

func ServiceMonitor(params manifests.Params) (*monitoringv1.ServiceMonitor, error)

ServiceMonitor returns the service monitor for the given instance.

func StatefulSet

func StatefulSet(params manifests.Params) *appsv1.StatefulSet

StatefulSet builds the statefulset for the given instance.

func VolumeClaimTemplates

func VolumeClaimTemplates(otelcol v1alpha1.OpenTelemetryCollector) []corev1.PersistentVolumeClaim

VolumeClaimTemplates builds the volumeClaimTemplates for the given instance, including the config map volume mount.

func Volumes

func Volumes(cfg config.Config, otelcol v1alpha1.OpenTelemetryCollector) []corev1.Volume

Volumes builds the volumes for the given instance, including the config map volume.

Types

type Config

type Config struct {
	PromConfig        *promconfig.Config `yaml:"config"`
	TargetAllocConfig *targetAllocator   `yaml:"target_allocator,omitempty"`
}