update endpoint and proxygroup

pull/17649/head
Ethan 1 month ago
parent 79cc6c1442
commit dfd81634b0
No known key found for this signature in database

@ -409,6 +409,7 @@ func (r *ProxyGroupReconciler) maybeProvision(ctx context.Context, pg *tsapi.Pro
proxyStsName: pg.Name, proxyStsName: pg.Name,
proxyLabels: pgLabels(pg.Name, nil), proxyLabels: pgLabels(pg.Name, nil),
proxyType: "proxygroup", proxyType: "proxygroup",
metricsPortName: metricsPortName(proxyClass),
} }
if err := reconcileMetricsResources(ctx, logger, mo, proxyClass, r.Client); err != nil { if err := reconcileMetricsResources(ctx, logger, mo, proxyClass, r.Client); err != nil {
return r.notReadyErrf(pg, logger, "error reconciling metrics resources: %w", err) return r.notReadyErrf(pg, logger, "error reconciling metrics resources: %w", err)

@ -854,7 +854,7 @@ func applyProxyClassToStatefulSet(pc *tsapi.ProxyClass, ss *appsv1.StatefulSet,
// For egress proxies, currently all cluster traffic is forwarded to the tailnet target. // For egress proxies, currently all cluster traffic is forwarded to the tailnet target.
logger.Info("ProxyClass specifies that metrics should be enabled, but this is currently not supported for Ingress proxies that accept cluster traffic.") logger.Info("ProxyClass specifies that metrics should be enabled, but this is currently not supported for Ingress proxies that accept cluster traffic.")
} else { } else {
enableEndpoints(ss, metricsEnabled, debugEnabled) enableEndpoints(ss, metricsEnabled, debugEnabled, metricsPortName(pc))
} }
} }
@ -957,7 +957,7 @@ func applyProxyClassToStatefulSet(pc *tsapi.ProxyClass, ss *appsv1.StatefulSet,
return ss return ss
} }
func enableEndpoints(ss *appsv1.StatefulSet, metrics, debug bool) { func enableEndpoints(ss *appsv1.StatefulSet, metrics, debug bool, metricsPortName string) {
for i, c := range ss.Spec.Template.Spec.Containers { for i, c := range ss.Spec.Template.Spec.Containers {
if isMainContainer(&c) { if isMainContainer(&c) {
if debug { if debug {
@ -1002,7 +1002,7 @@ func enableEndpoints(ss *appsv1.StatefulSet, metrics, debug bool) {
) )
ss.Spec.Template.Spec.Containers[i].Ports = append(ss.Spec.Template.Spec.Containers[i].Ports, ss.Spec.Template.Spec.Containers[i].Ports = append(ss.Spec.Template.Spec.Containers[i].Ports,
corev1.ContainerPort{ corev1.ContainerPort{
Name: "metrics", Name: metricsPortName,
Protocol: "TCP", Protocol: "TCP",
ContainerPort: 9002, ContainerPort: 9002,
}, },

Loading…
Cancel
Save