Iterate to get all pages when reading history (#123)

Author: Tamer Eldeeb

.gen/go/shared/shared.go

@@ -395,18 +395,48 @@ return int64(*p), nil
 type DecisionTaskFailedCause int64
 const (
   DecisionTaskFailedCause_UNHANDLED_DECISION DecisionTaskFailedCause = 0
+  DecisionTaskFailedCause_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES DecisionTaskFailedCause = 1
+  DecisionTaskFailedCause_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES DecisionTaskFailedCause = 2
+  DecisionTaskFailedCause_BAD_START_TIMER_ATTRIBUTES DecisionTaskFailedCause = 3
+  DecisionTaskFailedCause_BAD_CANCEL_TIMER_ATTRIBUTES DecisionTaskFailedCause = 4
+  DecisionTaskFailedCause_BAD_RECORD_MARKER_ATTRIBUTES DecisionTaskFailedCause = 5
+  DecisionTaskFailedCause_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES DecisionTaskFailedCause = 6
+  DecisionTaskFailedCause_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES DecisionTaskFailedCause = 7
+  DecisionTaskFailedCause_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES DecisionTaskFailedCause = 8
+  DecisionTaskFailedCause_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES DecisionTaskFailedCause = 9
+  DecisionTaskFailedCause_BAD_CONTINUE_AS_NEW_ATTRIBUTES DecisionTaskFailedCause = 10
 )
 
 func (p DecisionTaskFailedCause) String() string {
   switch p {
   case DecisionTaskFailedCause_UNHANDLED_DECISION: return "UNHANDLED_DECISION"
+  case DecisionTaskFailedCause_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES: return "BAD_SCHEDULE_ACTIVITY_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES: return "BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_START_TIMER_ATTRIBUTES: return "BAD_START_TIMER_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_CANCEL_TIMER_ATTRIBUTES: return "BAD_CANCEL_TIMER_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_RECORD_MARKER_ATTRIBUTES: return "BAD_RECORD_MARKER_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES: return "BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES: return "BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES: return "BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES: return "BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES"
+  case DecisionTaskFailedCause_BAD_CONTINUE_AS_NEW_ATTRIBUTES: return "BAD_CONTINUE_AS_NEW_ATTRIBUTES"
   }
   return "<UNSET>"
 }
 
 func DecisionTaskFailedCauseFromString(s string) (DecisionTaskFailedCause, error) {
   switch s {
   case "UNHANDLED_DECISION": return DecisionTaskFailedCause_UNHANDLED_DECISION, nil 
+  case "BAD_SCHEDULE_ACTIVITY_ATTRIBUTES": return DecisionTaskFailedCause_BAD_SCHEDULE_ACTIVITY_ATTRIBUTES, nil 
+  case "BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES": return DecisionTaskFailedCause_BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES, nil 
+  case "BAD_START_TIMER_ATTRIBUTES": return DecisionTaskFailedCause_BAD_START_TIMER_ATTRIBUTES, nil 
+  case "BAD_CANCEL_TIMER_ATTRIBUTES": return DecisionTaskFailedCause_BAD_CANCEL_TIMER_ATTRIBUTES, nil 
+  case "BAD_RECORD_MARKER_ATTRIBUTES": return DecisionTaskFailedCause_BAD_RECORD_MARKER_ATTRIBUTES, nil 
+  case "BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES": return DecisionTaskFailedCause_BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES, nil 
+  case "BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES": return DecisionTaskFailedCause_BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES, nil 
+  case "BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES": return DecisionTaskFailedCause_BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES, nil 
+  case "BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES": return DecisionTaskFailedCause_BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES, nil 
+  case "BAD_CONTINUE_AS_NEW_ATTRIBUTES": return DecisionTaskFailedCause_BAD_CONTINUE_AS_NEW_ATTRIBUTES, nil 
   }
   return DecisionTaskFailedCause(0), fmt.Errorf("not a valid DecisionTaskFailedCause string")
 }
@@ -17366,6 +17396,7 @@ func (p *PollForDecisionTaskRequest) String() string {
 //  - PreviousStartedEventId
 //  - StartedEventId
 //  - History
+//  - NextPageToken
 type PollForDecisionTaskResponse struct {
   // unused fields # 1 to 9
   TaskToken []byte `thrift:"taskToken,10" db:"taskToken" json:"taskToken,omitempty"`
@@ -17379,6 +17410,8 @@ type PollForDecisionTaskResponse struct {
   StartedEventId *int64 `thrift:"startedEventId,50" db:"startedEventId" json:"startedEventId,omitempty"`
   // unused fields # 51 to 59
   History *History `thrift:"history,60" db:"history" json:"history,omitempty"`
+  // unused fields # 61 to 69
+  NextPageToken []byte `thrift:"nextPageToken,70" db:"nextPageToken" json:"nextPageToken,omitempty"`
 }
 
 func NewPollForDecisionTaskResponse() *PollForDecisionTaskResponse {
@@ -17425,6 +17458,11 @@ func (p *PollForDecisionTaskResponse) GetHistory() *History {
   }
 return p.History
 }
+var PollForDecisionTaskResponse_NextPageToken_DEFAULT []byte
+
+func (p *PollForDecisionTaskResponse) GetNextPageToken() []byte {
+  return p.NextPageToken
+}
 func (p *PollForDecisionTaskResponse) IsSetTaskToken() bool {
   return p.TaskToken != nil
 }
@@ -17449,6 +17487,10 @@ func (p *PollForDecisionTaskResponse) IsSetHistory() bool {
   return p.History != nil
 }
 
+func (p *PollForDecisionTaskResponse) IsSetNextPageToken() bool {
+  return p.NextPageToken != nil
+}
+
 func (p *PollForDecisionTaskResponse) Read(iprot thrift.TProtocol) error {
   if _, err := iprot.ReadStructBegin(); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err)
@@ -17486,6 +17528,10 @@ func (p *PollForDecisionTaskResponse) Read(iprot thrift.TProtocol) error {
       if err := p.ReadField60(iprot); err != nil {
         return err
       }
+    case 70:
+      if err := p.ReadField70(iprot); err != nil {
+        return err
+      }
     default:
       if err := iprot.Skip(fieldTypeId); err != nil {
         return err
@@ -17552,6 +17598,15 @@ func (p *PollForDecisionTaskResponse)  ReadField60(iprot thrift.TProtocol) error
   return nil
 }
 
+func (p *PollForDecisionTaskResponse)  ReadField70(iprot thrift.TProtocol) error {
+  if v, err := iprot.ReadBinary(); err != nil {
+  return thrift.PrependError("error reading field 70: ", err)
+} else {
+  p.NextPageToken = v
+}
+  return nil
+}
+
 func (p *PollForDecisionTaskResponse) Write(oprot thrift.TProtocol) error {
   if err := oprot.WriteStructBegin("PollForDecisionTaskResponse"); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) }
@@ -17562,6 +17617,7 @@ func (p *PollForDecisionTaskResponse) Write(oprot thrift.TProtocol) error {
     if err := p.writeField40(oprot); err != nil { return err }
     if err := p.writeField50(oprot); err != nil { return err }
     if err := p.writeField60(oprot); err != nil { return err }
+    if err := p.writeField70(oprot); err != nil { return err }
   }
   if err := oprot.WriteFieldStop(); err != nil {
     return thrift.PrependError("write field stop error: ", err) }
@@ -17645,6 +17701,18 @@ func (p *PollForDecisionTaskResponse) writeField60(oprot thrift.TProtocol) (err
   return err
 }
 
+func (p *PollForDecisionTaskResponse) writeField70(oprot thrift.TProtocol) (err error) {
+  if p.IsSetNextPageToken() {
+    if err := oprot.WriteFieldBegin("nextPageToken", thrift.STRING, 70); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field begin error 70:nextPageToken: ", p), err) }
+    if err := oprot.WriteBinary(p.NextPageToken); err != nil {
+    return thrift.PrependError(fmt.Sprintf("%T.nextPageToken (70) field write error: ", p), err) }
+    if err := oprot.WriteFieldEnd(); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field end error 70:nextPageToken: ", p), err) }
+  }
+  return err
+}
+
 func (p *PollForDecisionTaskResponse) String() string {
   if p == nil {
     return "<nil>"
@@ -19544,11 +19612,17 @@ func (p *RequestCancelWorkflowExecutionRequest) String() string {
 // Attributes:
 //  - Domain
 //  - Execution
+//  - MaximumPageSize
+//  - NextPageToken
 type GetWorkflowExecutionHistoryRequest struct {
   // unused fields # 1 to 9
   Domain *string `thrift:"domain,10" db:"domain" json:"domain,omitempty"`
   // unused fields # 11 to 19
   Execution *WorkflowExecution `thrift:"execution,20" db:"execution" json:"execution,omitempty"`
+  // unused fields # 21 to 29
+  MaximumPageSize *int32 `thrift:"maximumPageSize,30" db:"maximumPageSize" json:"maximumPageSize,omitempty"`
+  // unused fields # 31 to 39
+  NextPageToken []byte `thrift:"nextPageToken,40" db:"nextPageToken" json:"nextPageToken,omitempty"`
 }
 
 func NewGetWorkflowExecutionHistoryRequest() *GetWorkflowExecutionHistoryRequest {
@@ -19569,6 +19643,18 @@ func (p *GetWorkflowExecutionHistoryRequest) GetExecution() *WorkflowExecution {
   }
 return p.Execution
 }
+var GetWorkflowExecutionHistoryRequest_MaximumPageSize_DEFAULT int32
+func (p *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32 {
+  if !p.IsSetMaximumPageSize() {
+    return GetWorkflowExecutionHistoryRequest_MaximumPageSize_DEFAULT
+  }
+return *p.MaximumPageSize
+}
+var GetWorkflowExecutionHistoryRequest_NextPageToken_DEFAULT []byte
+
+func (p *GetWorkflowExecutionHistoryRequest) GetNextPageToken() []byte {
+  return p.NextPageToken
+}
 func (p *GetWorkflowExecutionHistoryRequest) IsSetDomain() bool {
   return p.Domain != nil
 }
@@ -19577,6 +19663,14 @@ func (p *GetWorkflowExecutionHistoryRequest) IsSetExecution() bool {
   return p.Execution != nil
 }
 
+func (p *GetWorkflowExecutionHistoryRequest) IsSetMaximumPageSize() bool {
+  return p.MaximumPageSize != nil
+}
+
+func (p *GetWorkflowExecutionHistoryRequest) IsSetNextPageToken() bool {
+  return p.NextPageToken != nil
+}
+
 func (p *GetWorkflowExecutionHistoryRequest) Read(iprot thrift.TProtocol) error {
   if _, err := iprot.ReadStructBegin(); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err)
@@ -19598,6 +19692,14 @@ func (p *GetWorkflowExecutionHistoryRequest) Read(iprot thrift.TProtocol) error
       if err := p.ReadField20(iprot); err != nil {
         return err
       }
+    case 30:
+      if err := p.ReadField30(iprot); err != nil {
+        return err
+      }
+    case 40:
+      if err := p.ReadField40(iprot); err != nil {
+        return err
+      }
     default:
       if err := iprot.Skip(fieldTypeId); err != nil {
         return err
@@ -19630,12 +19732,32 @@ func (p *GetWorkflowExecutionHistoryRequest)  ReadField20(iprot thrift.TProtocol
   return nil
 }
 
+func (p *GetWorkflowExecutionHistoryRequest)  ReadField30(iprot thrift.TProtocol) error {
+  if v, err := iprot.ReadI32(); err != nil {
+  return thrift.PrependError("error reading field 30: ", err)
+} else {
+  p.MaximumPageSize = &v
+}
+  return nil
+}
+
+func (p *GetWorkflowExecutionHistoryRequest)  ReadField40(iprot thrift.TProtocol) error {
+  if v, err := iprot.ReadBinary(); err != nil {
+  return thrift.PrependError("error reading field 40: ", err)
+} else {
+  p.NextPageToken = v
+}
+  return nil
+}
+
 func (p *GetWorkflowExecutionHistoryRequest) Write(oprot thrift.TProtocol) error {
   if err := oprot.WriteStructBegin("GetWorkflowExecutionHistoryRequest"); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) }
   if p != nil {
     if err := p.writeField10(oprot); err != nil { return err }
     if err := p.writeField20(oprot); err != nil { return err }
+    if err := p.writeField30(oprot); err != nil { return err }
+    if err := p.writeField40(oprot); err != nil { return err }
   }
   if err := oprot.WriteFieldStop(); err != nil {
     return thrift.PrependError("write field stop error: ", err) }
@@ -19669,6 +19791,30 @@ func (p *GetWorkflowExecutionHistoryRequest) writeField20(oprot thrift.TProtocol
   return err
 }
 
+func (p *GetWorkflowExecutionHistoryRequest) writeField30(oprot thrift.TProtocol) (err error) {
+  if p.IsSetMaximumPageSize() {
+    if err := oprot.WriteFieldBegin("maximumPageSize", thrift.I32, 30); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field begin error 30:maximumPageSize: ", p), err) }
+    if err := oprot.WriteI32(int32(*p.MaximumPageSize)); err != nil {
+    return thrift.PrependError(fmt.Sprintf("%T.maximumPageSize (30) field write error: ", p), err) }
+    if err := oprot.WriteFieldEnd(); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field end error 30:maximumPageSize: ", p), err) }
+  }
+  return err
+}
+
+func (p *GetWorkflowExecutionHistoryRequest) writeField40(oprot thrift.TProtocol) (err error) {
+  if p.IsSetNextPageToken() {
+    if err := oprot.WriteFieldBegin("nextPageToken", thrift.STRING, 40); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field begin error 40:nextPageToken: ", p), err) }
+    if err := oprot.WriteBinary(p.NextPageToken); err != nil {
+    return thrift.PrependError(fmt.Sprintf("%T.nextPageToken (40) field write error: ", p), err) }
+    if err := oprot.WriteFieldEnd(); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field end error 40:nextPageToken: ", p), err) }
+  }
+  return err
+}
+
 func (p *GetWorkflowExecutionHistoryRequest) String() string {
   if p == nil {
     return "<nil>"
@@ -19678,9 +19824,12 @@ func (p *GetWorkflowExecutionHistoryRequest) String() string {
 
 // Attributes:
 //  - History
+//  - NextPageToken
 type GetWorkflowExecutionHistoryResponse struct {
   // unused fields # 1 to 9
   History *History `thrift:"history,10" db:"history" json:"history,omitempty"`
+  // unused fields # 11 to 19
+  NextPageToken []byte `thrift:"nextPageToken,20" db:"nextPageToken" json:"nextPageToken,omitempty"`
 }
 
 func NewGetWorkflowExecutionHistoryResponse() *GetWorkflowExecutionHistoryResponse {
@@ -19694,10 +19843,19 @@ func (p *GetWorkflowExecutionHistoryResponse) GetHistory() *History {
   }
 return p.History
 }
+var GetWorkflowExecutionHistoryResponse_NextPageToken_DEFAULT []byte
+
+func (p *GetWorkflowExecutionHistoryResponse) GetNextPageToken() []byte {
+  return p.NextPageToken
+}
 func (p *GetWorkflowExecutionHistoryResponse) IsSetHistory() bool {
   return p.History != nil
 }
 
+func (p *GetWorkflowExecutionHistoryResponse) IsSetNextPageToken() bool {
+  return p.NextPageToken != nil
+}
+
 func (p *GetWorkflowExecutionHistoryResponse) Read(iprot thrift.TProtocol) error {
   if _, err := iprot.ReadStructBegin(); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err)
@@ -19715,6 +19873,10 @@ func (p *GetWorkflowExecutionHistoryResponse) Read(iprot thrift.TProtocol) error
       if err := p.ReadField10(iprot); err != nil {
         return err
       }
+    case 20:
+      if err := p.ReadField20(iprot); err != nil {
+        return err
+      }
     default:
       if err := iprot.Skip(fieldTypeId); err != nil {
         return err
@@ -19738,11 +19900,21 @@ func (p *GetWorkflowExecutionHistoryResponse)  ReadField10(iprot thrift.TProtoco
   return nil
 }
 
+func (p *GetWorkflowExecutionHistoryResponse)  ReadField20(iprot thrift.TProtocol) error {
+  if v, err := iprot.ReadBinary(); err != nil {
+  return thrift.PrependError("error reading field 20: ", err)
+} else {
+  p.NextPageToken = v
+}
+  return nil
+}
+
 func (p *GetWorkflowExecutionHistoryResponse) Write(oprot thrift.TProtocol) error {
   if err := oprot.WriteStructBegin("GetWorkflowExecutionHistoryResponse"); err != nil {
     return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) }
   if p != nil {
     if err := p.writeField10(oprot); err != nil { return err }
+    if err := p.writeField20(oprot); err != nil { return err }
   }
   if err := oprot.WriteFieldStop(); err != nil {
     return thrift.PrependError("write field stop error: ", err) }
@@ -19764,6 +19936,18 @@ func (p *GetWorkflowExecutionHistoryResponse) writeField10(oprot thrift.TProtoco
   return err
 }
 
+func (p *GetWorkflowExecutionHistoryResponse) writeField20(oprot thrift.TProtocol) (err error) {
+  if p.IsSetNextPageToken() {
+    if err := oprot.WriteFieldBegin("nextPageToken", thrift.STRING, 20); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field begin error 20:nextPageToken: ", p), err) }
+    if err := oprot.WriteBinary(p.NextPageToken); err != nil {
+    return thrift.PrependError(fmt.Sprintf("%T.nextPageToken (20) field write error: ", p), err) }
+    if err := oprot.WriteFieldEnd(); err != nil {
+      return thrift.PrependError(fmt.Sprintf("%T write field end error 20:nextPageToken: ", p), err) }
+  }
+  return err
+}
+
 func (p *GetWorkflowExecutionHistoryResponse) String() string {
   if p == nil {
     return "<nil>"

idl/github.com/uber/cadence/shared.thrift

@@ -116,6 +116,16 @@ enum EventType {
 
 enum DecisionTaskFailedCause {
   UNHANDLED_DECISION,
+  BAD_SCHEDULE_ACTIVITY_ATTRIBUTES,
+  BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES,
+  BAD_START_TIMER_ATTRIBUTES,
+  BAD_CANCEL_TIMER_ATTRIBUTES,
+  BAD_RECORD_MARKER_ATTRIBUTES,
+  BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES,
+  BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES,
+  BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES,
+  BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES,
+  BAD_CONTINUE_AS_NEW_ATTRIBUTES,
 }
 
 enum CancelExternalWorkflowExecutionFailedCause {
@@ -667,6 +677,7 @@ struct PollForDecisionTaskResponse {
   40: optional i64 (js.type = "Long") previousStartedEventId
   50: optional i64 (js.type = "Long") startedEventId
   60: optional History history
+  70: optional binary nextPageToken
 }
 
 struct RespondDecisionTaskCompletedRequest {
@@ -734,10 +745,13 @@ struct RequestCancelWorkflowExecutionRequest {
 struct GetWorkflowExecutionHistoryRequest {
   10: optional string domain
   20: optional WorkflowExecution execution
+  30: optional i32 maximumPageSize
+  40: optional binary nextPageToken
 }
 
 struct GetWorkflowExecutionHistoryResponse {
   10: optional History history
+  20: optional binary nextPageToken
 }
 
 struct SignalWorkflowExecutionRequest {