diff --git a/internal/serviceadapter/informer.go b/internal/serviceadapter/informer.go index 1ca2e24..1f4cf08 100644 --- a/internal/serviceadapter/informer.go +++ b/internal/serviceadapter/informer.go @@ -48,11 +48,18 @@ func NewLoader(registry *Registry, namespace string) (*Loader, error) { pool := x509.NewCertPool() pool.AppendCertsFromPEM(caBytes) + // Use env vars injected by kubelet — no DNS dependency + host := os.Getenv("KUBERNETES_SERVICE_HOST") + port := os.Getenv("KUBERNETES_SERVICE_PORT") + if host == "" || port == "" { + return nil, fmt.Errorf("KUBERNETES_SERVICE_HOST/PORT not set") + } + return &Loader{ registry: registry, namespace: namespace, token: string(tokenBytes), - baseURL: "https://kubernetes.default.svc", + baseURL: fmt.Sprintf("https://%s:%s", host, port), client: &http.Client{ Timeout: 30 * time.Second, Transport: &http.Transport{