mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-31 03:45:17 +00:00
Code Activity

remove commented code / extra lines, correct spelling

Browse source
This commit is contained in:
shuting 2019-05-03 16:41:45 -07:00
parent 7bdaff157e
commit 82176b5371
3 changed files with 7 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
controller/controller.go
View file

@ -49,7 +49,6 @@ func NewPolicyController(config *rest.Config, logger *log.Logger) (*PolicyContro
if err != nil {
return nil, err
}
log.Print(kubeClient)
policyInformerFactory := informers.NewSharedInformerFactory(policyClientset, time.Second*30)
policyInformer := policyInformerFactory.Nirmata().V1alpha1().Policies()

6
pkg/resourceClient/client.go
View file

@ -2,17 +2,15 @@ package resourceClient
import (
meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes"
"k8s.io/apimachinery/pkg/runtime"
"k8s.io/client-go/kubernetes"
)
func GetResouce(clientSet *kubernetes.Clientset, kind string, resourceNamespace string, resourceName string) (runtime.Object, error) {
switch kind {
case "Deployment":
{
obj, err := clientSet.AppsV1().Deployments(resourceNamespace).Get(resourceName, meta_v1.GetOptions{}) // Deployment
obj, err := clientSet.AppsV1().Deployments(resourceNamespace).Get(resourceName, meta_v1.GetOptions{})
if err != nil {
return nil, err
}

12
pkg/violation/violation.go
View file

@ -2,6 +2,9 @@ package violation
import (
"fmt"
"log"
"time"
types "github.com/nirmata/kube-policy/pkg/apis/policy/v1alpha1"
clientset "github.com/nirmata/kube-policy/pkg/client/clientset/versioned"
policyscheme "github.com/nirmata/kube-policy/pkg/client/clientset/versioned/scheme"
@ -17,8 +20,6 @@ import (
"k8s.io/client-go/tools/cache"
"k8s.io/client-go/tools/record"
"k8s.io/client-go/util/workqueue"
"log"
"time"
)
type Violations []Violation
@ -66,7 +67,7 @@ func NewViolationHelper(kubeClient *kubernetes.Clientset, policyClientSet *clien
// Create to generate violation jsonpatch script &
// queue events to generate events
// TO-DO create should validate the rule number and update the violation if one exists
// TODO: create should validate the rule number and update the violation if one exists
func (b *Builder) Create(info Info) error {
// generate patch
// we can generate the patch as the policy resource will alwasy exist
@ -185,9 +186,7 @@ func (b *Builder) ValidationResourceActive(violation types.Violation) (bool, err
}
func (b *Builder) patch(policy *types.Policy, updatedPolicy *types.Policy) error {
_, err := b.policyClientset.Nirmata().Policies(updatedPolicy.Namespace).UpdateStatus(updatedPolicy)
// _, err = b.policyClientset.Nirmata().Policies(policy.Namespace).Patch(policy.Name, patchTypes.MergePatchType, patchBytes)
if err != nil {
return err
}
@ -196,7 +195,6 @@ func (b *Builder) patch(policy *types.Policy, updatedPolicy *types.Policy) error
// Run : Initialize the worker routines to process the event creation
func (b *Builder) Run(threadiness int, stopCh <-chan struct{}) error {
defer utilruntime.HandleCrash()
defer b.workqueue.ShutDown()
log.Println("Starting violation builder")
@ -233,7 +231,7 @@ func (b *Builder) processNextWorkItem() bool {
var ok bool
if key, ok = obj.(EventInfo); !ok {
b.workqueue.Forget(obj)
log.Printf("Expecting type info by got %v", obj)
log.Printf("Expecting type info but got %v", obj)
return nil
}