mirror of
https://github.com/optim-enterprises-bv/kubernetes.git
synced 2025-11-04 04:08:16 +00:00
106 lines
3.2 KiB
Go
106 lines
3.2 KiB
Go
/*
|
|
Copyright 2018 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package util
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
|
|
v1 "k8s.io/api/core/v1"
|
|
"k8s.io/client-go/informers"
|
|
coreinformers "k8s.io/client-go/informers/core/v1"
|
|
clientset "k8s.io/client-go/kubernetes"
|
|
"k8s.io/client-go/tools/events"
|
|
"k8s.io/klog"
|
|
"k8s.io/kubernetes/pkg/api/legacyscheme"
|
|
"k8s.io/kubernetes/pkg/scheduler"
|
|
"k8s.io/kubernetes/test/integration/framework"
|
|
)
|
|
|
|
// ShutdownFunc represents the function handle to be called, typically in a defer handler, to shutdown a running module
|
|
type ShutdownFunc func()
|
|
|
|
// StartApiserver starts a local API server for testing and returns the handle to the URL and the shutdown function to stop it.
|
|
func StartApiserver() (string, ShutdownFunc) {
|
|
h := &framework.MasterHolder{Initialized: make(chan struct{})}
|
|
s := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
|
|
<-h.Initialized
|
|
h.M.GenericAPIServer.Handler.ServeHTTP(w, req)
|
|
}))
|
|
|
|
_, _, closeFn := framework.RunAMasterUsingServer(framework.NewIntegrationTestMasterConfig(), s, h)
|
|
|
|
shutdownFunc := func() {
|
|
klog.Infof("destroying API server")
|
|
closeFn()
|
|
s.Close()
|
|
klog.Infof("destroyed API server")
|
|
}
|
|
return s.URL, shutdownFunc
|
|
}
|
|
|
|
// StartScheduler configures and starts a scheduler given a handle to the clientSet interface
|
|
// and event broadcaster. It returns the running scheduler and the shutdown function to stop it.
|
|
func StartScheduler(clientSet clientset.Interface) (*scheduler.Scheduler, coreinformers.PodInformer, ShutdownFunc) {
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
|
|
informerFactory := informers.NewSharedInformerFactory(clientSet, 0)
|
|
podInformer := informerFactory.Core().V1().Pods()
|
|
evtBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{
|
|
Interface: clientSet.EventsV1beta1().Events("")})
|
|
|
|
evtBroadcaster.StartRecordingToSink(ctx.Done())
|
|
|
|
recorder := evtBroadcaster.NewRecorder(
|
|
legacyscheme.Scheme,
|
|
v1.DefaultSchedulerName,
|
|
)
|
|
|
|
sched, err := createScheduler(clientSet, informerFactory, podInformer, recorder, ctx.Done())
|
|
if err != nil {
|
|
klog.Fatalf("Error creating scheduler: %v", err)
|
|
}
|
|
|
|
informerFactory.Start(ctx.Done())
|
|
go sched.Run(ctx)
|
|
|
|
shutdownFunc := func() {
|
|
klog.Infof("destroying scheduler")
|
|
cancel()
|
|
klog.Infof("destroyed scheduler")
|
|
}
|
|
return sched, podInformer, shutdownFunc
|
|
}
|
|
|
|
// createScheduler create a scheduler with given informer factory and default name.
|
|
func createScheduler(
|
|
clientSet clientset.Interface,
|
|
informerFactory informers.SharedInformerFactory,
|
|
podInformer coreinformers.PodInformer,
|
|
recorder events.EventRecorder,
|
|
stopCh <-chan struct{},
|
|
) (*scheduler.Scheduler, error) {
|
|
return scheduler.New(
|
|
clientSet,
|
|
informerFactory,
|
|
podInformer,
|
|
recorder,
|
|
stopCh,
|
|
)
|
|
}
|