collector

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Overview

Package collector handles the OpenTelemetry Collector.

Package collector handles the OpenTelemetry Collector.

Index

Constants

View Source
const (
	StatsD             = "statsd"
	CollectD           = "collectd"
	XrayProxy          = "aws-proxy"
	XrayTraces         = "aws-traces"
	OtlpGrpc           = "otlp-grpc"
	OtlpHttp           = "otlp-http"
	AppSignalsGrpc     = "appsig-grpc"
	AppSignalsHttp     = "appsig-http"
	AppSignalsProxy    = "appsig-xray"
	AppSignalsGrpcSA   = ":4315"
	AppSignalsHttpSA   = ":4316"
	AppSignalsProxySA  = ":2000"
	AppSignalsServerSA = ":4311"
	EMF                = "emf"
	EMFTcp             = "emf-tcp"
	EMFUdp             = "emf-udp"
	CWA                = "cwa-"
	JmxHttp            = "jmx-http"
	Server             = "server"
)
View Source
const (
	ComponentAmazonCloudWatchAgent = "amazon-cloudwatch-agent"
)

Variables

View Source
var AppSignalsPortToServicePortMap = map[int32][]corev1.ServicePort{
	4315: {{
		Name: AppSignalsGrpc,
		Port: 4315,
	}},
	4316: {{
		Name: AppSignalsHttp,
		Port: 4316,
	}},
	2000: {{
		Name: AppSignalsProxy,
		Port: 2000,
	}},
}

Functions

func Annotations

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

Annotations return the annotations for AmazonCloudWatchAgent 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, error)

func Container

func Container(cfg config.Config, logger logr.Logger, agent v1alpha1.AmazonCloudWatchAgent, 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, error)

func HorizontalPodAutoscaler

func HorizontalPodAutoscaler(params manifests.Params) client.Object

func Ingress

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

func MonitoringService

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

func PodAnnotations

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

PodAnnotations return the spec annotations for AmazonCloudWatchAgent pod.

func PodDisruptionBudget

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

func PodMonitor

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

ServiceMonitor returns the service monitor for the given instance.

func PortMapToServicePortList

func PortMapToServicePortList(portMap map[int32][]corev1.ServicePort) []corev1.ServicePort

func ReplaceConfig

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

func ReplaceOtelConfig added in v1.8.0

func ReplaceOtelConfig(instance v1alpha1.AmazonCloudWatchAgent) (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

ServiceAccount returns the service account for the given instance.

func ServiceAccountName

func ServiceAccountName(instance v1alpha1.AmazonCloudWatchAgent) 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.AmazonCloudWatchAgent) []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.AmazonCloudWatchAgent) []corev1.Volume

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

Types

This section is empty.

Directories

Path Synopsis
Package adapters is for data conversion.
Package adapters is for data conversion.

Jump to

Keyboard shortcuts

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