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(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *corev1.ConfigMap
- func Container(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector, ...) corev1.Container
- func ConvertToV2Beta2HPAScalingPolicy(v2policy autoscalingv2.HPAScalingPolicy) autoscalingv2beta2.HPAScalingPolicy
- func ConvertToV2Beta2PodMetrics(v2metrics []v1alpha1.MetricSpec) []autoscalingv2beta2.MetricSpec
- func ConvertToV2Beta2SelectPolicy(scalingPolicy autoscalingv2.ScalingPolicySelect) autoscalingv2beta2.ScalingPolicySelect
- func ConvertToV2beta2Behavior(v2behavior autoscalingv2.HorizontalPodAutoscalerBehavior) autoscalingv2beta2.HorizontalPodAutoscalerBehavior
- func DaemonSet(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *appsv1.DaemonSet
- func Deployment(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *appsv1.Deployment
- func HeadlessService(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *corev1.Service
- func HorizontalPodAutoscaler(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) client.Object
- func Ingress(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *networkingv1.Ingress
- func Labels(instance v1alpha1.OpenTelemetryCollector, name string, filterLabels []string) map[string]string
- func MonitoringService(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *corev1.Service
- func PodAnnotations(instance v1alpha1.OpenTelemetryCollector) map[string]string
- func ReplaceConfig(instance v1alpha1.OpenTelemetryCollector) (string, error)
- func Routes(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) []*routev1.Route
- func SelectorLabels(instance v1alpha1.OpenTelemetryCollector) map[string]string
- func Service(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *corev1.Service
- func ServiceAccount(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *corev1.ServiceAccount
- func ServiceAccountName(instance v1alpha1.OpenTelemetryCollector) string
- func ServiceMonitor(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) (*monitoringv1.ServiceMonitor, error)
- func StatefulSet(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *appsv1.StatefulSet
- func VolumeClaimTemplates(otelcol v1alpha1.OpenTelemetryCollector) []corev1.PersistentVolumeClaim
- func Volumes(cfg config.Config, otelcol v1alpha1.OpenTelemetryCollector) []corev1.Volume
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Annotations ¶
func Annotations(instance v1alpha1.OpenTelemetryCollector) map[string]string
Annotations return the annotations for OpenTelemetryCollector pod.
func Build ¶
Build is currently unused, but will be implemented to solve https://github.com/open-telemetry/opentelemetry-operator/issues/1876
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 ConvertToV2Beta2HPAScalingPolicy ¶
func ConvertToV2Beta2HPAScalingPolicy(v2policy autoscalingv2.HPAScalingPolicy) autoscalingv2beta2.HPAScalingPolicy
func ConvertToV2Beta2PodMetrics ¶
func ConvertToV2Beta2PodMetrics(v2metrics []v1alpha1.MetricSpec) []autoscalingv2beta2.MetricSpec
func ConvertToV2Beta2SelectPolicy ¶
func ConvertToV2Beta2SelectPolicy(scalingPolicy autoscalingv2.ScalingPolicySelect) autoscalingv2beta2.ScalingPolicySelect
func ConvertToV2beta2Behavior ¶
func ConvertToV2beta2Behavior(v2behavior autoscalingv2.HorizontalPodAutoscalerBehavior) autoscalingv2beta2.HorizontalPodAutoscalerBehavior
Create a v2beta2 HorizontalPodAutoscalerBehavior from a v2 instance.
func DaemonSet ¶
func DaemonSet(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *appsv1.DaemonSet
DaemonSet builds the deployment for the given instance.
func Deployment ¶
func Deployment(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *appsv1.Deployment
Deployment builds the deployment for the given instance.
func HeadlessService ¶
func HorizontalPodAutoscaler ¶
func Ingress ¶
func Ingress(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *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 PodAnnotations ¶
func PodAnnotations(instance v1alpha1.OpenTelemetryCollector) map[string]string
PodAnnotations return the spec annotations for OpenTelemetryCollector pod.
func ReplaceConfig ¶
func ReplaceConfig(instance v1alpha1.OpenTelemetryCollector) (string, error)
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 ServiceAccount ¶
func ServiceAccount(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *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(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) (*monitoringv1.ServiceMonitor, error)
ServiceMonitor returns the service account for the given instance.
func StatefulSet ¶
func StatefulSet(cfg config.Config, logger logr.Logger, otelcol v1alpha1.OpenTelemetryCollector) *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.
Types ¶
type Config ¶
type Config struct { PromConfig *promconfig.Config `yaml:"config"` TargetAllocConfig *targetAllocator `yaml:"target_allocator,omitempty"` }