Handle branch token update with long poll API

temporalio · Oct 7, 2023 · 84e68ce · 84e68ce
1 parent d54f4d8
commit 84e68ce
Show file tree

Hide file tree

Showing 14 changed files with 902 additions and 618 deletions.
diff --git a/api/historyservice/v1/request_response.pb.go b/api/historyservice/v1/request_response.pb.go
diff --git a/api/token/v1/message.pb.go b/api/token/v1/message.pb.go
diff --git a/proto/internal/temporal/server/api/historyservice/v1/request_response.proto b/proto/internal/temporal/server/api/historyservice/v1/request_response.proto
@@ -80,6 +80,7 @@ message GetMutableStateRequest {
     temporal.api.common.v1.WorkflowExecution execution = 2;
     int64 expected_next_event_id = 3;
     bytes current_branch_token = 4;
+    temporal.server.api.history.v1.VersionHistoryItem version_history_item = 5;
 }
 
 message GetMutableStateResponse {
@@ -115,6 +116,7 @@ message PollMutableStateRequest {
     temporal.api.common.v1.WorkflowExecution execution = 2;
     int64 expected_next_event_id = 3;
     bytes current_branch_token = 4;
+    temporal.server.api.history.v1.VersionHistoryItem version_history_item = 5;
 }
 
 message PollMutableStateResponse {

diff --git a/proto/internal/temporal/server/api/token/v1/message.proto b/proto/internal/temporal/server/api/token/v1/message.proto
@@ -38,6 +38,7 @@ message HistoryContinuation {
     temporal.server.api.history.v1.TransientWorkflowTaskInfo transient_workflow_task = 7;
     bytes branch_token = 8;
     reserved 9;
+    temporal.server.api.history.v1.VersionHistoryItem version_history_item = 10;
 }
 
 message RawHistoryContinuation{