mirror of
https://github.com/k8sgpt-ai/k8sgpt.git
synced 2025-04-28 19:33:33 +00:00
chore: make go-lint happy (#405)
Signed-off-by: Peter Pan <Peter.Pan@daocloud.io>
This commit is contained in:
parent
50916f2c93
commit
ed73485d92
@ -35,7 +35,7 @@ var AuthCmd = &cobra.Command{
|
|||||||
Long: `Provide the necessary credentials to authenticate with your chosen backend.`,
|
Long: `Provide the necessary credentials to authenticate with your chosen backend.`,
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
if len(args) == 0 {
|
if len(args) == 0 {
|
||||||
cmd.Help()
|
_ = cmd.Help()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
@ -33,8 +33,8 @@ var newCmd = &cobra.Command{
|
|||||||
PreRun: func(cmd *cobra.Command, args []string) {
|
PreRun: func(cmd *cobra.Command, args []string) {
|
||||||
backend, _ := cmd.Flags().GetString("backend")
|
backend, _ := cmd.Flags().GetString("backend")
|
||||||
if strings.ToLower(backend) == "azureopenai" {
|
if strings.ToLower(backend) == "azureopenai" {
|
||||||
cmd.MarkFlagRequired("engine")
|
_ = cmd.MarkFlagRequired("engine")
|
||||||
cmd.MarkFlagRequired("baseurl")
|
_ = cmd.MarkFlagRequired("baseurl")
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
|
@ -25,7 +25,7 @@ var FiltersCmd = &cobra.Command{
|
|||||||
You can list available filters to analyze resources.`,
|
You can list available filters to analyze resources.`,
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
if len(args) == 0 {
|
if len(args) == 0 {
|
||||||
cmd.Help()
|
_ = cmd.Help()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
|
@ -37,7 +37,7 @@ var listCmd = &cobra.Command{
|
|||||||
activeFilters = coreFilters
|
activeFilters = coreFilters
|
||||||
}
|
}
|
||||||
inactiveFilters := util.SliceDiff(availableFilters, activeFilters)
|
inactiveFilters := util.SliceDiff(availableFilters, activeFilters)
|
||||||
fmt.Printf(color.YellowString("Active: \n"))
|
fmt.Print(color.YellowString("Active: \n"))
|
||||||
for _, filter := range activeFilters {
|
for _, filter := range activeFilters {
|
||||||
|
|
||||||
// if the filter is an integration, mark this differently
|
// if the filter is an integration, mark this differently
|
||||||
@ -50,7 +50,7 @@ var listCmd = &cobra.Command{
|
|||||||
|
|
||||||
// display inactive filters
|
// display inactive filters
|
||||||
if len(inactiveFilters) != 0 {
|
if len(inactiveFilters) != 0 {
|
||||||
fmt.Printf(color.YellowString("Unused: \n"))
|
fmt.Print(color.YellowString("Unused: \n"))
|
||||||
for _, filter := range inactiveFilters {
|
for _, filter := range inactiveFilters {
|
||||||
// if the filter is an integration, mark this differently
|
// if the filter is an integration, mark this differently
|
||||||
if util.SliceContainsString(integrationFilters, filter) {
|
if util.SliceContainsString(integrationFilters, filter) {
|
||||||
|
@ -32,7 +32,7 @@ var IntegrationCmd = &cobra.Command{
|
|||||||
|
|
||||||
This would allow you to deploy trivy into your cluster and use a K8sGPT analyzer to parse trivy results.`,
|
This would allow you to deploy trivy into your cluster and use a K8sGPT analyzer to parse trivy results.`,
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
cmd.Help()
|
_ = cmd.Help()
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -85,7 +85,7 @@ func initConfig() {
|
|||||||
viper.SetConfigType("yaml")
|
viper.SetConfigType("yaml")
|
||||||
viper.SetConfigName("k8sgpt")
|
viper.SetConfigName("k8sgpt")
|
||||||
|
|
||||||
viper.SafeWriteConfig()
|
_ = viper.SafeWriteConfig()
|
||||||
}
|
}
|
||||||
|
|
||||||
viper.Set("kubecontext", kubecontext)
|
viper.Set("kubecontext", kubecontext)
|
||||||
@ -96,6 +96,7 @@ func initConfig() {
|
|||||||
|
|
||||||
// If a config file is found, read it in.
|
// If a config file is found, read it in.
|
||||||
if err := viper.ReadInConfig(); err == nil {
|
if err := viper.ReadInConfig(); err == nil {
|
||||||
|
_ = 1
|
||||||
// fmt.Fprintln(os.Stderr, "Using config file:", viper.ConfigFileUsed())
|
// fmt.Fprintln(os.Stderr, "Using config file:", viper.ConfigFileUsed())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -141,7 +141,7 @@ func (a *Analysis) RunAnalysis() {
|
|||||||
results, err := analyzer.Analyze(analyzerConfig)
|
results, err := analyzer.Analyze(analyzerConfig)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
a.Errors = append(a.Errors, fmt.Sprintf(fmt.Sprintf("[%s] %s", reflect.TypeOf(analyzer).Name(), err)))
|
a.Errors = append(a.Errors, fmt.Sprintf("[%s] %s", reflect.TypeOf(analyzer).Name(), err))
|
||||||
mutex.Unlock()
|
mutex.Unlock()
|
||||||
}
|
}
|
||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
@ -167,7 +167,7 @@ func (a *Analysis) RunAnalysis() {
|
|||||||
results, err := analyzer.Analyze(analyzerConfig)
|
results, err := analyzer.Analyze(analyzerConfig)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
a.Errors = append(a.Errors, fmt.Sprintf(fmt.Sprintf("[%s] %s", filter, err)))
|
a.Errors = append(a.Errors, fmt.Sprintf("[%s] %s", filter, err))
|
||||||
mutex.Unlock()
|
mutex.Unlock()
|
||||||
}
|
}
|
||||||
mutex.Lock()
|
mutex.Lock()
|
||||||
@ -176,7 +176,7 @@ func (a *Analysis) RunAnalysis() {
|
|||||||
<-semaphore
|
<-semaphore
|
||||||
}(analyzer, filter)
|
}(analyzer, filter)
|
||||||
} else {
|
} else {
|
||||||
a.Errors = append(a.Errors, fmt.Sprintf(fmt.Sprintf("\"%s\" filter does not exist. Please run k8sgpt filters list.", filter)))
|
a.Errors = append(a.Errors, fmt.Sprintf("\"%s\" filter does not exist. Please run k8sgpt filters list.", filter))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
@ -234,7 +234,7 @@ func (a *Analysis) GetAIResults(output string, anonymize bool) error {
|
|||||||
// FIXME: can we avoid checking if output is json multiple times?
|
// FIXME: can we avoid checking if output is json multiple times?
|
||||||
// maybe implement the progress bar better?
|
// maybe implement the progress bar better?
|
||||||
if output != "json" {
|
if output != "json" {
|
||||||
bar.Exit()
|
_ = bar.Exit()
|
||||||
}
|
}
|
||||||
|
|
||||||
// Check for exhaustion
|
// Check for exhaustion
|
||||||
@ -255,7 +255,7 @@ func (a *Analysis) GetAIResults(output string, anonymize bool) error {
|
|||||||
|
|
||||||
analysis.Details = parsedText
|
analysis.Details = parsedText
|
||||||
if output != "json" {
|
if output != "json" {
|
||||||
bar.Add(1)
|
_ = bar.Add(1)
|
||||||
}
|
}
|
||||||
a.Results[index] = analysis
|
a.Results[index] = analysis
|
||||||
}
|
}
|
||||||
|
@ -58,7 +58,7 @@ func (NodeAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if len(failures) > 0 {
|
if len(failures) > 0 {
|
||||||
preAnalysis[fmt.Sprintf("%s", node.Name)] = common.PreAnalysis{
|
preAnalysis[node.Name]= common.PreAnalysis{
|
||||||
Node: node,
|
Node: node,
|
||||||
FailureDetails: failures,
|
FailureDetails: failures,
|
||||||
}
|
}
|
||||||
|
@ -85,7 +85,7 @@ func (PodAnalyzer) Analyze(a common.Analyzer) ([]common.Result, error) {
|
|||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// when pod is Running but its ReadinessProbe fails
|
// when pod is Running but its ReadinessProbe fails
|
||||||
if containerStatus.Ready == false && pod.Status.Phase == "Running" {
|
if !containerStatus.Ready && pod.Status.Phase == "Running" {
|
||||||
// parse the event log and append details
|
// parse the event log and append details
|
||||||
evt, err := FetchLatestEvent(a.Context, a.Client, pod.Namespace, pod.Name)
|
evt, err := FetchLatestEvent(a.Context, a.Client, pod.Namespace, pod.Name)
|
||||||
if err != nil || evt == nil {
|
if err != nil || evt == nil {
|
||||||
|
@ -107,7 +107,7 @@ func (s *Config) healthzHandler(w http.ResponseWriter, r *http.Request) {
|
|||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
fmt.Fprintf(w, string(js))
|
fmt.Fprint(w, string(js))
|
||||||
}
|
}
|
||||||
|
|
||||||
func getBoolParam(param string) bool {
|
func getBoolParam(param string) bool {
|
||||||
|
Loading…
Reference in New Issue
Block a user