esiramos/profiling

Makefile

@@ -1,6 +1,6 @@
-CONTAINER_REGISTRY ?= ghcr.io/tgoodwin
+CONTAINER_REGISTRY ?= docker.io/eirn
 IMAGE_NAME ?= $(CONTAINER_REGISTRY)/demo-monolith
-IMAGE_TAG  ?= workpool
+IMAGE_TAG  ?= dapr
 
 # Kubernetes manifest files location
 K8S_DIR ?= demo/monolith/k8s
@@ -26,7 +26,7 @@ push-demo: build-demo
 
 deploy-demo:
 	@echo "--- Deploying to Kubernetes using manifests in $(K8S_DIR) ---"
-	kind load docker-image $(IMAGE_NAME):$(IMAGE_TAG) --name operator-perf-test
+	kind load docker-image $(IMAGE_NAME):$(IMAGE_TAG) --name kind
 	kubectl apply -f $(K8S_DIR)
 
 undeploy:
@@ -52,8 +52,19 @@ delete-demo:
 delete-generated:
 	kubectl delete -f $(GENERATED_MANIFEST_DIR)
 
+delete-redis:
+	@echo "--- deleting redis manifests ---"
+	kubectl delete -f $(K8S_DIR)/redis.yaml 
+	kubectl wait --for=delete -f $(K8S_DIR)/redis.yaml --timeout=60s || true
+	kubectl delete -f $(K8S_DIR)/redis-multi.yaml 
+	kubectl wait --for=delete -f $(K8S_DIR)/redis-multi.yaml --timeout=60s || true
+
+
 reset-redis:
 	@echo "---deleting and then recreating redis---"
-	kubectl delete -f $(K8S_DIR)/redis.yaml
+	kubectl delete -f $(K8S_DIR)/redis.yaml --ignore-not-found=true
 	kubectl wait --for=delete -f $(K8S_DIR)/redis.yaml --timeout=60s || true
+	kubectl delete -f $(K8S_DIR)/redis-multi.yaml --ignore-not-found=true
+	kubectl wait --for=delete -f $(K8S_DIR)/redis-multi.yaml --timeout=60s || true
 	kubectl apply -f $(K8S_DIR)/redis.yaml
+	kubectl apply -f $(K8S_DIR)/redis-multi.yaml

demo/monolith/Makefile

@@ -1,4 +1,4 @@
-IMAGE_NAME ?= docker.io/tlg2132/demo-monolith
+IMAGE_NAME ?= docker.io/eirn/demo-monolith
 IMAGE_TAG  ?= latest
 
 # Kubernetes manifest files location

demo/monolith/frontend/handlers.go

@@ -181,15 +181,16 @@ func (h *APIHandlers) SaveHandler(w http.ResponseWriter, r *http.Request) {
 	}
 
 	// update timeline asynchronously to match DeathStarBench use of a queue
-	serviceCallStart = time.Now()
-	_, err = h.TimelineService.UpdateTimeline(ctx, timelineUpdateReq)
-	// TODO measure latency on the worker task instead of here
-	util.ObserveHist(serviceCallLatHist.WithLabelValues("timelineservice", "UpdateTimeline"), float64(time.Since(serviceCallStart).Milliseconds()))
-	if err != nil {
-		// Log error, but don't fail the entire Save operation for a timeline update failure
-		logger.Printf("SaveHandler: failed to update timeline for user %s, post %s: %v", userId, postId, err)
-	}
-	logger.Printf("SaveHandler: PostId %s, User %s, Text: %s, Image IDs: %v", postId, userId, text, imageIds)
+	go func(req timelineTypes.UpdateReq) {
+		serviceCallStart := time.Now()
+		_, err = h.TimelineService.UpdateTimeline(ctx, req)
+		util.ObserveHist(serviceCallLatHist.WithLabelValues("timelineservice", "UpdateTimeline"), float64(time.Since(serviceCallStart).Milliseconds()))
+		if err != nil {
+			// Log error, but don't fail the entire Save operation for a timeline update failure
+			logger.Printf("SaveHandler: failed to update timeline for user %s, post %s: %v", userId, postId, err)
+		}
+		logger.Printf("SaveHandler: PostId %s, User %s, Text: %s, Image IDs: %v", postId, userId, text, imageIds)
+	}(timelineUpdateReq)
 
 	resp := UpdateResp{PostId: postId} // Use type from frontend/types.go
 	writeJSONResponse(w, http.StatusOK, resp)

demo/monolith/k8s/monolith-deployment.yaml

@@ -20,19 +20,10 @@ spec:
         dapr.io/app-id: "monolith"
         dapr.io/app-port: "8080"
     spec:
-      tolerations:
-      - key: "tier"
-        operator: "Equal"
-        value: "entrypoint"
-        effect: "PreferNoSchedule"
-      - key: "tier"
-        operator: "Equal"
-        value: "backend"
-        effect: "PreferNoSchedule"
       containers:
       - name: monolith-app
         imagePullPolicy: Always
-        image: ghcr.io/tgoodwin/demo-monolith:workpool
+        image: docker.io/eirn/demo-monolith:dapr
         ports:
         - name: http-app
           containerPort: 8080
@@ -61,6 +52,7 @@ spec:
             resourceFieldRef:
               containerName: monolith-app
               resource: limits.memory # Expresses value in bytes
+
         # If using a Kubernetes Secret for the password, it would look like this:
         # - name: REDIS_PASSWORD
         #   valueFrom:
@@ -72,5 +64,4 @@ spec:
             memory: "128Mi"
             cpu: "500m"
           limits:
-            memory: "4Gi"
             cpu: "4000m"