Added header to marker (#798)

* Added header to marker * Added marker header copy from the marker decision to the marker event * Added marker test to historyBuilder unit test * Changed header fields to map * update generated files to reflect idl changes * update generated idl file
cadence-workflow · Jun 18, 2018 · 922b0e6 · 922b0e6
1 parent 1733b61
commit 922b0e6
Show file tree

Hide file tree

Showing 5 changed files with 306 additions and 6 deletions.
diff --git a/.gen/go/shared/idl.go b/.gen/go/shared/idl.go
diff --git a/.gen/go/shared/types.go b/.gen/go/shared/types.go
diff --git a/idl/github.com/uber/cadence/shared.thrift b/idl/github.com/uber/cadence/shared.thrift
@@ -234,6 +234,10 @@ enum TaskListKind {
   STICKY,
 }
 
+struct Header {
+    10: optional map<string, binary> fields
+}
+
 struct WorkflowType {
   10: optional string name
 }
@@ -336,6 +340,7 @@ struct SignalExternalWorkflowExecutionDecisionAttributes {
 struct RecordMarkerDecisionAttributes {
   10: optional string markerName
   20: optional binary details
+  30: optional Header header
 }
 
 struct ContinueAsNewWorkflowExecutionDecisionAttributes {
@@ -550,6 +555,7 @@ struct MarkerRecordedEventAttributes {
   10: optional string markerName
   20: optional binary details
   30: optional i64 (js.type = "Long") decisionTaskCompletedEventId
+  40: optional Header header
 }
 
 struct WorkflowExecutionSignaledEventAttributes {

diff --git a/service/history/historyBuilder.go b/service/history/historyBuilder.go
@@ -689,6 +689,7 @@ func (b *historyBuilder) newMarkerRecordedEventAttributes(decisionTaskCompletedE
 	attributes.MarkerName = common.StringPtr(common.StringDefault(request.MarkerName))
 	attributes.Details = request.Details
 	attributes.DecisionTaskCompletedEventId = common.Int64Ptr(decisionTaskCompletedEventID)
+	attributes.Header = request.Header
 	historyEvent.MarkerRecordedEventAttributes = attributes
 
 	return historyEvent