controllers

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2026 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func EgressMITMCAPoolRef

func EgressMITMCAPoolRef() types.NamespacedName

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

Types

type EgressMITMTrustReconciler

type EgressMITMTrustReconciler struct {
	client.Client
}

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
}

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