gke demos

Author: Huang-Wei

demos/gke/crs/cr-tcp1.yaml

@@ -0,0 +1,10 @@
+apiVersion: kubecon.k8s.io/v1alpha1
+kind: SharedLB
+metadata:
+  name: sharedlb-tcp1
+spec:
+  ports:
+  - port: 4001
+    targetPort: 4000
+  selector:
+    app: tcp1

demos/gke/crs/cr-tcp2.yaml

@@ -0,0 +1,10 @@
+apiVersion: kubecon.k8s.io/v1alpha1
+kind: SharedLB
+metadata:
+  name: sharedlb-tcp2
+spec:
+  ports:
+  - port: 4002
+    targetPort: 4000
+  selector:
+    app: tcp2

demos/gke/crs/cr-tcp3.yaml

@@ -0,0 +1,10 @@
+apiVersion: kubecon.k8s.io/v1alpha1
+kind: SharedLB
+metadata:
+  name: sharedlb-tcp3
+spec:
+  ports:
+  - port: 4003
+    targetPort: 4000
+  selector:
+    app: tcp3

demos/gke/crs/cr-tcp4.yaml

@@ -0,0 +1,10 @@
+apiVersion: kubecon.k8s.io/v1alpha1
+kind: SharedLB
+metadata:
+  name: sharedlb-tcp4
+spec:
+  ports:
+  - port: 4004
+    targetPort: 4000
+  selector:
+    app: tcp4

demos/gke/demo.sh

@@ -0,0 +1,46 @@
+#!/usr/bin/env bash
+
+source $(dirname "$0")/../demoscript
+source ~/.gke
+
+comment This is a demo on Google Kubernetes Engine
+
+doit source ~/.gke
+doit echo "\$KUBECONFIG"
+
+doit kubectl get node
+doit kubectl version --short
+
+doit kubectl get svc,pod
+
+comment We are going to create some deployments
+
+doit kubectl create -f demos/gke/deployments/
+
+comment Custom Resource Definition has been pre-created
+doit kubectl get crd
+doit kubectl get slb
+
+comment We are going to create 4 SharedLB CRs in parallel
+doit kubectl create -f demos/gke/crs
+
+comment So are you expected to see FOUR LBs being created, or just ONE?
+doit kubectl get svc
+doit kubectl get slb
+
+comment GKE LB needs ~1min to be created
+doit kubectl get svc
+doit kubectl get slb
+
+comment Use nc to try connecting
+out=$(kubectl get slb)
+doit nc -zv $(echo "$out" | grep sharedlb-tcp1 | awk '{print $2}') $(echo "$out" | grep sharedlb-tcp1 | awk '{print $3}')
+doit nc -zv $(echo "$out" | grep sharedlb-tcp4 | awk '{print $2}') $(echo "$out" | grep sharedlb-tcp4 | awk '{print $3}')
+
+# comment Cleanup
+
+# doit kubectl delete deploy --all
+# doit kubectl delete slb --all
+# doit kubectl delete svc -l=lb-template=
+
+comment ~End~

demos/gke/deployments/tcp1-deploy.yaml

@@ -0,0 +1,19 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: tcp1-deploy
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: tcp1
+  template:
+    metadata:
+      labels:
+        app: tcp1
+    spec:
+      containers:
+      - name: tcp1
+        image: hweicdl/netcat-tcp:v0.1.0
+        ports:
+        - containerPort: 4000

demos/gke/deployments/tcp2-deploy.yaml

@@ -0,0 +1,19 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: tcp2-deploy
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: tcp2
+  template:
+    metadata:
+      labels:
+        app: tcp2
+    spec:
+      containers:
+      - name: tcp2
+        image: hweicdl/netcat-tcp:v0.1.0
+        ports:
+        - containerPort: 4000

demos/gke/deployments/tcp3-deploy.yaml

@@ -0,0 +1,19 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: tcp3-deploy
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: tcp3
+  template:
+    metadata:
+      labels:
+        app: tcp3
+    spec:
+      containers:
+      - name: tcp3
+        image: hweicdl/netcat-tcp:v0.1.0
+        ports:
+        - containerPort: 4000

demos/gke/deployments/tcp4-deploy.yaml

@@ -0,0 +1,19 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: tcp4-deploy
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      app: tcp4
+  template:
+    metadata:
+      labels:
+        app: tcp4
+    spec:
+      containers:
+      - name: tcp4
+        image: hweicdl/netcat-tcp:v0.1.0
+        ports:
+        - containerPort: 4000

pkg/providers/gke.go

@@ -327,7 +327,6 @@ func (g *GKE) insertForwardingRule(name, ip string, port int32, proto corev1.Pro
 	_, err := fwdInsertCall.Do()
 
 	if err != nil {
-		log.WithName("gke").Error(err, "failed to create the forwarding rule", "target", item)
 		return fmt.Errorf("failed to create the forwarding rule for the item %v: %v", item, err)
 	}
 	return nil