From f0b8edacccf60565cd77d4117aa074f77767bfbd Mon Sep 17 00:00:00 2001 From: Maciej Szulik Date: Wed, 18 May 2016 15:25:05 +0200 Subject: [PATCH] ScheduledJob storage leftovers --- pkg/master/storage_batch.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/master/storage_batch.go b/pkg/master/storage_batch.go index b6e793296e0..09de5faf8eb 100644 --- a/pkg/master/storage_batch.go +++ b/pkg/master/storage_batch.go @@ -23,6 +23,7 @@ import ( batchapiv2alpha1 "k8s.io/kubernetes/pkg/apis/batch/v2alpha1" "k8s.io/kubernetes/pkg/genericapiserver" jobetcd "k8s.io/kubernetes/pkg/registry/job/etcd" + scheduledjobetcd "k8s.io/kubernetes/pkg/registry/scheduledjob/etcd" ) type BatchRESTStorageProvider struct{} @@ -65,5 +66,10 @@ func (p BatchRESTStorageProvider) v2alpha1Storage(apiResourceConfigSource generi storage["jobs"] = jobsStorage storage["jobs/status"] = jobsStatusStorage } + if apiResourceConfigSource.ResourceEnabled(version.WithResource("scheduledjobs")) { + scheduledJobsStorage, scheduledJobsStatusStorage := scheduledjobetcd.NewREST(restOptionsGetter(batch.Resource("scheduledjobs"))) + storage["scheduledjobs"] = scheduledJobsStorage + storage["scheduledjobs/status"] = scheduledJobsStatusStorage + } return storage }