move pkg/scheduler/server to cmd/kube-scheduler/app

This commit is contained in:
Tim Hockin
2015-02-07 20:16:29 -08:00
parent 0b17c0f225
commit 5f021cfc3e
4 changed files with 43 additions and 23 deletions

View File

@@ -14,8 +14,8 @@ See the License for the specific language governing permissions and
limitations under the License.
*/
// Package server implements a Server object for running the scheduler.
package server
// Package app implements a Server object for running the scheduler.
package app
import (
"net"
@@ -26,7 +26,6 @@ import (
"github.com/GoogleCloudPlatform/kubernetes/pkg/client"
"github.com/GoogleCloudPlatform/kubernetes/pkg/client/record"
_ "github.com/GoogleCloudPlatform/kubernetes/pkg/healthz"
"github.com/GoogleCloudPlatform/kubernetes/pkg/hyperkube"
"github.com/GoogleCloudPlatform/kubernetes/pkg/master/ports"
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
"github.com/GoogleCloudPlatform/kubernetes/plugin/pkg/scheduler"
@@ -55,22 +54,6 @@ func NewSchedulerServer() *SchedulerServer {
return &s
}
// NewHyperkubeServer creates a new hyperkube Server object that includes the
// description and flags.
func NewHyperkubeServer() *hyperkube.Server {
s := NewSchedulerServer()
hks := hyperkube.Server{
SimpleUsage: "scheduler",
Long: "Implements a Kubernetes scheduler. This will assign pods to kubelets based on capacity and constraints.",
Run: func(_ *hyperkube.Server, args []string) error {
return s.Run(args)
},
}
s.AddFlags(hks.Flags())
return &hks
}
// AddFlags adds flags for a specific SchedulerServer to the specified FlagSet
func (s *SchedulerServer) AddFlags(fs *pflag.FlagSet) {
fs.IntVar(&s.Port, "port", s.Port, "The port that the scheduler's http service runs on")

View File

@@ -19,13 +19,13 @@ package main
import (
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
"github.com/GoogleCloudPlatform/kubernetes/pkg/version/verflag"
"github.com/GoogleCloudPlatform/kubernetes/plugin/pkg/scheduler/server"
"github.com/GoogleCloudPlatform/kubernetes/plugin/cmd/kube-scheduler/app"
"github.com/spf13/pflag"
)
func main() {
s := server.NewSchedulerServer()
s := app.NewSchedulerServer()
s.AddFlags(pflag.CommandLine)
util.InitFlags()