Repository navigation
Expand file tree
/
Copy pathroot.go
More file actions
99 lines (84 loc) · 3.53 KB
/
Copy pathroot.go
File metadata and controls
99 lines (84 loc) · 3.53 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
package cmd
import (
"fmt"
"regexp"
"github.com/fatih/color"
pkgcmd "github.com/linkerd/linkerd2/pkg/cmd"
"github.com/linkerd/linkerd2/pkg/healthcheck"
log "github.com/sirupsen/logrus"
"github.com/spf13/cobra"
)
const (
// ExtensionName is the value that the viz extension resources should be labeled with
ExtensionName = "viz"
// LegacyExtensionName is the value that the viz extension resources were labeled with
// until 15d1809bd043192bb21cacbc96112cce35bf384f
LegacyExtensionName = "linkerd-viz"
vizChartName = "linkerd-viz"
defaultLinkerdNamespace = "linkerd"
maxRps = 100.0
jsonOutput = healthcheck.JSONOutput
tableOutput = healthcheck.TableOutput
wideOutput = healthcheck.WideOutput
)
var (
// special handling for Windows, on all other platforms these resolve to
// os.Stdout and os.Stderr, thanks to https://github.com/mattn/go-colorable
stdout = color.Output
stderr = color.Error
apiAddr string // An empty value means "use the Kubernetes configuration"
controlPlaneNamespace string
kubeconfigPath string
kubeContext string
impersonate string
impersonateGroup []string
verbose bool
// These regexs are not as strict as they could be, but are a quick and dirty
// sanity check against illegal characters.
alphaNumDash = regexp.MustCompile(`^[a-zA-Z0-9-]+$`)
)
// NewCmdViz returns a new jaeger command
func NewCmdViz() *cobra.Command {
vizCmd := &cobra.Command{
Use: "viz",
Short: "viz manages the linkerd-viz extension of Linkerd service mesh",
Long: `viz manages the linkerd-viz extension of Linkerd service mesh.`,
PersistentPreRunE: func(cmd *cobra.Command, args []string) error {
// enable / disable logging
if verbose {
log.SetLevel(log.DebugLevel)
} else {
log.SetLevel(log.PanicLevel)
}
if !alphaNumDash.MatchString(controlPlaneNamespace) {
return fmt.Errorf("%s is not a valid namespace", controlPlaneNamespace)
}
return nil
},
}
vizCmd.PersistentFlags().StringVarP(&controlPlaneNamespace, "linkerd-namespace", "L", defaultLinkerdNamespace, "Namespace in which Linkerd is installed")
vizCmd.PersistentFlags().StringVar(&kubeconfigPath, "kubeconfig", "", "Path to the kubeconfig file to use for CLI requests")
vizCmd.PersistentFlags().StringVar(&kubeContext, "context", "", "Name of the kubeconfig context to use")
vizCmd.PersistentFlags().StringVar(&impersonate, "as", "", "Username to impersonate for Kubernetes operations")
vizCmd.PersistentFlags().StringArrayVar(&impersonateGroup, "as-group", []string{}, "Group to impersonate for Kubernetes operations")
vizCmd.PersistentFlags().StringVar(&apiAddr, "api-addr", "", "Override kubeconfig and communicate directly with the control plane at host:port (mostly for testing)")
vizCmd.PersistentFlags().BoolVar(&verbose, "verbose", false, "Turn on debug logging")
vizCmd.AddCommand(NewCmdAuthz())
vizCmd.AddCommand(NewCmdCheck())
vizCmd.AddCommand(NewCmdDashboard())
vizCmd.AddCommand(NewCmdEdges())
vizCmd.AddCommand(newCmdInstall())
vizCmd.AddCommand(newCmdList())
vizCmd.AddCommand(newCmdProfile())
vizCmd.AddCommand(NewCmdRoutes())
vizCmd.AddCommand(NewCmdStat())
vizCmd.AddCommand(NewCmdTap())
vizCmd.AddCommand(NewCmdTop())
vizCmd.AddCommand(newCmdUninstall())
// resource-aware completion flag configurations
pkgcmd.ConfigureNamespaceFlagCompletion(
vizCmd, []string{"linkerd-namespace"},
kubeconfigPath, impersonate, impersonateGroup, kubeContext)
p
2FE3
kgcmd.ConfigureKubeContextFlagCompletion(vizCmd, kubeconfigPath)
return vizCmd
}