{-# LANGUAGE AllowAmbiguousTypes #-}
{-# LANGUAGE DataKinds #-}
{-# LANGUAGE KindSignatures #-}
{-# LANGUAGE RankNTypes #-}
{-# LANGUAGE TypeApplications #-}
module Temporal.Core.Client.WorkflowService (
countWorkflowExecutions,
createSchedule,
deleteSchedule,
deprecateNamespace,
describeNamespace,
describeSchedule,
describeTaskQueue,
describeWorkflowExecution,
getClusterInfo,
getSearchAttributes,
getSystemInfo,
getWorkerBuildIdCompatibility,
getWorkflowExecutionHistory,
getWorkflowExecutionHistoryReverse,
listArchivedWorkflowExecutions,
listClosedWorkflowExecutions,
listNamespaces,
listOpenWorkflowExecutions,
listScheduleMatchingTimes,
listSchedules,
listTaskQueuePartitions,
listWorkflowExecutions,
patchSchedule,
pollActivityTaskQueue,
pollWorkflowExecutionUpdate,
pollWorkflowTaskQueue,
queryWorkflow,
recordActivityTaskHeartbeat,
recordActivityTaskHeartbeatById,
registerNamespace,
requestCancelWorkflowExecution,
resetStickyTaskQueue,
resetWorkflowExecution,
respondActivityTaskCanceled,
respondActivityTaskCanceledById,
respondActivityTaskCompleted,
respondActivityTaskCompletedById,
respondActivityTaskFailed,
respondActivityTaskFailedById,
respondQueryTaskCompleted,
respondWorkflowTaskCompleted,
respondWorkflowTaskFailed,
scanWorkflowExecutions,
signalWithStartWorkflowExecution,
signalWorkflowExecution,
startWorkflowExecution,
terminateWorkflowExecution,
updateNamespace,
updateSchedule,
updateWorkflowExecution,
updateWorkerBuildIdCompatibility,
) where
import Proto.Temporal.Api.Workflowservice.V1.RequestResponse
import Proto.Temporal.Api.Workflowservice.V1.Service
import Temporal.Core.Client
foreign import ccall "hs_count_workflow_executions" hs_count_workflow_executions :: PrimRpcCall
countWorkflowExecutions :: Client -> CountWorkflowExecutionsRequest -> IO (Either RpcError CountWorkflowExecutionsResponse)
countWorkflowExecutions :: Client
-> CountWorkflowExecutionsRequest
-> IO (Either RpcError CountWorkflowExecutionsResponse)
countWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"countWorkflowExecutions" PrimRpcCall
hs_count_workflow_executions
foreign import ccall "hs_create_schedule" hs_create_schedule :: PrimRpcCall
createSchedule :: Client -> CreateScheduleRequest -> IO (Either RpcError CreateScheduleResponse)
createSchedule :: Client
-> CreateScheduleRequest
-> IO (Either RpcError CreateScheduleResponse)
createSchedule = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"createSchedule" PrimRpcCall
hs_create_schedule
foreign import ccall "hs_delete_schedule" hs_delete_schedule :: PrimRpcCall
deleteSchedule :: Client -> DeleteScheduleRequest -> IO (Either RpcError DeleteScheduleResponse)
deleteSchedule :: Client
-> DeleteScheduleRequest
-> IO (Either RpcError DeleteScheduleResponse)
deleteSchedule = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"deleteSchedule" PrimRpcCall
hs_delete_schedule
foreign import ccall "hs_deprecate_namespace" hs_deprecate_namespace :: PrimRpcCall
deprecateNamespace :: Client -> DeprecateNamespaceRequest -> IO (Either RpcError DeprecateNamespaceResponse)
deprecateNamespace :: Client
-> DeprecateNamespaceRequest
-> IO (Either RpcError DeprecateNamespaceResponse)
deprecateNamespace = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"deprecateNamespace" PrimRpcCall
hs_deprecate_namespace
foreign import ccall "hs_describe_namespace" hs_describe_namespace :: PrimRpcCall
describeNamespace :: Client -> DescribeNamespaceRequest -> IO (Either RpcError DescribeNamespaceResponse)
describeNamespace :: Client
-> DescribeNamespaceRequest
-> IO (Either RpcError DescribeNamespaceResponse)
describeNamespace = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"describeNamespace" PrimRpcCall
hs_describe_namespace
foreign import ccall "hs_describe_schedule" hs_describe_schedule :: PrimRpcCall
describeSchedule :: Client -> DescribeScheduleRequest -> IO (Either RpcError DescribeScheduleResponse)
describeSchedule :: Client
-> DescribeScheduleRequest
-> IO (Either RpcError DescribeScheduleResponse)
describeSchedule = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"describeSchedule" PrimRpcCall
hs_describe_schedule
foreign import ccall "hs_describe_task_queue" hs_describe_task_queue :: PrimRpcCall
describeTaskQueue :: Client -> DescribeTaskQueueRequest -> IO (Either RpcError DescribeTaskQueueResponse)
describeTaskQueue :: Client
-> DescribeTaskQueueRequest
-> IO (Either RpcError DescribeTaskQueueResponse)
describeTaskQueue = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"describeTaskQueue" PrimRpcCall
hs_describe_task_queue
foreign import ccall "hs_describe_workflow_execution" hs_describe_workflow_execution :: PrimRpcCall
describeWorkflowExecution :: Client -> DescribeWorkflowExecutionRequest -> IO (Either RpcError DescribeWorkflowExecutionResponse)
describeWorkflowExecution :: Client
-> DescribeWorkflowExecutionRequest
-> IO (Either RpcError DescribeWorkflowExecutionResponse)
describeWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"describeWorkflowExecution" PrimRpcCall
hs_describe_workflow_execution
foreign import ccall "hs_get_cluster_info" hs_get_cluster_info :: PrimRpcCall
getClusterInfo :: Client -> GetClusterInfoRequest -> IO (Either RpcError GetClusterInfoResponse)
getClusterInfo :: Client
-> GetClusterInfoRequest
-> IO (Either RpcError GetClusterInfoResponse)
getClusterInfo = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getClusterInfo" PrimRpcCall
hs_get_cluster_info
foreign import ccall "hs_get_search_attributes" hs_get_search_attributes :: PrimRpcCall
getSearchAttributes :: Client -> GetSearchAttributesRequest -> IO (Either RpcError GetSearchAttributesResponse)
getSearchAttributes :: Client
-> GetSearchAttributesRequest
-> IO (Either RpcError GetSearchAttributesResponse)
getSearchAttributes = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getSearchAttributes" PrimRpcCall
hs_get_search_attributes
foreign import ccall "hs_get_system_info" hs_get_system_info :: PrimRpcCall
getSystemInfo :: Client -> GetSystemInfoRequest -> IO (Either RpcError GetSystemInfoResponse)
getSystemInfo :: Client
-> GetSystemInfoRequest
-> IO (Either RpcError GetSystemInfoResponse)
getSystemInfo = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getSystemInfo" PrimRpcCall
hs_get_system_info
foreign import ccall "hs_get_worker_build_id_compatibility" hs_get_worker_build_id_compatibility :: PrimRpcCall
getWorkerBuildIdCompatibility :: Client -> GetWorkerBuildIdCompatibilityRequest -> IO (Either RpcError GetWorkerBuildIdCompatibilityResponse)
getWorkerBuildIdCompatibility :: Client
-> GetWorkerBuildIdCompatibilityRequest
-> IO (Either RpcError GetWorkerBuildIdCompatibilityResponse)
getWorkerBuildIdCompatibility = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getWorkerBuildIdCompatibility" PrimRpcCall
hs_get_worker_build_id_compatibility
foreign import ccall "hs_get_workflow_execution_history" hs_get_workflow_execution_history :: PrimRpcCall
getWorkflowExecutionHistory :: Client -> GetWorkflowExecutionHistoryRequest -> IO (Either RpcError GetWorkflowExecutionHistoryResponse)
getWorkflowExecutionHistory :: Client
-> GetWorkflowExecutionHistoryRequest
-> IO (Either RpcError GetWorkflowExecutionHistoryResponse)
getWorkflowExecutionHistory = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getWorkflowExecutionHistory" PrimRpcCall
hs_get_workflow_execution_history
foreign import ccall "hs_get_workflow_execution_history_reverse" hs_get_workflow_execution_history_reverse :: PrimRpcCall
getWorkflowExecutionHistoryReverse :: Client -> GetWorkflowExecutionHistoryReverseRequest -> IO (Either RpcError GetWorkflowExecutionHistoryReverseResponse)
getWorkflowExecutionHistoryReverse :: Client
-> GetWorkflowExecutionHistoryReverseRequest
-> IO (Either RpcError GetWorkflowExecutionHistoryReverseResponse)
getWorkflowExecutionHistoryReverse = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"getWorkflowExecutionHistoryReverse" PrimRpcCall
hs_get_workflow_execution_history_reverse
foreign import ccall "hs_list_archived_workflow_executions" hs_list_archived_workflow_executions :: PrimRpcCall
listArchivedWorkflowExecutions :: Client -> ListArchivedWorkflowExecutionsRequest -> IO (Either RpcError ListArchivedWorkflowExecutionsResponse)
listArchivedWorkflowExecutions :: Client
-> ListArchivedWorkflowExecutionsRequest
-> IO (Either RpcError ListArchivedWorkflowExecutionsResponse)
listArchivedWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listArchivedWorkflowExecutions" PrimRpcCall
hs_list_archived_workflow_executions
foreign import ccall "hs_list_closed_workflow_executions" hs_list_closed_workflow_executions :: PrimRpcCall
listClosedWorkflowExecutions :: Client -> ListClosedWorkflowExecutionsRequest -> IO (Either RpcError ListClosedWorkflowExecutionsResponse)
listClosedWorkflowExecutions :: Client
-> ListClosedWorkflowExecutionsRequest
-> IO (Either RpcError ListClosedWorkflowExecutionsResponse)
listClosedWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listClosedWorkflowExecutions" PrimRpcCall
hs_list_closed_workflow_executions
foreign import ccall "hs_list_namespaces" hs_list_namespaces :: PrimRpcCall
listNamespaces :: Client -> ListNamespacesRequest -> IO (Either RpcError ListNamespacesResponse)
listNamespaces :: Client
-> ListNamespacesRequest
-> IO (Either RpcError ListNamespacesResponse)
listNamespaces = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listNamespaces" PrimRpcCall
hs_list_namespaces
foreign import ccall "hs_list_open_workflow_executions" hs_list_open_workflow_executions :: PrimRpcCall
listOpenWorkflowExecutions :: Client -> ListOpenWorkflowExecutionsRequest -> IO (Either RpcError ListOpenWorkflowExecutionsResponse)
listOpenWorkflowExecutions :: Client
-> ListOpenWorkflowExecutionsRequest
-> IO (Either RpcError ListOpenWorkflowExecutionsResponse)
listOpenWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listOpenWorkflowExecutions" PrimRpcCall
hs_list_open_workflow_executions
foreign import ccall "hs_list_schedule_matching_times" hs_list_schedule_matching_times :: PrimRpcCall
listScheduleMatchingTimes :: Client -> ListScheduleMatchingTimesRequest -> IO (Either RpcError ListScheduleMatchingTimesResponse)
listScheduleMatchingTimes :: Client
-> ListScheduleMatchingTimesRequest
-> IO (Either RpcError ListScheduleMatchingTimesResponse)
listScheduleMatchingTimes = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listScheduleMatchingTimes" PrimRpcCall
hs_list_schedule_matching_times
foreign import ccall "hs_list_schedules" hs_list_schedules :: PrimRpcCall
listSchedules :: Client -> ListSchedulesRequest -> IO (Either RpcError ListSchedulesResponse)
listSchedules :: Client
-> ListSchedulesRequest
-> IO (Either RpcError ListSchedulesResponse)
listSchedules = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listSchedules" PrimRpcCall
hs_list_schedules
foreign import ccall "hs_list_task_queue_partitions" hs_list_task_queue_partitions :: PrimRpcCall
listTaskQueuePartitions :: Client -> ListTaskQueuePartitionsRequest -> IO (Either RpcError ListTaskQueuePartitionsResponse)
listTaskQueuePartitions :: Client
-> ListTaskQueuePartitionsRequest
-> IO (Either RpcError ListTaskQueuePartitionsResponse)
listTaskQueuePartitions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listTaskQueuePartitions" PrimRpcCall
hs_list_task_queue_partitions
foreign import ccall "hs_list_workflow_executions" hs_list_workflow_executions :: PrimRpcCall
listWorkflowExecutions :: Client -> ListWorkflowExecutionsRequest -> IO (Either RpcError ListWorkflowExecutionsResponse)
listWorkflowExecutions :: Client
-> ListWorkflowExecutionsRequest
-> IO (Either RpcError ListWorkflowExecutionsResponse)
listWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"listWorkflowExecutions" PrimRpcCall
hs_list_workflow_executions
foreign import ccall "hs_patch_schedule" hs_patch_schedule :: PrimRpcCall
patchSchedule :: Client -> PatchScheduleRequest -> IO (Either RpcError PatchScheduleResponse)
patchSchedule :: Client
-> PatchScheduleRequest
-> IO (Either RpcError PatchScheduleResponse)
patchSchedule = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"patchSchedule" PrimRpcCall
hs_patch_schedule
foreign import ccall "hs_poll_activity_task_queue" hs_poll_activity_task_queue :: PrimRpcCall
pollActivityTaskQueue :: Client -> PollActivityTaskQueueRequest -> IO (Either RpcError PollActivityTaskQueueResponse)
pollActivityTaskQueue :: Client
-> PollActivityTaskQueueRequest
-> IO (Either RpcError PollActivityTaskQueueResponse)
pollActivityTaskQueue = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"pollActivityTaskQueue" PrimRpcCall
hs_poll_activity_task_queue
foreign import ccall "hs_poll_workflow_execution_update" hs_poll_workflow_execution_update :: PrimRpcCall
pollWorkflowExecutionUpdate :: Client -> PollWorkflowExecutionUpdateRequest -> IO (Either RpcError PollWorkflowExecutionUpdateResponse)
pollWorkflowExecutionUpdate :: Client
-> PollWorkflowExecutionUpdateRequest
-> IO (Either RpcError PollWorkflowExecutionUpdateResponse)
pollWorkflowExecutionUpdate = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"pollWorkflowExecutionUpdate" PrimRpcCall
hs_poll_workflow_execution_update
foreign import ccall "hs_poll_workflow_task_queue" hs_poll_workflow_task_queue :: PrimRpcCall
pollWorkflowTaskQueue :: Client -> PollWorkflowTaskQueueRequest -> IO (Either RpcError PollWorkflowTaskQueueResponse)
pollWorkflowTaskQueue :: Client
-> PollWorkflowTaskQueueRequest
-> IO (Either RpcError PollWorkflowTaskQueueResponse)
pollWorkflowTaskQueue = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"pollWorkflowTaskQueue" PrimRpcCall
hs_poll_workflow_task_queue
foreign import ccall "hs_query_workflow" hs_query_workflow :: PrimRpcCall
queryWorkflow :: Client -> QueryWorkflowRequest -> IO (Either RpcError QueryWorkflowResponse)
queryWorkflow :: Client
-> QueryWorkflowRequest
-> IO (Either RpcError QueryWorkflowResponse)
queryWorkflow = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"queryWorkflow" PrimRpcCall
hs_query_workflow
foreign import ccall "hs_record_activity_task_heartbeat" hs_record_activity_task_heartbeat :: PrimRpcCall
recordActivityTaskHeartbeat :: Client -> RecordActivityTaskHeartbeatRequest -> IO (Either RpcError RecordActivityTaskHeartbeatResponse)
recordActivityTaskHeartbeat :: Client
-> RecordActivityTaskHeartbeatRequest
-> IO (Either RpcError RecordActivityTaskHeartbeatResponse)
recordActivityTaskHeartbeat = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"recordActivityTaskHeartbeat" PrimRpcCall
hs_record_activity_task_heartbeat
foreign import ccall "hs_record_activity_task_heartbeat_by_id" hs_record_activity_task_heartbeat_by_id :: PrimRpcCall
recordActivityTaskHeartbeatById :: Client -> RecordActivityTaskHeartbeatByIdRequest -> IO (Either RpcError RecordActivityTaskHeartbeatByIdResponse)
recordActivityTaskHeartbeatById :: Client
-> RecordActivityTaskHeartbeatByIdRequest
-> IO (Either RpcError RecordActivityTaskHeartbeatByIdResponse)
recordActivityTaskHeartbeatById = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"recordActivityTaskHeartbeatById" PrimRpcCall
hs_record_activity_task_heartbeat_by_id
foreign import ccall "hs_register_namespace" hs_register_namespace :: PrimRpcCall
registerNamespace :: Client -> RegisterNamespaceRequest -> IO (Either RpcError RegisterNamespaceResponse)
registerNamespace :: Client
-> RegisterNamespaceRequest
-> IO (Either RpcError RegisterNamespaceResponse)
registerNamespace = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"registerNamespace" PrimRpcCall
hs_register_namespace
foreign import ccall "hs_request_cancel_workflow_execution" hs_request_cancel_workflow_execution :: PrimRpcCall
requestCancelWorkflowExecution :: Client -> RequestCancelWorkflowExecutionRequest -> IO (Either RpcError RequestCancelWorkflowExecutionResponse)
requestCancelWorkflowExecution :: Client
-> RequestCancelWorkflowExecutionRequest
-> IO (Either RpcError RequestCancelWorkflowExecutionResponse)
requestCancelWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"requestCancelWorkflowExecution" PrimRpcCall
hs_request_cancel_workflow_execution
foreign import ccall "hs_reset_sticky_task_queue" hs_reset_sticky_task_queue :: PrimRpcCall
resetStickyTaskQueue :: Client -> ResetStickyTaskQueueRequest -> IO (Either RpcError ResetStickyTaskQueueResponse)
resetStickyTaskQueue :: Client
-> ResetStickyTaskQueueRequest
-> IO (Either RpcError ResetStickyTaskQueueResponse)
resetStickyTaskQueue = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"resetStickyTaskQueue" PrimRpcCall
hs_reset_sticky_task_queue
foreign import ccall "hs_reset_workflow_execution" hs_reset_workflow_execution :: PrimRpcCall
resetWorkflowExecution :: Client -> ResetWorkflowExecutionRequest -> IO (Either RpcError ResetWorkflowExecutionResponse)
resetWorkflowExecution :: Client
-> ResetWorkflowExecutionRequest
-> IO (Either RpcError ResetWorkflowExecutionResponse)
resetWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"resetWorkflowExecution" PrimRpcCall
hs_reset_workflow_execution
foreign import ccall "hs_respond_activity_task_canceled" hs_respond_activity_task_canceled :: PrimRpcCall
respondActivityTaskCanceled :: Client -> RespondActivityTaskCanceledRequest -> IO (Either RpcError RespondActivityTaskCanceledResponse)
respondActivityTaskCanceled :: Client
-> RespondActivityTaskCanceledRequest
-> IO (Either RpcError RespondActivityTaskCanceledResponse)
respondActivityTaskCanceled = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskCanceled" PrimRpcCall
hs_respond_activity_task_canceled
foreign import ccall "hs_respond_activity_task_canceled_by_id" hs_respond_activity_task_canceled_by_id :: PrimRpcCall
respondActivityTaskCanceledById :: Client -> RespondActivityTaskCanceledByIdRequest -> IO (Either RpcError RespondActivityTaskCanceledByIdResponse)
respondActivityTaskCanceledById :: Client
-> RespondActivityTaskCanceledByIdRequest
-> IO (Either RpcError RespondActivityTaskCanceledByIdResponse)
respondActivityTaskCanceledById = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskCanceledById" PrimRpcCall
hs_respond_activity_task_canceled_by_id
foreign import ccall "hs_respond_activity_task_completed" hs_respond_activity_task_completed :: PrimRpcCall
respondActivityTaskCompleted :: Client -> RespondActivityTaskCompletedRequest -> IO (Either RpcError RespondActivityTaskCompletedResponse)
respondActivityTaskCompleted :: Client
-> RespondActivityTaskCompletedRequest
-> IO (Either RpcError RespondActivityTaskCompletedResponse)
respondActivityTaskCompleted = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskCompleted" PrimRpcCall
hs_respond_activity_task_completed
foreign import ccall "hs_respond_activity_task_completed_by_id" hs_respond_activity_task_completed_by_id :: PrimRpcCall
respondActivityTaskCompletedById :: Client -> RespondActivityTaskCompletedByIdRequest -> IO (Either RpcError RespondActivityTaskCompletedByIdResponse)
respondActivityTaskCompletedById :: Client
-> RespondActivityTaskCompletedByIdRequest
-> IO (Either RpcError RespondActivityTaskCompletedByIdResponse)
respondActivityTaskCompletedById = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskCompletedById" PrimRpcCall
hs_respond_activity_task_completed_by_id
foreign import ccall "hs_respond_activity_task_failed" hs_respond_activity_task_failed :: PrimRpcCall
respondActivityTaskFailed :: Client -> RespondActivityTaskFailedRequest -> IO (Either RpcError RespondActivityTaskFailedResponse)
respondActivityTaskFailed :: Client
-> RespondActivityTaskFailedRequest
-> IO (Either RpcError RespondActivityTaskFailedResponse)
respondActivityTaskFailed = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskFailed" PrimRpcCall
hs_respond_activity_task_failed
foreign import ccall "hs_respond_activity_task_failed_by_id" hs_respond_activity_task_failed_by_id :: PrimRpcCall
respondActivityTaskFailedById :: Client -> RespondActivityTaskFailedByIdRequest -> IO (Either RpcError RespondActivityTaskFailedByIdResponse)
respondActivityTaskFailedById :: Client
-> RespondActivityTaskFailedByIdRequest
-> IO (Either RpcError RespondActivityTaskFailedByIdResponse)
respondActivityTaskFailedById = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondActivityTaskFailedById" PrimRpcCall
hs_respond_activity_task_failed_by_id
foreign import ccall "hs_respond_query_task_completed" hs_respond_query_task_completed :: PrimRpcCall
respondQueryTaskCompleted :: Client -> RespondQueryTaskCompletedRequest -> IO (Either RpcError RespondQueryTaskCompletedResponse)
respondQueryTaskCompleted :: Client
-> RespondQueryTaskCompletedRequest
-> IO (Either RpcError RespondQueryTaskCompletedResponse)
respondQueryTaskCompleted = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondQueryTaskCompleted" PrimRpcCall
hs_respond_query_task_completed
foreign import ccall "hs_respond_workflow_task_completed" hs_respond_workflow_task_completed :: PrimRpcCall
respondWorkflowTaskCompleted :: Client -> RespondWorkflowTaskCompletedRequest -> IO (Either RpcError RespondWorkflowTaskCompletedResponse)
respondWorkflowTaskCompleted :: Client
-> RespondWorkflowTaskCompletedRequest
-> IO (Either RpcError RespondWorkflowTaskCompletedResponse)
respondWorkflowTaskCompleted = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondWorkflowTaskCompleted" PrimRpcCall
hs_respond_workflow_task_completed
foreign import ccall "hs_respond_workflow_task_failed" hs_respond_workflow_task_failed :: PrimRpcCall
respondWorkflowTaskFailed :: Client -> RespondWorkflowTaskFailedRequest -> IO (Either RpcError RespondWorkflowTaskFailedResponse)
respondWorkflowTaskFailed :: Client
-> RespondWorkflowTaskFailedRequest
-> IO (Either RpcError RespondWorkflowTaskFailedResponse)
respondWorkflowTaskFailed = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"respondWorkflowTaskFailed" PrimRpcCall
hs_respond_workflow_task_failed
foreign import ccall "hs_scan_workflow_executions" hs_scan_workflow_executions :: PrimRpcCall
scanWorkflowExecutions :: Client -> ScanWorkflowExecutionsRequest -> IO (Either RpcError ScanWorkflowExecutionsResponse)
scanWorkflowExecutions :: Client
-> ScanWorkflowExecutionsRequest
-> IO (Either RpcError ScanWorkflowExecutionsResponse)
scanWorkflowExecutions = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"scanWorkflowExecutions" PrimRpcCall
hs_scan_workflow_executions
foreign import ccall "hs_signal_with_start_workflow_execution" hs_signal_with_start_workflow_execution :: PrimRpcCall
signalWithStartWorkflowExecution :: Client -> SignalWithStartWorkflowExecutionRequest -> IO (Either RpcError SignalWithStartWorkflowExecutionResponse)
signalWithStartWorkflowExecution :: Client
-> SignalWithStartWorkflowExecutionRequest
-> IO (Either RpcError SignalWithStartWorkflowExecutionResponse)
signalWithStartWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"signalWithStartWorkflowExecution" PrimRpcCall
hs_signal_with_start_workflow_execution
foreign import ccall "hs_signal_workflow_execution" hs_signal_workflow_execution :: PrimRpcCall
signalWorkflowExecution :: Client -> SignalWorkflowExecutionRequest -> IO (Either RpcError SignalWorkflowExecutionResponse)
signalWorkflowExecution :: Client
-> SignalWorkflowExecutionRequest
-> IO (Either RpcError SignalWorkflowExecutionResponse)
signalWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"signalWorkflowExecution" PrimRpcCall
hs_signal_workflow_execution
foreign import ccall "hs_start_workflow_execution" hs_start_workflow_execution :: PrimRpcCall
startWorkflowExecution :: Client -> StartWorkflowExecutionRequest -> IO (Either RpcError StartWorkflowExecutionResponse)
startWorkflowExecution :: Client
-> StartWorkflowExecutionRequest
-> IO (Either RpcError StartWorkflowExecutionResponse)
startWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"startWorkflowExecution" PrimRpcCall
hs_start_workflow_execution
foreign import ccall "hs_terminate_workflow_execution" hs_terminate_workflow_execution :: PrimRpcCall
terminateWorkflowExecution :: Client -> TerminateWorkflowExecutionRequest -> IO (Either RpcError TerminateWorkflowExecutionResponse)
terminateWorkflowExecution :: Client
-> TerminateWorkflowExecutionRequest
-> IO (Either RpcError TerminateWorkflowExecutionResponse)
terminateWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"terminateWorkflowExecution" PrimRpcCall
hs_terminate_workflow_execution
foreign import ccall "hs_update_namespace" hs_update_namespace :: PrimRpcCall
updateNamespace :: Client -> UpdateNamespaceRequest -> IO (Either RpcError UpdateNamespaceResponse)
updateNamespace :: Client
-> UpdateNamespaceRequest
-> IO (Either RpcError UpdateNamespaceResponse)
updateNamespace = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"updateNamespace" PrimRpcCall
hs_update_namespace
foreign import ccall "hs_update_schedule" hs_update_schedule :: PrimRpcCall
updateSchedule :: Client -> UpdateScheduleRequest -> IO (Either RpcError UpdateScheduleResponse)
updateSchedule :: Client
-> UpdateScheduleRequest
-> IO (Either RpcError UpdateScheduleResponse)
updateSchedule = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"updateSchedule" PrimRpcCall
hs_update_schedule
foreign import ccall "hs_update_workflow_execution" hs_update_workflow_execution :: PrimRpcCall
updateWorkflowExecution :: Client -> UpdateWorkflowExecutionRequest -> IO (Either RpcError UpdateWorkflowExecutionResponse)
updateWorkflowExecution :: Client
-> UpdateWorkflowExecutionRequest
-> IO (Either RpcError UpdateWorkflowExecutionResponse)
updateWorkflowExecution = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"updateWorkflowExecution" PrimRpcCall
hs_update_workflow_execution
foreign import ccall "hs_update_worker_build_id_compatibility" hs_update_worker_build_id_compatibility :: PrimRpcCall
updateWorkerBuildIdCompatibility :: Client -> UpdateWorkerBuildIdCompatibilityRequest -> IO (Either RpcError UpdateWorkerBuildIdCompatibilityResponse)
updateWorkerBuildIdCompatibility :: Client
-> UpdateWorkerBuildIdCompatibilityRequest
-> IO (Either RpcError UpdateWorkerBuildIdCompatibilityResponse)
updateWorkerBuildIdCompatibility = forall svc (t :: Symbol).
HasMethodImpl svc t =>
PrimRpcCall
-> Client
-> MethodInput svc t
-> IO (Either RpcError (MethodOutput svc t))
call @WorkflowService @"updateWorkerBuildIdCompatibility" PrimRpcCall
hs_update_worker_build_id_compatibility