From 3d824103a744af1145a060a3667dca78fbc46f5c Mon Sep 17 00:00:00 2001 From: Rohit Ramkumar Date: Tue, 31 Jul 2018 18:20:11 -0700 Subject: [PATCH] Remove all code related to legacy health checks --- pkg/backends/syncer.go | 6 ++++-- pkg/healthchecks/healthchecks.go | 13 ------------- pkg/healthchecks/healthchecks_test.go | 20 -------------------- pkg/healthchecks/interfaces.go | 2 -- 4 files changed, 4 insertions(+), 37 deletions(-) diff --git a/pkg/backends/syncer.go b/pkg/backends/syncer.go index bfa3e61dec..44e4d92b0b 100644 --- a/pkg/backends/syncer.go +++ b/pkg/backends/syncer.go @@ -86,8 +86,7 @@ func (s *backendSyncer) ensureBackendService(sp utils.ServicePort) error { } } - // Ensure health check for backend service exists. Note that hasLegacyHC - // will dictate whether we search for an existing legacy health check. + // Ensure health check for backend service exists. hcLink, err := s.ensureHealthCheck(sp, hasLegacyHC) if err != nil { return err @@ -170,6 +169,9 @@ func (s *backendSyncer) Shutdown() error { } func (s *backendSyncer) ensureHealthCheck(sp utils.ServicePort, hasLegacyHC bool) (string, error) { + if hasLegacyHC { + glog.Errorf("Backend %+v has legacy health check", sp.ID) + } hc := s.healthChecker.New(sp) if s.prober != nil { probe, err := s.prober.GetProbe(sp) diff --git a/pkg/healthchecks/healthchecks.go b/pkg/healthchecks/healthchecks.go index 94b7afc7c3..a90826938a 100644 --- a/pkg/healthchecks/healthchecks.go +++ b/pkg/healthchecks/healthchecks.go @@ -244,19 +244,6 @@ func (h *HealthChecks) Get(name string, version meta.Version) (*HealthCheck, err return NewHealthCheck(hc), err } -// GetLegacy deletes legacy HTTP health checks -func (h *HealthChecks) GetLegacy(port int64) (*compute.HttpHealthCheck, error) { - name := h.namer.IGBackend(port) - return h.cloud.GetHttpHealthCheck(name) -} - -// DeleteLegacy deletes legacy HTTP health checks -func (h *HealthChecks) DeleteLegacy(port int64) error { - name := h.namer.IGBackend(port) - glog.V(2).Infof("Deleting legacy HTTP health check %v", name) - return h.cloud.DeleteHttpHealthCheck(name) -} - // DefaultHealthCheck simply returns the default health check. func DefaultHealthCheck(port int64, protocol annotations.AppProtocol) *HealthCheck { httpSettings := computealpha.HTTPHealthCheck{Port: port} diff --git a/pkg/healthchecks/healthchecks_test.go b/pkg/healthchecks/healthchecks_test.go index 6efbee0ca1..ab682cac12 100644 --- a/pkg/healthchecks/healthchecks_test.go +++ b/pkg/healthchecks/healthchecks_test.go @@ -20,8 +20,6 @@ import ( "net/http" "testing" - compute "google.golang.org/api/compute/v1" - "k8s.io/apimachinery/pkg/types" "k8s.io/ingress-gce/pkg/annotations" "k8s.io/ingress-gce/pkg/utils" @@ -311,24 +309,6 @@ func TestHealthCheckUpdate(t *testing.T) { } } -func TestHealthCheckDeleteLegacy(t *testing.T) { - hcp := NewFakeHealthCheckProvider() - healthChecks := NewHealthChecker(hcp, "/", "/healthz", namer, defaultBackendSvc) - - err := hcp.CreateHttpHealthCheck(&compute.HttpHealthCheck{ - Name: namer.IGBackend(80), - }) - if err != nil { - t.Fatalf("expected health check to be created, err: %v", err) - } - - err = healthChecks.DeleteLegacy(80) - if err != nil { - t.Fatalf("expected health check to be deleted, err: %v", err) - } - -} - func TestAlphaHealthCheck(t *testing.T) { hcp := NewFakeHealthCheckProvider() healthChecks := NewHealthChecker(hcp, "/", "/healthz", namer, defaultBackendSvc) diff --git a/pkg/healthchecks/interfaces.go b/pkg/healthchecks/interfaces.go index e4ab210954..5e5ff20fc8 100644 --- a/pkg/healthchecks/interfaces.go +++ b/pkg/healthchecks/interfaces.go @@ -50,6 +50,4 @@ type HealthChecker interface { Sync(hc *HealthCheck) (string, error) Delete(name string) error Get(name string, version meta.Version) (*HealthCheck, error) - GetLegacy(port int64) (*compute.HttpHealthCheck, error) - DeleteLegacy(port int64) error }