| // Copyright 2020 The Monogon Project Authors. |
| // |
| // SPDX-License-Identifier: Apache-2.0 |
| // |
| // 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 main |
| |
| import ( |
| "context" |
| "log" |
| |
| metroctl "source.monogon.dev/metropolis/cli/metroctl/core" |
| clicontext "source.monogon.dev/metropolis/cli/pkg/context" |
| "source.monogon.dev/metropolis/test/launch/cluster" |
| ) |
| |
| func main() { |
| ctx := clicontext.WithInterrupt(context.Background()) |
| cl, err := cluster.LaunchCluster(ctx, cluster.ClusterOptions{ |
| NumNodes: 2, |
| NodeLogsToFiles: true, |
| }) |
| if err != nil { |
| log.Fatalf("LaunchCluster: %v", err) |
| } |
| |
| mpath, err := cluster.MetroctlRunfilePath() |
| if err != nil { |
| log.Fatalf("MetroctlRunfilePath: %v", err) |
| } |
| wpath, err := cl.MakeMetroctlWrapper() |
| if err != nil { |
| log.Fatalf("MakeWrapper: %v", err) |
| } |
| |
| apiservers, err := cl.KubernetesControllerNodeAddresses(ctx) |
| if err != nil { |
| log.Fatalf("Could not get Kubernetes controller nodes: %v", err) |
| } |
| if len(apiservers) < 1 { |
| log.Fatalf("Cluster has no Kubernetes controller nodes") |
| } |
| |
| configName := "launch-multi2" |
| if err := metroctl.InstallKubeletConfig(mpath, cl.ConnectOptions(), configName, apiservers[0]); err != nil { |
| log.Fatalf("InstallKubeletConfig: %v", err) |
| } |
| |
| log.Printf("Launch: Cluster running!") |
| log.Printf(" To access cluster use: metroctl %s", cl.MetroctlFlags()) |
| log.Printf(" Or use this handy wrapper: %s", wpath) |
| log.Printf(" To access Kubernetes, use kubectl --context=%s", configName) |
| |
| <-ctx.Done() |
| cl.Close() |
| } |