mirror of https://github.com/k3s-io/k3s
commit
3e1e3d90a3
|
@ -23,6 +23,7 @@ import (
|
|||
"flag"
|
||||
"fmt"
|
||||
"log"
|
||||
"math/rand"
|
||||
"net/http"
|
||||
"os"
|
||||
"time"
|
||||
|
@ -90,8 +91,10 @@ func api_server() {
|
|||
Client: http.DefaultClient,
|
||||
Port: *kubelet_port,
|
||||
}
|
||||
random := rand.New(rand.NewSource(int64(time.Now().Nanosecond())))
|
||||
|
||||
storage := map[string]apiserver.RESTStorage{
|
||||
"pods": registry.MakePodRegistryStorage(podRegistry, containerInfo, registry.MakeFirstFitScheduler(machineList, podRegistry)),
|
||||
"pods": registry.MakePodRegistryStorage(podRegistry, containerInfo, registry.MakeFirstFitScheduler(machineList, podRegistry, random)),
|
||||
"replicationControllers": registry.MakeControllerRegistryStorage(controllerRegistry),
|
||||
"services": registry.MakeServiceRegistryStorage(serviceRegistry),
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue