From c0aba1dc8a826ddda1a5ace5bab18c843e1b7ae9 Mon Sep 17 00:00:00 2001 From: Wojciech Tyczynski Date: Tue, 25 Aug 2015 15:11:29 +0200 Subject: [PATCH] Reenable watch in apiserver --- pkg/master/master.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pkg/master/master.go b/pkg/master/master.go index d90c1f19767..ec6795eb53a 100644 --- a/pkg/master/master.go +++ b/pkg/master/master.go @@ -429,9 +429,10 @@ func logStackOnRecover(panicReason interface{}, httpWriter http.ResponseWriter) // init initializes master. func (m *Master) init(c *Config) { + enableCacher := true healthzChecks := []healthz.HealthzChecker{} m.clock = util.RealClock{} - podStorage := podetcd.NewStorage(c.DatabaseStorage, false, c.KubeletClient) + podStorage := podetcd.NewStorage(c.DatabaseStorage, enableCacher, c.KubeletClient) podTemplateStorage := podtemplateetcd.NewREST(c.DatabaseStorage) @@ -447,10 +448,10 @@ func (m *Master) init(c *Config) { namespaceStorage, namespaceStatusStorage, namespaceFinalizeStorage := namespaceetcd.NewREST(c.DatabaseStorage) m.namespaceRegistry = namespace.NewRegistry(namespaceStorage) - endpointsStorage := endpointsetcd.NewREST(c.DatabaseStorage, false) + endpointsStorage := endpointsetcd.NewREST(c.DatabaseStorage, enableCacher) m.endpointRegistry = endpoint.NewRegistry(endpointsStorage) - nodeStorage, nodeStatusStorage := nodeetcd.NewREST(c.DatabaseStorage, false, c.KubeletClient) + nodeStorage, nodeStatusStorage := nodeetcd.NewREST(c.DatabaseStorage, enableCacher, c.KubeletClient) m.nodeRegistry = minion.NewRegistry(nodeStorage) serviceStorage := serviceetcd.NewREST(c.DatabaseStorage)