Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
marccampbell committed Aug 6, 2021
1 parent 9c4dfce commit fceeacf
Show file tree
Hide file tree
Showing 5 changed files with 325 additions and 94 deletions.
36 changes: 18 additions & 18 deletions pkg/cluster/cluster.go
Original file line number Diff line number Diff line change
Expand Up @@ -21,14 +21,14 @@ func Start(ctx context.Context, slug string, dataDir string) error {
}

// start the api server
// if err := runAPIServer(ctx, dataDir, slug); err != nil {
// return errors.Wrap(err, "start api server")
// }
if err := runAPIServer(ctx, dataDir, slug); err != nil {
return errors.Wrap(err, "start api server")
}

// // start the scheduler on port 11251 (this is a non-standard port)
// if err := runScheduler(ctx, dataDir); err != nil {
// return errors.Wrap(err, "start scheduler")
// }
// start the scheduler on port 11251 (this is a non-standard port)
if err := runScheduler(ctx, dataDir); err != nil {
return errors.Wrap(err, "start scheduler")
}

// start the controller manager on port 11252 (non standard)
// TODO the controller should start
Expand All @@ -38,19 +38,19 @@ func Start(ctx context.Context, slug string, dataDir string) error {

// because these are all synchoronous, the api is ready and we
// can install our addons
// kubeconfigPath, err := kubeconfigFilePath(dataDir)
// if err != nil {
// return errors.Wrap(err, "get kubeconfig path")
// }
kubeconfigPath, err := kubeconfigFilePath(dataDir)
if err != nil {
return errors.Wrap(err, "get kubeconfig path")
}

// if err := installCNI(kubeconfigPath); err != nil {
// return errors.Wrap(err, "install antrea")
// }
if err := installCNI(kubeconfigPath); err != nil {
return errors.Wrap(err, "install antrea")
}

// fmt.Println("starting cri")
// if err := startCRI(dataDir); err != nil {
// return errors.Wrap(err, "install cri")
// }
fmt.Println("starting cri")
if err := startCRI(dataDir); err != nil {
return errors.Wrap(err, "install cri")
}

fmt.Println("starting kubelet")
if err := startKubelet(ctx, dataDir); err != nil {
Expand Down

0 comments on commit fceeacf

Please sign in to comment.