Add memory_limiter and GOMEMLIMIT

Makefile

@@ -143,7 +143,7 @@ endif
 
 .PHONY: install
 install: manifests kustomize ## Install CRDs into the K8s cluster specified in ~/.kube/config.
-	$(KUSTOMIZE) build config/crd | $(KUBECTL) apply -f -
+	$(KUSTOMIZE) build config/crd | $(KUBECTL) apply --server-side -f -
 
 .PHONY: uninstall
 uninstall: manifests kustomize ## Uninstall CRDs from the K8s cluster specified in ~/.kube/config. Call with ignore-not-found=true to ignore resource not found errors during deletion.
@@ -152,7 +152,7 @@ uninstall: manifests kustomize ## Uninstall CRDs from the K8s cluster specified
 .PHONY: deploy
 deploy: manifests kustomize ## Deploy controller to the K8s cluster specified in ~/.kube/config.
 	cd config/manager && $(KUSTOMIZE) edit set image controller=${IMG}
-	$(KUSTOMIZE) build config/default | $(KUBECTL) apply -f -
+	$(KUSTOMIZE) build config/default | $(KUBECTL) apply --server-side -f -
 
 .PHONY: undeploy
 undeploy: ## Undeploy controller from the K8s cluster specified in ~/.kube/config. Call with ignore-not-found=true to ignore resource not found errors during deletion.

api/telemetry/v1alpha1/collector_types.go

@@ -15,16 +15,67 @@
 package v1alpha1
 
 import (
+	"time"
+
+	"github.com/cisco-open/operator-tools/pkg/typeoverride"
+	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
+type MemoryLimiter struct {
+	// From 	go.opentelemetry.io/collector/processor/memorylimiterprocessor
+
+	// CheckInterval is the time between measurements of memory usage for the
+	// purposes of avoiding going over the limits. Defaults to zero, so no
+	// checks will be performed.
+	CheckInterval time.Duration `json:"check_interval"`
+
+	// MemoryLimitMiB is the maximum amount of memory, in MiB, targeted to be
+	// allocated by the process.
+	MemoryLimitMiB uint32 `json:"limit_mib"`
+
+	// MemorySpikeLimitMiB is the maximum, in MiB, spike expected between the
+	// measurements of memory usage.
+	MemorySpikeLimitMiB uint32 `json:"spike_limit_mib"`
+
+	// MemoryLimitPercentage is the maximum amount of memory, in %, targeted to be
+	// allocated by the process. The fixed memory settings MemoryLimitMiB has a higher precedence.
+	MemoryLimitPercentage uint32 `json:"limit_percentage"`
+
+	// MemorySpikePercentage is the maximum, in percents against the total memory,
+	// spike expected between the measurements of memory usage.
+	MemorySpikePercentage uint32 `json:"spike_limit_percentage"`
+}
+
 // CollectorSpec defines the desired state of Collector
 type CollectorSpec struct {
 	TenantSelector metav1.LabelSelector `json:"tenantSelector,omitempty"`
 	// Namespace where OTel collector DaemonSet is deployed
 	ControlNamespace string `json:"controlNamespace"`
 	// Enables debug logging for the collector
 	Debug bool `json:"debug,omitempty"`
+	// Setting memory limits for the Collector
+	MemoryLimiter      *MemoryLimiter          `json:"memoryLimiter,omitempty"`
+	DaemonSetOverrides *typeoverride.DaemonSet `json:"daemonSet,omitempty"`
+}
+
+func (c *CollectorSpec) SetDefaults() {
+	if c.MemoryLimiter == nil {
+		c.MemoryLimiter = &MemoryLimiter{
+			CheckInterval:         1 * time.Second,
+			MemoryLimitPercentage: 75,
+			MemorySpikeLimitMiB:   25,
+		}
+	}
+}
+
+func (c CollectorSpec) GetMemoryLimit() *resource.Quantity {
+	if c.DaemonSetOverrides != nil && len(c.DaemonSetOverrides.Spec.Template.Spec.Containers) > 0 {
+		if memoryLimit := c.DaemonSetOverrides.Spec.Template.Spec.Containers[0].Resources.Limits.Memory(); !memoryLimit.IsZero() {
+			return memoryLimit
+		}
+	}
+	return nil
 }
 
 // CollectorStatus defines the observed state of Collector