controllers

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2026 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EgressMITMCAPoolRef

func EgressMITMCAPoolRef(systemNamespace string) types.NamespacedName

EgressMITMCAPoolRef names the Secret holding the CA pool the egress gateway signs per-SNI leaves with.

Types

type EgressMITMTrustReconciler

type EgressMITMTrustReconciler struct {
	client.Client

	// SystemNamespace is the namespace holding the egress MITM CA pool Secret.
	SystemNamespace string
	// contains filtered or unexported fields
}

EgressMITMTrustReconciler derives a ClusterTrustBundle from the egress MITM CA pool.

func (*EgressMITMTrustReconciler) Reconcile

func (*EgressMITMTrustReconciler) SetupWithManager

func (r *EgressMITMTrustReconciler) SetupWithManager(mgr ctrl.Manager) error

type NetworkPolicyReconciler

type NetworkPolicyReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	// SystemNamespace is the namespace atenet-router runs in. The generated
	// ingress policy admits only that namespace, so a value that does not
	// match the running router blocks every request to the worker pool.
	SystemNamespace string
}

func (*NetworkPolicyReconciler) Reconcile

func (r *NetworkPolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*NetworkPolicyReconciler) SetupWithManager

func (r *NetworkPolicyReconciler) SetupWithManager(mgr ctrl.Manager) error

type WorkerPoolReconciler

type WorkerPoolReconciler struct {
	client.Client
	Scheme       *runtime.Scheme
	OTelEndpoint string
	// OTelMetricExportInterval is the OTEL_METRIC_EXPORT_INTERVAL propagated to
	// ateom pods. Empty keeps the SDK's default.
	OTelMetricExportInterval string
	// OTelMetricExportTimeout is the OTEL_METRIC_EXPORT_TIMEOUT propagated to
	// ateom pods. Empty keeps the SDK's default.
	OTelMetricExportTimeout string
	// OTelTracesSampler is the OTEL_TRACES_SAMPLER propagated to ateom pods.
	// Empty keeps the ateom binary's default.
	OTelTracesSampler string
	// OTelTracesSamplerArg is the OTEL_TRACES_SAMPLER_ARG propagated to ateom
	// pods. Ignored unless OTelTracesSampler is set.
	OTelTracesSamplerArg string
	// OTelLogsExporter is the OTEL_LOGS_EXPORTER propagated to ateom pods.
	// Empty keeps the ateom binary's default.
	OTelLogsExporter string
	// SystemNamespace is the namespace substrate's control plane runs in, and
	// AteletServiceAccount / RouterServiceAccount are the ServiceAccounts those
	// components run as. Together they name the SPIFFE identities that atunnel
	// authenticates inside each worker, which is why the ServiceAccount names
	// are configuration and not constants: a deployment that prefixes
	// resource names changes them.
	SystemNamespace      string
	AteletServiceAccount string
	RouterServiceAccount string
	// contains filtered or unexported fields
}

func (*WorkerPoolReconciler) InitMetrics

func (r *WorkerPoolReconciler) InitMetrics(meter metric.Meter) error

InitMetrics initializes the OpenTelemetry instruments for ate.workerpool.desired_workers and ate.workerpool.ready_workers and registers the asynchronous callback.

func (*WorkerPoolReconciler) Reconcile

func (r *WorkerPoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*WorkerPoolReconciler) SetupWithManager

func (r *WorkerPoolReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

Jump to

Keyboard shortcuts

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