feat: support headers for message (#108)

Signed-off-by: Yashash H L <[email protected]>
numaproj · Mar 21, 2024 · 526a7c6 · 526a7c6
1 parent 40335cf
commit 526a7c6
Show file tree

Hide file tree

Showing 43 changed files with 705 additions and 437 deletions.
diff --git a/Makefile b/Makefile
@@ -16,4 +16,9 @@ proto:
 generate:
 	go generate ./...
 
+.PHONY: image-push-all
+image-push-all:
+	for dir in $(shell find ./pkg -name 'Makefile' -exec dirname {} \;); do \
+		$(MAKE) -C $$dir image-push TAG=$(TAG); \
+	done
 
diff --git a/pkg/apis/proto/map/v1/map.pb.go b/pkg/apis/proto/map/v1/map.pb.go
diff --git a/pkg/apis/proto/map/v1/map.proto b/pkg/apis/proto/map/v1/map.proto
@@ -23,6 +23,7 @@ message MapRequest {
   bytes value = 2;
   google.protobuf.Timestamp event_time = 3;
   google.protobuf.Timestamp watermark = 4;
+  map<string, string> headers = 5;
 }
 
 /**