Skip to content

K
k3s
Commit f0b8edac authored by Maciej Szulik's avatar Maciej Szulik
Browse files
Options

ScheduledJob storage leftovers

parent 17c8feee
Hide whitespace changes
Inline Side-by-side
Showing with 6 additions and 0 deletions
pkg/master/storage_batch.go
View file @ f0b8edac
...@@ -23,6 +23,7 @@ import ( ...@@ -23,6 +23,7 @@ import (
batchapiv2alpha1 "k8s.io/kubernetes/pkg/apis/batch/v2alpha1" batchapiv2alpha1 "k8s.io/kubernetes/pkg/apis/batch/v2alpha1"
"k8s.io/kubernetes/pkg/genericapiserver" "k8s.io/kubernetes/pkg/genericapiserver"
jobetcd "k8s.io/kubernetes/pkg/registry/job/etcd" jobetcd "k8s.io/kubernetes/pkg/registry/job/etcd"
scheduledjobetcd "k8s.io/kubernetes/pkg/registry/scheduledjob/etcd"
) )
type BatchRESTStorageProvider struct{} type BatchRESTStorageProvider struct{}
...@@ -65,5 +66,10 @@ func (p BatchRESTStorageProvider) v2alpha1Storage(apiResourceConfigSource generi ...@@ -65,5 +66,10 @@ func (p BatchRESTStorageProvider) v2alpha1Storage(apiResourceConfigSource generi
storage["jobs"] = jobsStorage storage["jobs"] = jobsStorage
storage["jobs/status"] = jobsStatusStorage 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 return storage
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment