TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-07-01 20:48:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

k8s-operator: adding check for advertised services before setting ingress status

Browse Source 
Signed-off-by: chaosinthecrd <tom@tmlabs.co.uk>
This commit is contained in:
chaosinthecrd 2025-05-02 14:49:12 +01:00
parent 31c2c61e77
commit b87c72e788
No known key found for this signature in database
GPG Key ID: 87942E75F71EF65D
1 changed files with 19 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cmd/k8s-operator/svc-for-pg.go
View File

@ -356,19 +356,31 @@ func (r *HAServiceReconciler) maybeProvision(ctx context.Context, hostname strin
return false, fmt.Errorf("failed to update tailscaled config: %w", err) return false, fmt.Errorf("failed to update tailscaled config: %w", err)
} }
// TODO: is it ready?
if svc.Spec.Type != corev1.ServiceTypeLoadBalancer { if svc.Spec.Type != corev1.ServiceTypeLoadBalancer {
return false, nil return false, nil
} }
count, err := r.numberPodsAdvertising(ctx, pgName, serviceName)
if err != nil {
return false, fmt.Errorf("failed to get number of advertised Pods: %w", err)
}
var lbs []corev1.LoadBalancerIngress
if count != 0 {
dnsName, err := r.dnsNameForService(ctx, serviceName) dnsName, err := r.dnsNameForService(ctx, serviceName)
if err != nil { if err != nil {
return false, fmt.Errorf("error getting DNS name for Service: %w", err) return false, fmt.Errorf("error getting DNS name for Service: %w", err)
} }
ingress := []corev1.LoadBalancerIngress{
{Hostname: dnsName, lbs = []corev1.LoadBalancerIngress{
IP: vipv4.String()}, {
Hostname: dnsName,
IP: vipv4.String(),
},
} }
svc.Status.LoadBalancer.Ingress = ingress }
svc.Status.LoadBalancer.Ingress = lbs
// if apiequality.Semantic.DeepEqual(oldStatus, &ing.Status) { // if apiequality.Semantic.DeepEqual(oldStatus, &ing.Status) {
// return svcsChanged, nil // return svcsChanged, nil