kuard handler example

Author: odacremolbap

cmd/triggermesh-hook/start/start.go

@@ -13,9 +13,9 @@ type Cmd struct {
 	Path    string `help:"Path where hook requests are served." env:"PATH" default:"v1"`
 }
 
-func (c *Cmd) Run(globals *commoncmd.Globals) error {
-	globals.Logger.Debug("Creating TriggerMesh hook server")
+func (c *Cmd) Run(g *commoncmd.Globals) error {
+	g.Logger.Debug("Creating TriggerMesh hook server")
 
-	s := server.New(c.Path, c.Address, globals.Logger)
-	return s.Start(globals.Context)
+	s := server.New(c.Path, c.Address, g.KubeClient, g.Logger)
+	return s.Start(g.Context)
 }

pkg/common/cmd/globals.go

@@ -14,6 +14,7 @@ import (
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/wait"
+	kdclient "k8s.io/client-go/dynamic"
 	kclient "k8s.io/client-go/kubernetes"
 
 	"github.com/triggermesh/scoby-hook-triggermesh/pkg/config/observability"
@@ -43,6 +44,7 @@ type Globals struct {
 	Logger       *zap.SugaredLogger `kong:"-"`
 	LogLevel     zap.AtomicLevel    `kong:"-"`
 	KubeClient   kclient.Interface  `kong:"-"`
+	DynClient    kdclient.Interface `kong:"-"`
 	ConfigMethod ConfigMethod       `kong:"-"`
 }
 
@@ -83,11 +85,11 @@ func (g *Globals) Initialize() error {
 	defaultConfigApplied := false
 	var err error
 
-	kcfg, err := kubernetes.NewClient(g.Kubeconfig)
+	kc, kdc, err := kubernetes.NewClients(g.Kubeconfig)
 	if err != nil {
 		return err
 	}
-	g.KubeClient = kcfg
+	g.KubeClient, g.DynClient = kc, kdc
 
 	switch {
 	case g.ObservabilityConfig != "":

pkg/handlers/handler.go

@@ -0,0 +1,28 @@
+package handlers
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+
+	hookv1 "github.com/triggermesh/scoby/pkg/hook/v1"
+)
+
+type HandlerD struct {
+	GVR  schema.GroupVersionResource
+	Kind string
+}
+
+// Handler exposes methods for hook handler registration and reconciling.
+type Handler interface {
+	// GVR for the managed object
+	GroupVersionResource() *schema.GroupVersionResource
+	// Kind for the managed object
+	Kind() string
+
+	Reconcile(obj metav1.Object) *hookv1.HookResponse
+}
+
+// HandlerFinalizable exposes methods for hook handler finalize operation.
+type HandlerFinalizable interface {
+	Finalize(obj metav1.Object) hookv1.HookResponse
+}

pkg/handlers/kuards/kuards.go

@@ -0,0 +1,66 @@
+package myhandler
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+
+	commonv1alpha1 "github.com/triggermesh/scoby/pkg/apis/common/v1alpha1"
+	hookv1 "github.com/triggermesh/scoby/pkg/hook/v1"
+	corev1 "k8s.io/api/core/v1"
+
+	"github.com/triggermesh/scoby-hook-triggermesh/pkg/handlers"
+)
+
+type KuardHandler struct {
+	gvr  schema.GroupVersionResource
+	kind string
+}
+
+var _ handlers.Handler = (*KuardHandler)(nil)
+
+func New() *KuardHandler {
+	return &KuardHandler{
+		gvr: schema.GroupVersionResource{
+			Group:    "extensions.triggermesh.io",
+			Version:  "v1",
+			Resource: "kuards",
+		},
+		kind: "Kuard",
+	}
+}
+
+func (h *KuardHandler) GroupVersionResource() *schema.GroupVersionResource {
+	return &h.gvr
+}
+
+// Kind for the managed object
+func (h *KuardHandler) Kind() string {
+	return h.kind
+}
+
+func (h *KuardHandler) Reconcile(obj metav1.Object) *hookv1.HookResponse {
+	return &hookv1.HookResponse{
+		Status: &hookv1.HookStatus{
+			Conditions: commonv1alpha1.Conditions{
+				{
+					Type:   "HookReportedStatus",
+					Status: metav1.ConditionTrue,
+					Reason: "HOOKREPORTSOK",
+				},
+			},
+			Annotations: map[string]string{
+				"io.triggermesh.hook/my-annotation": "annotation from hook",
+			},
+		},
+		EnvVars: []corev1.EnvVar{
+			{
+				Name:  "FROM_HOOK_NAME",
+				Value: obj.GetName(),
+			},
+			{
+				Name:  "FROM_HOOK_NAMESPACE",
+				Value: obj.GetNamespace(),
+			},
+		},
+	}
+}

pkg/kubernetes/client.go

@@ -4,6 +4,7 @@ import (
 	"os"
 	"path/filepath"
 
+	kdclient "k8s.io/client-go/dynamic"
 	kclient "k8s.io/client-go/kubernetes"
 	restclient "k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/clientcmd"
@@ -32,11 +33,21 @@ func NewConfig(path string) (*restclient.Config, error) {
 	return restclient.InClusterConfig()
 }
 
-func NewClient(path string) (kclient.Interface, error) {
+func NewClients(path string) (kclient.Interface, kdclient.Interface, error) {
 	cfg, err := NewConfig(path)
 	if err != nil {
-		return nil, err
+		return nil, nil, err
 	}
 
-	return kclient.NewForConfig(cfg)
+	kc, err := kclient.NewForConfig(cfg)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	kdc, err := kdclient.NewForConfig(cfg)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	return kc, kdc, err
 }

pkg/server/server.go

@@ -12,6 +12,8 @@ import (
 
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	kdclient "k8s.io/client-go/dynamic"
+	kclient "k8s.io/client-go/kubernetes"
 
 	commonv1alpha1 "github.com/triggermesh/scoby/pkg/apis/common/v1alpha1"
 	hookv1 "github.com/triggermesh/scoby/pkg/hook/v1"
@@ -20,15 +22,18 @@ import (
 type Server struct {
 	path    string
 	address string
+	client  kclient.Interface
+	dyn     kdclient.Interface
 
 	logger   *zap.SugaredLogger `kong:"-"`
 	handlers map[string]interface{}
 }
 
-func New(path, address string, logger *zap.SugaredLogger) *Server {
+func New(path, address string, client kclient.Interface, logger *zap.SugaredLogger) *Server {
 	return &Server{
 		path:    path,
 		address: address,
+		client:  client,
 
 		logger: logger,
 	}
@@ -53,6 +58,15 @@ func (s *Server) Start(ctx context.Context) error {
 		close(errCh)
 	}()
 
+	pods, err := s.client.CoreV1().Pods("default").List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return err
+	}
+
+	for _, p := range pods.Items {
+		s.logger.Infow("pod", zap.String("name", p.Name))
+	}
+
 	select {
 	case err := <-errCh:
 		return err