From e869d5c6fc14b7c85205496e5633db6c091617f1 Mon Sep 17 00:00:00 2001 From: Jordan Liggitt Date: Tue, 16 Jun 2015 01:20:39 -0400 Subject: [PATCH] Apply BeforeCreate logic to kubernetes service --- pkg/master/controller.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/pkg/master/controller.go b/pkg/master/controller.go index c067527387..a8558750cf 100644 --- a/pkg/master/controller.go +++ b/pkg/master/controller.go @@ -24,6 +24,7 @@ import ( "github.com/GoogleCloudPlatform/kubernetes/pkg/api" "github.com/GoogleCloudPlatform/kubernetes/pkg/api/endpoints" "github.com/GoogleCloudPlatform/kubernetes/pkg/api/errors" + "github.com/GoogleCloudPlatform/kubernetes/pkg/api/rest" "github.com/GoogleCloudPlatform/kubernetes/pkg/registry/endpoint" "github.com/GoogleCloudPlatform/kubernetes/pkg/registry/namespace" "github.com/GoogleCloudPlatform/kubernetes/pkg/registry/service" @@ -157,8 +158,14 @@ func (c *Controller) CreateMasterServiceIfNeeded(serviceName string, serviceIP n Selector: nil, ClusterIP: serviceIP.String(), SessionAffinity: api.ServiceAffinityNone, + Type: api.ServiceTypeClusterIP, }, } + + if err := rest.BeforeCreate(rest.Services, ctx, svc); err != nil { + return err + } + _, err := c.ServiceRegistry.CreateService(ctx, svc) if err != nil && errors.IsAlreadyExists(err) { err = nil