collector

Documentation

Overview

Package collector handles the OpenTelemetry Collector.

Package collector handles the OpenTelemetry Collector.

Index

• Constants
• Variables
• func Annotations(instance v1alpha1.AmazonCloudWatchAgent) map[string]string
• func Build(params manifests.Params) ([]client.Object, error)
• func ConfigMap(params manifests.Params) (*corev1.ConfigMap, error)
• func Container(cfg config.Config, logger logr.Logger, agent v1alpha1.AmazonCloudWatchAgent, ...) corev1.Container
• func DaemonSet(params manifests.Params) *appsv1.DaemonSet
• func Deployment(params manifests.Params) *appsv1.Deployment
• func HeadlessService(params manifests.Params) (*corev1.Service, error)
• func HorizontalPodAutoscaler(params manifests.Params) client.Object
• func Ingress(params manifests.Params) (*networkingv1.Ingress, error)
• func MonitoringService(params manifests.Params) (*corev1.Service, error)
• func PodAnnotations(instance v1alpha1.AmazonCloudWatchAgent) map[string]string
• func PodDisruptionBudget(params manifests.Params) *policyV1.PodDisruptionBudget
• func PodMonitor(params manifests.Params) (*monitoringv1.PodMonitor, error)
• func PortMapToServicePortList(portMap map[int32]corev1.ServicePort) []corev1.ServicePort
• func ReplaceConfig(instance v1alpha1.AmazonCloudWatchAgent) (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
• func ServiceAccountName(instance v1alpha1.AmazonCloudWatchAgent) string
• func ServiceMonitor(params manifests.Params) (*monitoringv1.ServiceMonitor, error)
• func StatefulSet(params manifests.Params) *appsv1.StatefulSet
• func VolumeClaimTemplates(otelcol v1alpha1.AmazonCloudWatchAgent) []corev1.PersistentVolumeClaim
• func Volumes(cfg config.Config, otelcol v1alpha1.AmazonCloudWatchAgent) []corev1.Volume

Constants

const (
	StatsD          = "statsd"
	CollectD        = "collectd"
	XrayProxy       = "aws-proxy"
	XrayTraces      = "aws-traces"
	OtlpGrpc        = "otlp-grpc"
	OtlpHttp        = "otlp-http"
	AppSignalsGrpc  = "appsignals-grpc"
	AppSignalsHttp  = "appsignals-http"
	AppSignalsProxy = "appsignals-xray"
	EMF             = "emf"
	CWA             = "cwa-"
)

const (
	ComponentAmazonCloudWatchAgent = "amazon-cloudwatch-agent"
)

Variables

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 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.