mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-06 16:06:56 +00:00
Code Activity

temporarily comment out code to pass CI build

Browse source
This commit is contained in:
Shuting Zhao 2020-10-15 18:06:34 -07:00
parent c906baa1a7
commit f1f8ed3f7d
5 changed files with 765 additions and 762 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

126
pkg/kyverno/report/allreports.go
View file

@ -1,67 +1,67 @@
package report package report
import ( // import (
"fmt" // "fmt"
"os" // "os"
"sync" // "sync"
"time" // "time"
"github.com/kyverno/kyverno/pkg/common" // "github.com/kyverno/kyverno/pkg/common"
"github.com/kyverno/kyverno/pkg/constant" // "github.com/kyverno/kyverno/pkg/constant"
"github.com/kyverno/kyverno/pkg/utils" // "github.com/kyverno/kyverno/pkg/utils"
"github.com/spf13/cobra" // "github.com/spf13/cobra"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" // metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/cli-runtime/pkg/genericclioptions" // "k8s.io/cli-runtime/pkg/genericclioptions"
log "sigs.k8s.io/controller-runtime/pkg/log" // log "sigs.k8s.io/controller-runtime/pkg/log"
) // )
func AllReportsCommand() *cobra.Command { // func AllReportsCommand() *cobra.Command {
kubernetesConfig := genericclioptions.NewConfigFlags(true) // kubernetesConfig := genericclioptions.NewConfigFlags(true)
var mode, namespace, policy string // var mode, namespace, policy string
cmd := &cobra.Command{ // cmd := &cobra.Command{
Use: "all", // Use: "all",
Short: "generate report for all scope", // Short: "generate report for all scope",
Example: fmt.Sprintf("To create a namespace report from background scan:\nkyverno report namespace --namespace=defaults \n kyverno report namespace"), // Example: fmt.Sprintf("To create a namespace report from background scan:\nkyverno report namespace --namespace=defaults \n kyverno report namespace"),
RunE: func(cmd *cobra.Command, args []string) (err error) { // RunE: func(cmd *cobra.Command, args []string) (err error) {
os.Setenv("POLICY-TYPE", common.PolicyReport) // os.Setenv("POLICY-TYPE", common.PolicyReport)
logger := log.Log.WithName("Report") // logger := log.Log.WithName("Report")
restConfig, err := kubernetesConfig.ToRESTConfig() // restConfig, err := kubernetesConfig.ToRESTConfig()
if err != nil { // if err != nil {
logger.Error(err, "failed to create rest config of kubernetes cluster ") // logger.Error(err, "failed to create rest config of kubernetes cluster ")
os.Exit(1) // os.Exit(1)
} // }
const resyncPeriod = 1 * time.Second // const resyncPeriod = 1 * time.Second
kubeClient, err := utils.NewKubeClient(restConfig) // kubeClient, err := utils.NewKubeClient(restConfig)
if err != nil { // if err != nil {
log.Log.Error(err, "Failed to create kubernetes client") // log.Log.Error(err, "Failed to create kubernetes client")
os.Exit(1) // os.Exit(1)
} // }
var wg sync.WaitGroup // var wg sync.WaitGroup
if mode == "cli" { // if mode == "cli" {
if namespace != "" { // if namespace != "" {
wg.Add(1) // wg.Add(1)
go backgroundScan(namespace, constant.All, policy, &wg, restConfig, logger) // go backgroundScan(namespace, constant.All, policy, &wg, restConfig, logger)
} else { // } else {
ns, err := kubeClient.CoreV1().Namespaces().List(metav1.ListOptions{}) // ns, err := kubeClient.CoreV1().Namespaces().List(metav1.ListOptions{})
if err != nil { // if err != nil {
os.Exit(1) // os.Exit(1)
} // }
wg.Add(len(ns.Items)) // wg.Add(len(ns.Items))
for _, n := range ns.Items { // for _, n := range ns.Items {
go backgroundScan(n.GetName(), constant.All, policy, &wg, restConfig, logger) // go backgroundScan(n.GetName(), constant.All, policy, &wg, restConfig, logger)
} // }
} // }
} else { // } else {
wg.Add(1) // wg.Add(1)
go configmapScan(constant.All, &wg, restConfig, logger) // go configmapScan(constant.All, &wg, restConfig, logger)
} // }
wg.Wait() // wg.Wait()
os.Exit(0) // os.Exit(0)
return nil // return nil
}, // },
} // }
cmd.Flags().StringVarP(&namespace, "namespace", "n", "", "define specific namespace") // cmd.Flags().StringVarP(&namespace, "namespace", "n", "", "define specific namespace")
cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy") // cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy")
cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode") // cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode")
return cmd // return cmd
} // }

