add support for "bench warp" command

Signed-off-by: Utkarsh Srivastava <[email protected]>

Author: tangledbytes

deploy/warp/warp-job.yaml

@@ -0,0 +1,17 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: warp-job
+spec:
+  template:
+    spec:
+      containers:
+      - name: warp-job
+        env:
+          - name: WARP_ACCESS_KEY
+          - name: WARP_SECRET_KEY
+        image: "minio/warp:latest"
+        imagePullPolicy: Always
+      restartPolicy: Never
+  backoffLimit: 0
+

deploy/warp/warp-svc.yaml

@@ -0,0 +1,14 @@
+apiVersion: v1
+kind: Service
+metadata:
+  name: warp
+  labels:
+    app: warp
+spec:
+  publishNotReadyAddresses: true
+  clusterIP: None
+  ports:
+    - port: 7761
+      name: warp
+  selector:
+    app: warp

deploy/warp/warp.yaml

@@ -0,0 +1,39 @@
+apiVersion: apps/v1
+kind: StatefulSet
+metadata:
+  name: warp
+  labels:
+    app: warp
+spec:
+  serviceName: warp
+  podManagementPolicy: Parallel
+  replicas: 1
+  selector:
+    matchLabels:
+      app: warp
+  template:
+    metadata:
+      name: warp
+      labels:
+        app: warp
+    spec:
+      affinity:
+        podAntiAffinity:
+          requiredDuringSchedulingIgnoredDuringExecution:
+            - labelSelector:
+                matchExpressions:
+                - key: app
+                  operator: In
+                  values:
+                  - warp
+              topologyKey: "kubernetes.io/hostname"
+      containers:
+        - name: warp
+          image: "minio/warp:latest"
+          imagePullPolicy: Always
+          args:
+            - client
+          ports:
+            - name: http
+              containerPort: 7761
+

pkg/admission/server.go

@@ -6,10 +6,10 @@ import (
 	"fmt"
 	"net/http"
 	"os"
-	"os/signal"
 	"syscall"
 
 	"github.com/noobaa/noobaa-operator/v5/pkg/options"
+	"github.com/noobaa/noobaa-operator/v5/pkg/util"
 	"github.com/sirupsen/logrus"
 )
 
@@ -67,13 +67,11 @@ func RunAdmissionServer() {
 	log.Infof("Server running and listening in port: %s", port)
 
 	// listening shutdown singal
-	signalChan := make(chan os.Signal, 1)
-	signal.Notify(signalChan, syscall.SIGINT, syscall.SIGTERM)
-	<-signalChan
-
-	log.Info("Got shutdown signal, shutting down webhook server gracefully...")
-	err = server.Shutdown(context.Background())
-	if err != nil {
-		log.Info("Failed to Shutdown admission server")
-	}
+	util.OnSignal(func() {
+		log.Info("Got shutdown signal, shutting down webhook server gracefully...")
+		err = server.Shutdown(context.Background())
+		if err != nil {
+			log.Info("Failed to Shutdown admission server")
+		}
+	}, syscall.SIGINT, syscall.SIGTERM)
 }