Get worker id from env

cmd/snowflake/main.go

@@ -1,6 +1,9 @@
 package main
 
 import (
+	"log"
+	"os"
+	"strconv"
 	"sync"
 
 	"github.com/dustinpianalto/snowflake/internal/generator"
@@ -10,7 +13,12 @@ import (
 
 func main() {
 
-	generator.CreateGenerator(1)
+	workerID, err := strconv.ParseUint(os.Getenv("WORKER_ID"), 10, 64)
+	if err != nil {
+		log.Fatal("Not a valid worker id")
+	}
+
+	generator.CreateGenerator(workerID)
 
 	go generator.Generator.Run()
 

deployment.yml

@@ -21,21 +21,28 @@ status:
 
 ---
 
-apiVersion: v1
+apiVersion: apps/v1
-apiVersion: batch/v1beta1
+kind: Deployment
-kind: CronJob
 metadata:
   name: snowflake-server
-  namespace: default
+  namespace: dca
   labels:
     app: snowflake-server
 spec:
-  schedule: "0 0 * * *"
+  replicas: 1
-  jobTemplate:
+  selector:
-    spec:
+    matchLabels:
+      app: snowflake-server
+  strategy:
+    rollingUpdate:
+      maxSurge: 1
+      maxUnavailable: 1
+  minReadySeconds: 30
   template:
+    metadata:
+      labels:
+        app: snowflake-server
     spec:
-          restartPolicy: "OnFailure"
       containers:
         - name: snowflake-server
           image: <IMAGE>