84
pkg/kyverno/report/cluster.go
View file

@ -1,47 +1,47 @@
package report package report
import ( // import (
"fmt" // "fmt"
"os" // "os"
"sync" // "sync"
"github.com/kyverno/kyverno/pkg/common" // "github.com/kyverno/kyverno/pkg/common"
"github.com/kyverno/kyverno/pkg/constant" // "github.com/kyverno/kyverno/pkg/constant"
"github.com/spf13/cobra" // "github.com/spf13/cobra"
"k8s.io/cli-runtime/pkg/genericclioptions" // "k8s.io/cli-runtime/pkg/genericclioptions"
log "sigs.k8s.io/controller-runtime/pkg/log" // log "sigs.k8s.io/controller-runtime/pkg/log"
) // )
func ClusterCommand() *cobra.Command { // func ClusterCommand() *cobra.Command {
kubernetesConfig := genericclioptions.NewConfigFlags(true) // kubernetesConfig := genericclioptions.NewConfigFlags(true)
var mode, policy string // var mode, policy string
cmd := &cobra.Command{ // cmd := &cobra.Command{
Use: "cluster", // Use: "cluster",
Short: "generate report for cluster scope", // Short: "generate report for cluster scope",
Example: fmt.Sprintf("To create a cluster report from background scan: kyverno report cluster"), // Example: fmt.Sprintf("To create a cluster report from background scan: kyverno report cluster"),
RunE: func(cmd *cobra.Command, args []string) (err error) { // RunE: func(cmd *cobra.Command, args []string) (err error) {
os.Setenv("POLICY-TYPE", common.PolicyReport) // os.Setenv("POLICY-TYPE", common.PolicyReport)
logger := log.Log.WithName("Report") // logger := log.Log.WithName("Report")
restConfig, err := kubernetesConfig.ToRESTConfig() // restConfig, err := kubernetesConfig.ToRESTConfig()
if err != nil { // if err != nil {
logger.Error(err, "failed to create rest config of kubernetes cluster ") // logger.Error(err, "failed to create rest config of kubernetes cluster ")
os.Exit(1) // os.Exit(1)
} // }
var wg sync.WaitGroup // var wg sync.WaitGroup
wg.Add(1) // wg.Add(1)
if mode == "cli" { // if mode == "cli" {
go backgroundScan("", constant.Cluster, policy, &wg, restConfig, logger) // go backgroundScan("", constant.Cluster, policy, &wg, restConfig, logger)
wg.Wait() // wg.Wait()
os.Exit(0) // os.Exit(0)
} // }
go configmapScan(constant.Cluster, &wg, restConfig, logger) // go configmapScan(constant.Cluster, &wg, restConfig, logger)
wg.Wait() // wg.Wait()
os.Exit(0) // os.Exit(0)
return nil // return nil
}, // },
} // }
cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode of cli") // cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode of cli")
cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy") // cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy")
return cmd // return cmd
} // }

6
pkg/kyverno/report/command.go
View file

@ -25,8 +25,8 @@ func Command() *cobra.Command {
return err return err
}, },
} }
cmd.AddCommand(NamespaceCommand()) // cmd.AddCommand(NamespaceCommand())
cmd.AddCommand(ClusterCommand()) // cmd.AddCommand(ClusterCommand())
cmd.AddCommand(AllReportsCommand()) // cmd.AddCommand(AllReportsCommand())
return cmd return cmd
} }

1184
pkg/kyverno/report/common.go
View file

File diff suppressed because it is too large Load diff

127
pkg/kyverno/report/namespace.go
View file

