Class: CadenceThrift::WorkflowService::Client
- Inherits:
-
Object
- Object
- CadenceThrift::WorkflowService::Client
- Includes:
- Thrift::Client
- Defined in:
- lib/gen/thrift/workflow_service.rb
Instance Method Summary collapse
- #CountWorkflowExecutions(countRequest) ⇒ Object
- #DeprecateDomain(deprecateRequest) ⇒ Object
- #DescribeDomain(describeRequest) ⇒ Object
- #DescribeTaskList(request) ⇒ Object
- #DescribeWorkflowExecution(describeRequest) ⇒ Object
- #GetSearchAttributes ⇒ Object
- #GetWorkflowExecutionHistory(getRequest) ⇒ Object
- #ListArchivedWorkflowExecutions(listRequest) ⇒ Object
- #ListClosedWorkflowExecutions(listRequest) ⇒ Object
- #ListDomains(listRequest) ⇒ Object
- #ListOpenWorkflowExecutions(listRequest) ⇒ Object
- #ListWorkflowExecutions(listRequest) ⇒ Object
- #PollForActivityTask(pollRequest) ⇒ Object
- #PollForDecisionTask(pollRequest) ⇒ Object
- #QueryWorkflow(queryRequest) ⇒ Object
- #RecordActivityTaskHeartbeat(heartbeatRequest) ⇒ Object
- #RecordActivityTaskHeartbeatByID(heartbeatRequest) ⇒ Object
- #recv_CountWorkflowExecutions ⇒ Object
- #recv_DeprecateDomain ⇒ Object
- #recv_DescribeDomain ⇒ Object
- #recv_DescribeTaskList ⇒ Object
- #recv_DescribeWorkflowExecution ⇒ Object
- #recv_GetSearchAttributes ⇒ Object
- #recv_GetWorkflowExecutionHistory ⇒ Object
- #recv_ListArchivedWorkflowExecutions ⇒ Object
- #recv_ListClosedWorkflowExecutions ⇒ Object
- #recv_ListDomains ⇒ Object
- #recv_ListOpenWorkflowExecutions ⇒ Object
- #recv_ListWorkflowExecutions ⇒ Object
- #recv_PollForActivityTask ⇒ Object
- #recv_PollForDecisionTask ⇒ Object
- #recv_QueryWorkflow ⇒ Object
- #recv_RecordActivityTaskHeartbeat ⇒ Object
- #recv_RecordActivityTaskHeartbeatByID ⇒ Object
- #recv_RegisterDomain ⇒ Object
- #recv_RequestCancelWorkflowExecution ⇒ Object
- #recv_ResetStickyTaskList ⇒ Object
- #recv_ResetWorkflowExecution ⇒ Object
- #recv_RespondActivityTaskCanceled ⇒ Object
- #recv_RespondActivityTaskCanceledByID ⇒ Object
- #recv_RespondActivityTaskCompleted ⇒ Object
- #recv_RespondActivityTaskCompletedByID ⇒ Object
- #recv_RespondActivityTaskFailed ⇒ Object
- #recv_RespondActivityTaskFailedByID ⇒ Object
- #recv_RespondDecisionTaskCompleted ⇒ Object
- #recv_RespondDecisionTaskFailed ⇒ Object
- #recv_RespondQueryTaskCompleted ⇒ Object
- #recv_ScanWorkflowExecutions ⇒ Object
- #recv_SignalWithStartWorkflowExecution ⇒ Object
- #recv_SignalWorkflowExecution ⇒ Object
- #recv_StartWorkflowExecution ⇒ Object
- #recv_TerminateWorkflowExecution ⇒ Object
- #recv_UpdateDomain ⇒ Object
- #RegisterDomain(registerRequest) ⇒ Object
- #RequestCancelWorkflowExecution(cancelRequest) ⇒ Object
- #ResetStickyTaskList(resetRequest) ⇒ Object
- #ResetWorkflowExecution(resetRequest) ⇒ Object
- #RespondActivityTaskCanceled(canceledRequest) ⇒ Object
- #RespondActivityTaskCanceledByID(canceledRequest) ⇒ Object
- #RespondActivityTaskCompleted(completeRequest) ⇒ Object
- #RespondActivityTaskCompletedByID(completeRequest) ⇒ Object
- #RespondActivityTaskFailed(failRequest) ⇒ Object
- #RespondActivityTaskFailedByID(failRequest) ⇒ Object
- #RespondDecisionTaskCompleted(completeRequest) ⇒ Object
- #RespondDecisionTaskFailed(failedRequest) ⇒ Object
- #RespondQueryTaskCompleted(completeRequest) ⇒ Object
- #ScanWorkflowExecutions(listRequest) ⇒ Object
- #send_CountWorkflowExecutions(countRequest) ⇒ Object
- #send_DeprecateDomain(deprecateRequest) ⇒ Object
- #send_DescribeDomain(describeRequest) ⇒ Object
- #send_DescribeTaskList(request) ⇒ Object
- #send_DescribeWorkflowExecution(describeRequest) ⇒ Object
- #send_GetSearchAttributes ⇒ Object
- #send_GetWorkflowExecutionHistory(getRequest) ⇒ Object
- #send_ListArchivedWorkflowExecutions(listRequest) ⇒ Object
- #send_ListClosedWorkflowExecutions(listRequest) ⇒ Object
- #send_ListDomains(listRequest) ⇒ Object
- #send_ListOpenWorkflowExecutions(listRequest) ⇒ Object
- #send_ListWorkflowExecutions(listRequest) ⇒ Object
- #send_PollForActivityTask(pollRequest) ⇒ Object
- #send_PollForDecisionTask(pollRequest) ⇒ Object
- #send_QueryWorkflow(queryRequest) ⇒ Object
- #send_RecordActivityTaskHeartbeat(heartbeatRequest) ⇒ Object
- #send_RecordActivityTaskHeartbeatByID(heartbeatRequest) ⇒ Object
- #send_RegisterDomain(registerRequest) ⇒ Object
- #send_RequestCancelWorkflowExecution(cancelRequest) ⇒ Object
- #send_ResetStickyTaskList(resetRequest) ⇒ Object
- #send_ResetWorkflowExecution(resetRequest) ⇒ Object
- #send_RespondActivityTaskCanceled(canceledRequest) ⇒ Object
- #send_RespondActivityTaskCanceledByID(canceledRequest) ⇒ Object
- #send_RespondActivityTaskCompleted(completeRequest) ⇒ Object
- #send_RespondActivityTaskCompletedByID(completeRequest) ⇒ Object
- #send_RespondActivityTaskFailed(failRequest) ⇒ Object
- #send_RespondActivityTaskFailedByID(failRequest) ⇒ Object
- #send_RespondDecisionTaskCompleted(completeRequest) ⇒ Object
- #send_RespondDecisionTaskFailed(failedRequest) ⇒ Object
- #send_RespondQueryTaskCompleted(completeRequest) ⇒ Object
- #send_ScanWorkflowExecutions(listRequest) ⇒ Object
- #send_SignalWithStartWorkflowExecution(signalWithStartRequest) ⇒ Object
- #send_SignalWorkflowExecution(signalRequest) ⇒ Object
- #send_StartWorkflowExecution(startRequest) ⇒ Object
- #send_TerminateWorkflowExecution(terminateRequest) ⇒ Object
- #send_UpdateDomain(updateRequest) ⇒ Object
- #SignalWithStartWorkflowExecution(signalWithStartRequest) ⇒ Object
- #SignalWorkflowExecution(signalRequest) ⇒ Object
- #StartWorkflowExecution(startRequest) ⇒ Object
- #TerminateWorkflowExecution(terminateRequest) ⇒ Object
- #UpdateDomain(updateRequest) ⇒ Object
Instance Method Details
#CountWorkflowExecutions(countRequest) ⇒ Object
625 626 627 628 |
# File 'lib/gen/thrift/workflow_service.rb', line 625 def CountWorkflowExecutions(countRequest) send_CountWorkflowExecutions(countRequest) return recv_CountWorkflowExecutions() end |
#DeprecateDomain(deprecateRequest) ⇒ Object
95 96 97 98 |
# File 'lib/gen/thrift/workflow_service.rb', line 95 def DeprecateDomain(deprecateRequest) send_DeprecateDomain(deprecateRequest) recv_DeprecateDomain() end |
#DescribeDomain(describeRequest) ⇒ Object
34 35 36 37 |
# File 'lib/gen/thrift/workflow_service.rb', line 34 def DescribeDomain(describeRequest) send_DescribeDomain(describeRequest) return recv_DescribeDomain() end |
#DescribeTaskList(request) ⇒ Object
749 750 751 752 |
# File 'lib/gen/thrift/workflow_service.rb', line 749 def DescribeTaskList(request) send_DescribeTaskList(request) return recv_DescribeTaskList() end |
#DescribeWorkflowExecution(describeRequest) ⇒ Object
728 729 730 731 |
# File 'lib/gen/thrift/workflow_service.rb', line 728 def DescribeWorkflowExecution(describeRequest) send_DescribeWorkflowExecution(describeRequest) return recv_DescribeWorkflowExecution() end |
#GetSearchAttributes ⇒ Object
645 646 647 648 |
# File 'lib/gen/thrift/workflow_service.rb', line 645 def GetSearchAttributes() send_GetSearchAttributes() return recv_GetSearchAttributes() end |
#GetWorkflowExecutionHistory(getRequest) ⇒ Object
138 139 140 141 |
# File 'lib/gen/thrift/workflow_service.rb', line 138 def GetWorkflowExecutionHistory(getRequest) send_GetWorkflowExecutionHistory(getRequest) return recv_GetWorkflowExecutionHistory() end |
#ListArchivedWorkflowExecutions(listRequest) ⇒ Object
585 586 587 588 |
# File 'lib/gen/thrift/workflow_service.rb', line 585 def ListArchivedWorkflowExecutions(listRequest) send_ListArchivedWorkflowExecutions(listRequest) return recv_ListArchivedWorkflowExecutions() end |
#ListClosedWorkflowExecutions(listRequest) ⇒ Object
545 546 547 548 |
# File 'lib/gen/thrift/workflow_service.rb', line 545 def ListClosedWorkflowExecutions(listRequest) send_ListClosedWorkflowExecutions(listRequest) return recv_ListClosedWorkflowExecutions() end |
#ListDomains(listRequest) ⇒ Object
54 55 56 57 |
# File 'lib/gen/thrift/workflow_service.rb', line 54 def ListDomains(listRequest) send_ListDomains(listRequest) return recv_ListDomains() end |
#ListOpenWorkflowExecutions(listRequest) ⇒ Object
524 525 526 527 |
# File 'lib/gen/thrift/workflow_service.rb', line 524 def ListOpenWorkflowExecutions(listRequest) send_ListOpenWorkflowExecutions(listRequest) return recv_ListOpenWorkflowExecutions() end |
#ListWorkflowExecutions(listRequest) ⇒ Object
565 566 567 568 |
# File 'lib/gen/thrift/workflow_service.rb', line 565 def ListWorkflowExecutions(listRequest) send_ListWorkflowExecutions(listRequest) return recv_ListWorkflowExecutions() end |
#PollForActivityTask(pollRequest) ⇒ Object
223 224 225 226 |
# File 'lib/gen/thrift/workflow_service.rb', line 223 def PollForActivityTask(pollRequest) send_PollForActivityTask(pollRequest) return recv_PollForActivityTask() end |
#PollForDecisionTask(pollRequest) ⇒ Object
158 159 160 161 |
# File 'lib/gen/thrift/workflow_service.rb', line 158 def PollForDecisionTask(pollRequest) send_PollForDecisionTask(pollRequest) return recv_PollForDecisionTask() end |
#QueryWorkflow(queryRequest) ⇒ Object
706 707 708 709 |
# File 'lib/gen/thrift/workflow_service.rb', line 706 def QueryWorkflow(queryRequest) send_QueryWorkflow(queryRequest) return recv_QueryWorkflow() end |
#RecordActivityTaskHeartbeat(heartbeatRequest) ⇒ Object
245 246 247 248 |
# File 'lib/gen/thrift/workflow_service.rb', line 245 def RecordActivityTaskHeartbeat(heartbeatRequest) send_RecordActivityTaskHeartbeat(heartbeatRequest) return recv_RecordActivityTaskHeartbeat() end |
#RecordActivityTaskHeartbeatByID(heartbeatRequest) ⇒ Object
267 268 269 270 |
# File 'lib/gen/thrift/workflow_service.rb', line 267 def RecordActivityTaskHeartbeatByID(heartbeatRequest) send_RecordActivityTaskHeartbeatByID(heartbeatRequest) return recv_RecordActivityTaskHeartbeatByID() end |
#recv_CountWorkflowExecutions ⇒ Object
634 635 636 637 638 639 640 641 642 643 |
# File 'lib/gen/thrift/workflow_service.rb', line 634 def recv_CountWorkflowExecutions() result = (CountWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CountWorkflowExecutions failed: unknown result') end |
#recv_DeprecateDomain ⇒ Object
104 105 106 107 108 109 110 111 112 113 |
# File 'lib/gen/thrift/workflow_service.rb', line 104 def recv_DeprecateDomain() result = (DeprecateDomain_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_DescribeDomain ⇒ Object
43 44 45 46 47 48 49 50 51 52 |
# File 'lib/gen/thrift/workflow_service.rb', line 43 def recv_DescribeDomain() result = (DescribeDomain_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeDomain failed: unknown result') end |
#recv_DescribeTaskList ⇒ Object
758 759 760 761 762 763 764 765 766 767 768 |
# File 'lib/gen/thrift/workflow_service.rb', line 758 def recv_DescribeTaskList() result = (DescribeTaskList_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeTaskList failed: unknown result') end |
#recv_DescribeWorkflowExecution ⇒ Object
737 738 739 740 741 742 743 744 745 746 747 |
# File 'lib/gen/thrift/workflow_service.rb', line 737 def recv_DescribeWorkflowExecution() result = (DescribeWorkflowExecution_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'DescribeWorkflowExecution failed: unknown result') end |
#recv_GetSearchAttributes ⇒ Object
654 655 656 657 658 659 660 661 |
# File 'lib/gen/thrift/workflow_service.rb', line 654 def recv_GetSearchAttributes() result = (GetSearchAttributes_result) return result.success unless result.success.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetSearchAttributes failed: unknown result') end |
#recv_GetWorkflowExecutionHistory ⇒ Object
147 148 149 150 151 152 153 154 155 156 |
# File 'lib/gen/thrift/workflow_service.rb', line 147 def recv_GetWorkflowExecutionHistory() result = (GetWorkflowExecutionHistory_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetWorkflowExecutionHistory failed: unknown result') end |
#recv_ListArchivedWorkflowExecutions ⇒ Object
594 595 596 597 598 599 600 601 602 603 |
# File 'lib/gen/thrift/workflow_service.rb', line 594 def recv_ListArchivedWorkflowExecutions() result = (ListArchivedWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListArchivedWorkflowExecutions failed: unknown result') end |
#recv_ListClosedWorkflowExecutions ⇒ Object
554 555 556 557 558 559 560 561 562 563 |
# File 'lib/gen/thrift/workflow_service.rb', line 554 def recv_ListClosedWorkflowExecutions() result = (ListClosedWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListClosedWorkflowExecutions failed: unknown result') end |
#recv_ListDomains ⇒ Object
63 64 65 66 67 68 69 70 71 72 |
# File 'lib/gen/thrift/workflow_service.rb', line 63 def recv_ListDomains() result = (ListDomains_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListDomains failed: unknown result') end |
#recv_ListOpenWorkflowExecutions ⇒ Object
533 534 535 536 537 538 539 540 541 542 543 |
# File 'lib/gen/thrift/workflow_service.rb', line 533 def recv_ListOpenWorkflowExecutions() result = (ListOpenWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListOpenWorkflowExecutions failed: unknown result') end |
#recv_ListWorkflowExecutions ⇒ Object
574 575 576 577 578 579 580 581 582 583 |
# File 'lib/gen/thrift/workflow_service.rb', line 574 def recv_ListWorkflowExecutions() result = (ListWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ListWorkflowExecutions failed: unknown result') end |
#recv_PollForActivityTask ⇒ Object
232 233 234 235 236 237 238 239 240 241 242 243 |
# File 'lib/gen/thrift/workflow_service.rb', line 232 def recv_PollForActivityTask() result = (PollForActivityTask_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'PollForActivityTask failed: unknown result') end |
#recv_PollForDecisionTask ⇒ Object
167 168 169 170 171 172 173 174 175 176 177 178 |
# File 'lib/gen/thrift/workflow_service.rb', line 167 def recv_PollForDecisionTask() result = (PollForDecisionTask_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'PollForDecisionTask failed: unknown result') end |
#recv_QueryWorkflow ⇒ Object
715 716 717 718 719 720 721 722 723 724 725 726 |
# File 'lib/gen/thrift/workflow_service.rb', line 715 def recv_QueryWorkflow() result = (QueryWorkflow_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.queryFailedError unless result.queryFailedError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'QueryWorkflow failed: unknown result') end |
#recv_RecordActivityTaskHeartbeat ⇒ Object
254 255 256 257 258 259 260 261 262 263 264 265 |
# File 'lib/gen/thrift/workflow_service.rb', line 254 def recv_RecordActivityTaskHeartbeat() result = (RecordActivityTaskHeartbeat_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RecordActivityTaskHeartbeat failed: unknown result') end |
#recv_RecordActivityTaskHeartbeatByID ⇒ Object
276 277 278 279 280 281 282 283 284 285 286 287 |
# File 'lib/gen/thrift/workflow_service.rb', line 276 def recv_RecordActivityTaskHeartbeatByID() result = (RecordActivityTaskHeartbeatByID_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RecordActivityTaskHeartbeatByID failed: unknown result') end |
#recv_RegisterDomain ⇒ Object
24 25 26 27 28 29 30 31 32 |
# File 'lib/gen/thrift/workflow_service.rb', line 24 def recv_RegisterDomain() result = (RegisterDomain_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.domainExistsError unless result.domainExistsError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RequestCancelWorkflowExecution ⇒ Object
424 425 426 427 428 429 430 431 432 433 434 435 |
# File 'lib/gen/thrift/workflow_service.rb', line 424 def recv_RequestCancelWorkflowExecution() result = (RequestCancelWorkflowExecution_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.cancellationAlreadyRequestedError unless result.cancellationAlreadyRequestedError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_ResetStickyTaskList ⇒ Object
693 694 695 696 697 698 699 700 701 702 703 704 |
# File 'lib/gen/thrift/workflow_service.rb', line 693 def recv_ResetStickyTaskList() result = (ResetStickyTaskList_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetStickyTaskList failed: unknown result') end |
#recv_ResetWorkflowExecution ⇒ Object
490 491 492 493 494 495 496 497 498 499 500 501 |
# File 'lib/gen/thrift/workflow_service.rb', line 490 def recv_ResetWorkflowExecution() result = (ResetWorkflowExecution_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ResetWorkflowExecution failed: unknown result') end |
#recv_RespondActivityTaskCanceled ⇒ Object
382 383 384 385 386 387 388 389 390 391 392 |
# File 'lib/gen/thrift/workflow_service.rb', line 382 def recv_RespondActivityTaskCanceled() result = (RespondActivityTaskCanceled_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondActivityTaskCanceledByID ⇒ Object
403 404 405 406 407 408 409 410 411 412 413 |
# File 'lib/gen/thrift/workflow_service.rb', line 403 def recv_RespondActivityTaskCanceledByID() result = (RespondActivityTaskCanceledByID_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondActivityTaskCompleted ⇒ Object
298 299 300 301 302 303 304 305 306 307 308 |
# File 'lib/gen/thrift/workflow_service.rb', line 298 def recv_RespondActivityTaskCompleted() result = (RespondActivityTaskCompleted_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondActivityTaskCompletedByID ⇒ Object
319 320 321 322 323 324 325 326 327 328 329 |
# File 'lib/gen/thrift/workflow_service.rb', line 319 def recv_RespondActivityTaskCompletedByID() result = (RespondActivityTaskCompletedByID_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondActivityTaskFailed ⇒ Object
340 341 342 343 344 345 346 347 348 349 350 |
# File 'lib/gen/thrift/workflow_service.rb', line 340 def recv_RespondActivityTaskFailed() result = (RespondActivityTaskFailed_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondActivityTaskFailedByID ⇒ Object
361 362 363 364 365 366 367 368 369 370 371 |
# File 'lib/gen/thrift/workflow_service.rb', line 361 def recv_RespondActivityTaskFailedByID() result = (RespondActivityTaskFailedByID_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondDecisionTaskCompleted ⇒ Object
189 190 191 192 193 194 195 196 197 198 199 200 |
# File 'lib/gen/thrift/workflow_service.rb', line 189 def recv_RespondDecisionTaskCompleted() result = (RespondDecisionTaskCompleted_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RespondDecisionTaskCompleted failed: unknown result') end |
#recv_RespondDecisionTaskFailed ⇒ Object
211 212 213 214 215 216 217 218 219 220 221 |
# File 'lib/gen/thrift/workflow_service.rb', line 211 def recv_RespondDecisionTaskFailed() result = (RespondDecisionTaskFailed_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_RespondQueryTaskCompleted ⇒ Object
672 673 674 675 676 677 678 679 680 681 682 |
# File 'lib/gen/thrift/workflow_service.rb', line 672 def recv_RespondQueryTaskCompleted() result = (RespondQueryTaskCompleted_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_ScanWorkflowExecutions ⇒ Object
614 615 616 617 618 619 620 621 622 623 |
# File 'lib/gen/thrift/workflow_service.rb', line 614 def recv_ScanWorkflowExecutions() result = (ScanWorkflowExecutions_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ScanWorkflowExecutions failed: unknown result') end |
#recv_SignalWithStartWorkflowExecution ⇒ Object
467 468 469 470 471 472 473 474 475 476 477 478 479 |
# File 'lib/gen/thrift/workflow_service.rb', line 467 def recv_SignalWithStartWorkflowExecution() result = (SignalWithStartWorkflowExecution_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.workflowAlreadyStartedError unless result.workflowAlreadyStartedError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'SignalWithStartWorkflowExecution failed: unknown result') end |
#recv_SignalWorkflowExecution ⇒ Object
446 447 448 449 450 451 452 453 454 455 456 |
# File 'lib/gen/thrift/workflow_service.rb', line 446 def recv_SignalWorkflowExecution() result = (SignalWorkflowExecution_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_StartWorkflowExecution ⇒ Object
124 125 126 127 128 129 130 131 132 133 134 135 136 |
# File 'lib/gen/thrift/workflow_service.rb', line 124 def recv_StartWorkflowExecution() result = (StartWorkflowExecution_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.sessionAlreadyExistError unless result.sessionAlreadyExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'StartWorkflowExecution failed: unknown result') end |
#recv_TerminateWorkflowExecution ⇒ Object
512 513 514 515 516 517 518 519 520 521 522 |
# File 'lib/gen/thrift/workflow_service.rb', line 512 def recv_TerminateWorkflowExecution() result = (TerminateWorkflowExecution_result) raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.limitExceededError unless result.limitExceededError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? return end |
#recv_UpdateDomain ⇒ Object
83 84 85 86 87 88 89 90 91 92 93 |
# File 'lib/gen/thrift/workflow_service.rb', line 83 def recv_UpdateDomain() result = (UpdateDomain_result) return result.success unless result.success.nil? raise result.badRequestError unless result.badRequestError.nil? raise result.internalServiceError unless result.internalServiceError.nil? raise result.entityNotExistError unless result.entityNotExistError.nil? raise result.serviceBusyError unless result.serviceBusyError.nil? raise result.domainNotActiveError unless result.domainNotActiveError.nil? raise result.clientVersionNotSupportedError unless result.clientVersionNotSupportedError.nil? raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'UpdateDomain failed: unknown result') end |
#RegisterDomain(registerRequest) ⇒ Object
15 16 17 18 |
# File 'lib/gen/thrift/workflow_service.rb', line 15 def RegisterDomain(registerRequest) send_RegisterDomain(registerRequest) recv_RegisterDomain() end |
#RequestCancelWorkflowExecution(cancelRequest) ⇒ Object
415 416 417 418 |
# File 'lib/gen/thrift/workflow_service.rb', line 415 def RequestCancelWorkflowExecution(cancelRequest) send_RequestCancelWorkflowExecution(cancelRequest) recv_RequestCancelWorkflowExecution() end |
#ResetStickyTaskList(resetRequest) ⇒ Object
684 685 686 687 |
# File 'lib/gen/thrift/workflow_service.rb', line 684 def ResetStickyTaskList(resetRequest) send_ResetStickyTaskList(resetRequest) return recv_ResetStickyTaskList() end |
#ResetWorkflowExecution(resetRequest) ⇒ Object
481 482 483 484 |
# File 'lib/gen/thrift/workflow_service.rb', line 481 def ResetWorkflowExecution(resetRequest) send_ResetWorkflowExecution(resetRequest) return recv_ResetWorkflowExecution() end |
#RespondActivityTaskCanceled(canceledRequest) ⇒ Object
373 374 375 376 |
# File 'lib/gen/thrift/workflow_service.rb', line 373 def RespondActivityTaskCanceled(canceledRequest) send_RespondActivityTaskCanceled(canceledRequest) recv_RespondActivityTaskCanceled() end |
#RespondActivityTaskCanceledByID(canceledRequest) ⇒ Object
394 395 396 397 |
# File 'lib/gen/thrift/workflow_service.rb', line 394 def RespondActivityTaskCanceledByID(canceledRequest) send_RespondActivityTaskCanceledByID(canceledRequest) recv_RespondActivityTaskCanceledByID() end |
#RespondActivityTaskCompleted(completeRequest) ⇒ Object
289 290 291 292 |
# File 'lib/gen/thrift/workflow_service.rb', line 289 def RespondActivityTaskCompleted(completeRequest) send_RespondActivityTaskCompleted(completeRequest) recv_RespondActivityTaskCompleted() end |
#RespondActivityTaskCompletedByID(completeRequest) ⇒ Object
310 311 312 313 |
# File 'lib/gen/thrift/workflow_service.rb', line 310 def RespondActivityTaskCompletedByID(completeRequest) send_RespondActivityTaskCompletedByID(completeRequest) recv_RespondActivityTaskCompletedByID() end |
#RespondActivityTaskFailed(failRequest) ⇒ Object
331 332 333 334 |
# File 'lib/gen/thrift/workflow_service.rb', line 331 def RespondActivityTaskFailed(failRequest) send_RespondActivityTaskFailed(failRequest) recv_RespondActivityTaskFailed() end |
#RespondActivityTaskFailedByID(failRequest) ⇒ Object
352 353 354 355 |
# File 'lib/gen/thrift/workflow_service.rb', line 352 def RespondActivityTaskFailedByID(failRequest) send_RespondActivityTaskFailedByID(failRequest) recv_RespondActivityTaskFailedByID() end |
#RespondDecisionTaskCompleted(completeRequest) ⇒ Object
180 181 182 183 |
# File 'lib/gen/thrift/workflow_service.rb', line 180 def RespondDecisionTaskCompleted(completeRequest) send_RespondDecisionTaskCompleted(completeRequest) return recv_RespondDecisionTaskCompleted() end |
#RespondDecisionTaskFailed(failedRequest) ⇒ Object
202 203 204 205 |
# File 'lib/gen/thrift/workflow_service.rb', line 202 def RespondDecisionTaskFailed(failedRequest) send_RespondDecisionTaskFailed(failedRequest) recv_RespondDecisionTaskFailed() end |
#RespondQueryTaskCompleted(completeRequest) ⇒ Object
663 664 665 666 |
# File 'lib/gen/thrift/workflow_service.rb', line 663 def RespondQueryTaskCompleted(completeRequest) send_RespondQueryTaskCompleted(completeRequest) recv_RespondQueryTaskCompleted() end |
#ScanWorkflowExecutions(listRequest) ⇒ Object
605 606 607 608 |
# File 'lib/gen/thrift/workflow_service.rb', line 605 def ScanWorkflowExecutions(listRequest) send_ScanWorkflowExecutions(listRequest) return recv_ScanWorkflowExecutions() end |
#send_CountWorkflowExecutions(countRequest) ⇒ Object
630 631 632 |
# File 'lib/gen/thrift/workflow_service.rb', line 630 def send_CountWorkflowExecutions(countRequest) ('CountWorkflowExecutions', CountWorkflowExecutions_args, :countRequest => countRequest) end |
#send_DeprecateDomain(deprecateRequest) ⇒ Object
100 101 102 |
# File 'lib/gen/thrift/workflow_service.rb', line 100 def send_DeprecateDomain(deprecateRequest) ('DeprecateDomain', DeprecateDomain_args, :deprecateRequest => deprecateRequest) end |
#send_DescribeDomain(describeRequest) ⇒ Object
39 40 41 |
# File 'lib/gen/thrift/workflow_service.rb', line 39 def send_DescribeDomain(describeRequest) ('DescribeDomain', DescribeDomain_args, :describeRequest => describeRequest) end |
#send_DescribeTaskList(request) ⇒ Object
754 755 756 |
# File 'lib/gen/thrift/workflow_service.rb', line 754 def send_DescribeTaskList(request) ('DescribeTaskList', DescribeTaskList_args, :request => request) end |
#send_DescribeWorkflowExecution(describeRequest) ⇒ Object
733 734 735 |
# File 'lib/gen/thrift/workflow_service.rb', line 733 def send_DescribeWorkflowExecution(describeRequest) ('DescribeWorkflowExecution', DescribeWorkflowExecution_args, :describeRequest => describeRequest) end |
#send_GetSearchAttributes ⇒ Object
650 651 652 |
# File 'lib/gen/thrift/workflow_service.rb', line 650 def send_GetSearchAttributes() ('GetSearchAttributes', GetSearchAttributes_args) end |
#send_GetWorkflowExecutionHistory(getRequest) ⇒ Object
143 144 145 |
# File 'lib/gen/thrift/workflow_service.rb', line 143 def send_GetWorkflowExecutionHistory(getRequest) ('GetWorkflowExecutionHistory', GetWorkflowExecutionHistory_args, :getRequest => getRequest) end |
#send_ListArchivedWorkflowExecutions(listRequest) ⇒ Object
590 591 592 |
# File 'lib/gen/thrift/workflow_service.rb', line 590 def send_ListArchivedWorkflowExecutions(listRequest) ('ListArchivedWorkflowExecutions', ListArchivedWorkflowExecutions_args, :listRequest => listRequest) end |
#send_ListClosedWorkflowExecutions(listRequest) ⇒ Object
550 551 552 |
# File 'lib/gen/thrift/workflow_service.rb', line 550 def send_ListClosedWorkflowExecutions(listRequest) ('ListClosedWorkflowExecutions', ListClosedWorkflowExecutions_args, :listRequest => listRequest) end |
#send_ListDomains(listRequest) ⇒ Object
59 60 61 |
# File 'lib/gen/thrift/workflow_service.rb', line 59 def send_ListDomains(listRequest) ('ListDomains', ListDomains_args, :listRequest => listRequest) end |
#send_ListOpenWorkflowExecutions(listRequest) ⇒ Object
529 530 531 |
# File 'lib/gen/thrift/workflow_service.rb', line 529 def send_ListOpenWorkflowExecutions(listRequest) ('ListOpenWorkflowExecutions', ListOpenWorkflowExecutions_args, :listRequest => listRequest) end |
#send_ListWorkflowExecutions(listRequest) ⇒ Object
570 571 572 |
# File 'lib/gen/thrift/workflow_service.rb', line 570 def send_ListWorkflowExecutions(listRequest) ('ListWorkflowExecutions', ListWorkflowExecutions_args, :listRequest => listRequest) end |
#send_PollForActivityTask(pollRequest) ⇒ Object
228 229 230 |
# File 'lib/gen/thrift/workflow_service.rb', line 228 def send_PollForActivityTask(pollRequest) ('PollForActivityTask', PollForActivityTask_args, :pollRequest => pollRequest) end |
#send_PollForDecisionTask(pollRequest) ⇒ Object
163 164 165 |
# File 'lib/gen/thrift/workflow_service.rb', line 163 def send_PollForDecisionTask(pollRequest) ('PollForDecisionTask', PollForDecisionTask_args, :pollRequest => pollRequest) end |
#send_QueryWorkflow(queryRequest) ⇒ Object
711 712 713 |
# File 'lib/gen/thrift/workflow_service.rb', line 711 def send_QueryWorkflow(queryRequest) ('QueryWorkflow', QueryWorkflow_args, :queryRequest => queryRequest) end |
#send_RecordActivityTaskHeartbeat(heartbeatRequest) ⇒ Object
250 251 252 |
# File 'lib/gen/thrift/workflow_service.rb', line 250 def send_RecordActivityTaskHeartbeat(heartbeatRequest) ('RecordActivityTaskHeartbeat', RecordActivityTaskHeartbeat_args, :heartbeatRequest => heartbeatRequest) end |
#send_RecordActivityTaskHeartbeatByID(heartbeatRequest) ⇒ Object
272 273 274 |
# File 'lib/gen/thrift/workflow_service.rb', line 272 def send_RecordActivityTaskHeartbeatByID(heartbeatRequest) ('RecordActivityTaskHeartbeatByID', RecordActivityTaskHeartbeatByID_args, :heartbeatRequest => heartbeatRequest) end |
#send_RegisterDomain(registerRequest) ⇒ Object
20 21 22 |
# File 'lib/gen/thrift/workflow_service.rb', line 20 def send_RegisterDomain(registerRequest) ('RegisterDomain', RegisterDomain_args, :registerRequest => registerRequest) end |
#send_RequestCancelWorkflowExecution(cancelRequest) ⇒ Object
420 421 422 |
# File 'lib/gen/thrift/workflow_service.rb', line 420 def send_RequestCancelWorkflowExecution(cancelRequest) ('RequestCancelWorkflowExecution', RequestCancelWorkflowExecution_args, :cancelRequest => cancelRequest) end |
#send_ResetStickyTaskList(resetRequest) ⇒ Object
689 690 691 |
# File 'lib/gen/thrift/workflow_service.rb', line 689 def send_ResetStickyTaskList(resetRequest) ('ResetStickyTaskList', ResetStickyTaskList_args, :resetRequest => resetRequest) end |
#send_ResetWorkflowExecution(resetRequest) ⇒ Object
486 487 488 |
# File 'lib/gen/thrift/workflow_service.rb', line 486 def send_ResetWorkflowExecution(resetRequest) ('ResetWorkflowExecution', ResetWorkflowExecution_args, :resetRequest => resetRequest) end |
#send_RespondActivityTaskCanceled(canceledRequest) ⇒ Object
378 379 380 |
# File 'lib/gen/thrift/workflow_service.rb', line 378 def send_RespondActivityTaskCanceled(canceledRequest) ('RespondActivityTaskCanceled', RespondActivityTaskCanceled_args, :canceledRequest => canceledRequest) end |
#send_RespondActivityTaskCanceledByID(canceledRequest) ⇒ Object
399 400 401 |
# File 'lib/gen/thrift/workflow_service.rb', line 399 def send_RespondActivityTaskCanceledByID(canceledRequest) ('RespondActivityTaskCanceledByID', RespondActivityTaskCanceledByID_args, :canceledRequest => canceledRequest) end |
#send_RespondActivityTaskCompleted(completeRequest) ⇒ Object
294 295 296 |
# File 'lib/gen/thrift/workflow_service.rb', line 294 def send_RespondActivityTaskCompleted(completeRequest) ('RespondActivityTaskCompleted', RespondActivityTaskCompleted_args, :completeRequest => completeRequest) end |
#send_RespondActivityTaskCompletedByID(completeRequest) ⇒ Object
315 316 317 |
# File 'lib/gen/thrift/workflow_service.rb', line 315 def send_RespondActivityTaskCompletedByID(completeRequest) ('RespondActivityTaskCompletedByID', RespondActivityTaskCompletedByID_args, :completeRequest => completeRequest) end |
#send_RespondActivityTaskFailed(failRequest) ⇒ Object
336 337 338 |
# File 'lib/gen/thrift/workflow_service.rb', line 336 def send_RespondActivityTaskFailed(failRequest) ('RespondActivityTaskFailed', RespondActivityTaskFailed_args, :failRequest => failRequest) end |
#send_RespondActivityTaskFailedByID(failRequest) ⇒ Object
357 358 359 |
# File 'lib/gen/thrift/workflow_service.rb', line 357 def send_RespondActivityTaskFailedByID(failRequest) ('RespondActivityTaskFailedByID', RespondActivityTaskFailedByID_args, :failRequest => failRequest) end |
#send_RespondDecisionTaskCompleted(completeRequest) ⇒ Object
185 186 187 |
# File 'lib/gen/thrift/workflow_service.rb', line 185 def send_RespondDecisionTaskCompleted(completeRequest) ('RespondDecisionTaskCompleted', RespondDecisionTaskCompleted_args, :completeRequest => completeRequest) end |
#send_RespondDecisionTaskFailed(failedRequest) ⇒ Object
207 208 209 |
# File 'lib/gen/thrift/workflow_service.rb', line 207 def send_RespondDecisionTaskFailed(failedRequest) ('RespondDecisionTaskFailed', RespondDecisionTaskFailed_args, :failedRequest => failedRequest) end |
#send_RespondQueryTaskCompleted(completeRequest) ⇒ Object
668 669 670 |
# File 'lib/gen/thrift/workflow_service.rb', line 668 def send_RespondQueryTaskCompleted(completeRequest) ('RespondQueryTaskCompleted', RespondQueryTaskCompleted_args, :completeRequest => completeRequest) end |
#send_ScanWorkflowExecutions(listRequest) ⇒ Object
610 611 612 |
# File 'lib/gen/thrift/workflow_service.rb', line 610 def send_ScanWorkflowExecutions(listRequest) ('ScanWorkflowExecutions', ScanWorkflowExecutions_args, :listRequest => listRequest) end |
#send_SignalWithStartWorkflowExecution(signalWithStartRequest) ⇒ Object
463 464 465 |
# File 'lib/gen/thrift/workflow_service.rb', line 463 def send_SignalWithStartWorkflowExecution(signalWithStartRequest) ('SignalWithStartWorkflowExecution', SignalWithStartWorkflowExecution_args, :signalWithStartRequest => signalWithStartRequest) end |
#send_SignalWorkflowExecution(signalRequest) ⇒ Object
442 443 444 |
# File 'lib/gen/thrift/workflow_service.rb', line 442 def send_SignalWorkflowExecution(signalRequest) ('SignalWorkflowExecution', SignalWorkflowExecution_args, :signalRequest => signalRequest) end |
#send_StartWorkflowExecution(startRequest) ⇒ Object
120 121 122 |
# File 'lib/gen/thrift/workflow_service.rb', line 120 def send_StartWorkflowExecution(startRequest) ('StartWorkflowExecution', StartWorkflowExecution_args, :startRequest => startRequest) end |
#send_TerminateWorkflowExecution(terminateRequest) ⇒ Object
508 509 510 |
# File 'lib/gen/thrift/workflow_service.rb', line 508 def send_TerminateWorkflowExecution(terminateRequest) ('TerminateWorkflowExecution', TerminateWorkflowExecution_args, :terminateRequest => terminateRequest) end |
#send_UpdateDomain(updateRequest) ⇒ Object
79 80 81 |
# File 'lib/gen/thrift/workflow_service.rb', line 79 def send_UpdateDomain(updateRequest) ('UpdateDomain', UpdateDomain_args, :updateRequest => updateRequest) end |
#SignalWithStartWorkflowExecution(signalWithStartRequest) ⇒ Object
458 459 460 461 |
# File 'lib/gen/thrift/workflow_service.rb', line 458 def SignalWithStartWorkflowExecution(signalWithStartRequest) send_SignalWithStartWorkflowExecution(signalWithStartRequest) return recv_SignalWithStartWorkflowExecution() end |
#SignalWorkflowExecution(signalRequest) ⇒ Object
437 438 439 440 |
# File 'lib/gen/thrift/workflow_service.rb', line 437 def SignalWorkflowExecution(signalRequest) send_SignalWorkflowExecution(signalRequest) recv_SignalWorkflowExecution() end |
#StartWorkflowExecution(startRequest) ⇒ Object
115 116 117 118 |
# File 'lib/gen/thrift/workflow_service.rb', line 115 def StartWorkflowExecution(startRequest) send_StartWorkflowExecution(startRequest) return recv_StartWorkflowExecution() end |
#TerminateWorkflowExecution(terminateRequest) ⇒ Object
503 504 505 506 |
# File 'lib/gen/thrift/workflow_service.rb', line 503 def TerminateWorkflowExecution(terminateRequest) send_TerminateWorkflowExecution(terminateRequest) recv_TerminateWorkflowExecution() end |
#UpdateDomain(updateRequest) ⇒ Object
74 75 76 77 |
# File 'lib/gen/thrift/workflow_service.rb', line 74 def UpdateDomain(updateRequest) send_UpdateDomain(updateRequest) return recv_UpdateDomain() end |