collector

Documentation

Overview

Package collector handles the OpenTelemetry Collector.

Package collector handles the OpenTelemetry Collector.

Index

• Constants
• func Build(params manifests.Params) ([]client.Object, error)
• func ClusterRole(params manifests.Params) (*rbacv1.ClusterRole, error)
• func ClusterRoleBinding(params manifests.Params) (*rbacv1.ClusterRoleBinding, error)
• func ConfigMap(params manifests.Params) (*corev1.ConfigMap, error)
• func Container(cfg config.Config, logger logr.Logger, otelcol v1beta1.OpenTelemetryCollector, ...) corev1.Container
• func DaemonSet(params manifests.Params) (*appsv1.DaemonSet, error)
• func Deployment(params manifests.Params) (*appsv1.Deployment, error)
• func HeadlessService(params manifests.Params) (*corev1.Service, error)
• func HorizontalPodAutoscaler(params manifests.Params) (*autoscalingv2.HorizontalPodAutoscaler, error)
• func Ingress(params manifests.Params) (*networkingv1.Ingress, error)
• func MonitoringService(params manifests.Params) (*corev1.Service, error)
• func PodDisruptionBudget(params manifests.Params) (*policyV1.PodDisruptionBudget, error)
• func PodMonitor(params manifests.Params) (*monitoringv1.PodMonitor, error)
• func ReplaceConfig(instance v1beta1.OpenTelemetryCollector) (string, error)
• func Routes(params manifests.Params) ([]*routev1.Route, error)
• func Service(params manifests.Params) (*corev1.Service, error)
• func ServiceAccount(params manifests.Params) (*corev1.ServiceAccount, error)
• func ServiceAccountName(instance v1beta1.OpenTelemetryCollector) string
• func ServiceMonitor(params manifests.Params) (*monitoringv1.ServiceMonitor, error)
• func ServiceMonitorMonitoring(params manifests.Params) (*monitoringv1.ServiceMonitor, error)
• func StatefulSet(params manifests.Params) (*appsv1.StatefulSet, error)
• func TargetAllocator(params manifests.Params) (*v1alpha1.TargetAllocator, error)
• func VolumeClaimTemplates(otelcol v1beta1.OpenTelemetryCollector) []corev1.PersistentVolumeClaim
• func Volumes(cfg config.Config, otelcol v1beta1.OpenTelemetryCollector) []corev1.Volume
• type Config
• type PortNumberKey
• type ServiceType
  • func (s ServiceType) String() string

Constants

const (
	ComponentOpenTelemetryCollector = "opentelemetry-collector"
)

Functions

func Build

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

Build creates the manifest for the collector resource.

func ClusterRole

func ClusterRole(params manifests.Params) (*rbacv1.ClusterRole, error)

func ClusterRoleBinding

func ClusterRoleBinding(params manifests.Params) (*rbacv1.ClusterRoleBinding, error)

func ConfigMap

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

func Container

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

Container builds a container for the given collector.

func DaemonSet

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

DaemonSet builds the deployment for the given instance.

func Deployment

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

Deployment builds the deployment for the given instance.

func HeadlessService

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

func HorizontalPodAutoscaler

func HorizontalPodAutoscaler(params manifests.Params) (*autoscalingv2.HorizontalPodAutoscaler, error)

func Ingress

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

func MonitoringService

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

func PodDisruptionBudget

func PodDisruptionBudget(params manifests.Params) (*policyV1.PodDisruptionBudget, error)

func PodMonitor

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

PodMonitor returns the pod monitor for the given instance.

func ReplaceConfig

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

func Routes

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

func Service

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

func ServiceAccount

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

ServiceAccount returns the service account for the given instance.

func ServiceAccountName

func ServiceAccountName(instance v1beta1.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 collector.

func ServiceMonitorMonitoring

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

ServiceMonitor returns the service monitor for the monitoring service of the collector.

func StatefulSet

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

StatefulSet builds the statefulset for the given instance.

func TargetAllocator

func TargetAllocator(params manifests.Params) (*v1alpha1.TargetAllocator, error)

TargetAllocator builds the TargetAllocator CR for the given instance.

func VolumeClaimTemplates

func VolumeClaimTemplates(otelcol v1beta1.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 v1beta1.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"`
}

type PortNumberKey

type PortNumberKey struct {
	Port     int32
	Protocol corev1.Protocol
}

type ServiceType

type ServiceType int

const (
	BaseServiceType ServiceType = iota
	HeadlessServiceType
	MonitoringServiceType
)

func (ServiceType) String

func (s ServiceType) String() string