@ -1,68 +1,71 @@
package report package report
import ( // import (
"fmt" // "fmt"
"os" // "os"
"sync" // "sync"
"time" // "time"
"github.com/kyverno/kyverno/pkg/common" // "github.com/kyverno/kyverno/pkg/common"
"github.com/kyverno/kyverno/pkg/constant" // "github.com/kyverno/kyverno/pkg/constant"
"github.com/kyverno/kyverno/pkg/utils" // client "github.com/kyverno/kyverno/pkg/dclient"
"github.com/spf13/cobra" // cliutil "github.com/kyverno/kyverno/pkg/kyverno/common"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" // "github.com/spf13/cobra"
"k8s.io/cli-runtime/pkg/genericclioptions" // metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
log "sigs.k8s.io/controller-runtime/pkg/log" // "k8s.io/cli-runtime/pkg/genericclioptions"
) // log "sigs.k8s.io/controller-runtime/pkg/log"
// )
func NamespaceCommand() *cobra.Command { // func NamespaceCommand() *cobra.Command {
kubernetesConfig := genericclioptions.NewConfigFlags(true) // var mode, namespace, policy string
var mode, namespace, policy string // cmd := &cobra.Command{
cmd := &cobra.Command{ // Use: "namespace",
Use: "namespace", // Short: "generate report for scope namespace",
Short: "generate report for scope namespace", // Example: fmt.Sprintf("To create a namespace report from background scan:\nkyverno report namespace --namespace=defaults \n kyverno report namespace"),
Example: fmt.Sprintf("To create a namespace report from background scan:\nkyverno report namespace --namespace=defaults \n kyverno report namespace"), // RunE: func(cmd *cobra.Command, args []string) (err error) {
RunE: func(cmd *cobra.Command, args []string) (err error) { // os.Setenv("POLICY-TYPE", common.PolicyReport)
os.Setenv("POLICY-TYPE", common.PolicyReport) // logger := log.Log.WithName("Report")
logger := log.Log.WithName("Report")
restConfig, err := kubernetesConfig.ToRESTConfig()
if err != nil {
logger.Error(err, "failed to create rest config of kubernetes cluster ")
os.Exit(1)
}
const resyncPeriod = 1 * time.Second
kubeClient, err := utils.NewKubeClient(restConfig)
if err != nil {
log.Log.Error(err, "Failed to create kubernetes client")
os.Exit(1)
}
var wg sync.WaitGroup // // with cluster
if mode == "cli" { // kubernetesConfig := genericclioptions.NewConfigFlags(true)
if namespace != "" { // restConfig, err := kubernetesConfig.ToRESTConfig()
wg.Add(1) // if err != nil {
go backgroundScan(namespace, constant.Namespace, policy, &wg, restConfig, logger) // return err
} else { // }
ns, err := kubeClient.CoreV1().Namespaces().List(metav1.ListOptions{})
if err != nil {
os.Exit(1)
}
wg.Add(len(ns.Items))
for _, n := range ns.Items {
go backgroundScan(n.GetName(), constant.Namespace, policy, &wg, restConfig, logger)
}
}
} else {
wg.Add(1)
go configmapScan(constant.Namespace, &wg, restConfig, logger)
}
wg.Wait() // dClient, err := client.NewClient(restConfig, 5*time.Minute, make(chan struct{}), log.Log)
return nil // if err != nil {
}, // return err
} // }
cmd.Flags().StringVarP(&namespace, "namespace", "n", "", "define specific namespace")
cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy") // resources, err := cliutil.GetResources(nil, []string{}, dClient)
cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode")
return cmd // var wg sync.WaitGroup
} // if mode == "cli" {
// if namespace != "" {
// wg.Add(1)
// go backgroundScan(namespace, constant.Namespace, policy, &wg, restConfig, logger)
// } else {
// ns, err := kubeClient.CoreV1().Namespaces().List(metav1.ListOptions{})
// if err != nil {
// os.Exit(1)
// }
// wg.Add(len(ns.Items))
// for _, n := range ns.Items {
// go backgroundScan(n.GetName(), constant.Namespace, policy, &wg, restConfig, logger)
// }
// }
// } else {
// wg.Add(1)
// go configmapScan(constant.Namespace, &wg, restConfig, logger)
// }
// wg.Wait()
// return nil
// },
// }
// cmd.Flags().StringVarP(&namespace, "namespace", "n", "", "define specific namespace")
// cmd.Flags().StringVarP(&policy, "policy", "p", "", "define specific policy")
// cmd.Flags().StringVarP(&mode, "mode", "m", "cli", "mode")
// return cmd
// }