Module Smaws_Client_SWF

SWF client library built on EIO.

Types

module Types : sig ... end

Builders

val make_workflow_type : version:Types.version -> name:Types.name -> unit -> Types.workflow_type
val make_workflow_type_info : ?deprecation_date:Types.timestamp -> ?description:Types.description -> creation_date:Types.timestamp -> status:Types.registration_status -> workflow_type:Types.workflow_type -> unit -> Types.workflow_type_info
val make_workflow_type_infos : ?next_page_token:Types.page_token -> type_infos:Types.workflow_type_info_list -> unit -> Types.workflow_type_infos
val make_workflow_type_filter : ?version:Types.version_optional -> name:Types.name -> unit -> Types.workflow_type_filter
val make_task_list : name:Types.name -> unit -> Types.task_list
val make_workflow_type_configuration : ?default_lambda_role:Types.arn -> ?default_child_policy:Types.child_policy -> ?default_task_priority:Types.task_priority -> ?default_task_list:Types.task_list -> ?default_execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?default_task_start_to_close_timeout:Types.duration_in_seconds_optional -> unit -> Types.workflow_type_configuration
val make_workflow_type_detail : configuration:Types.workflow_type_configuration -> type_info:Types.workflow_type_info -> unit -> Types.workflow_type_detail
val make_workflow_execution_timed_out_event_attributes : child_policy:Types.child_policy -> timeout_type:Types.workflow_execution_timeout_type -> unit -> Types.workflow_execution_timed_out_event_attributes
val make_workflow_execution_terminated_event_attributes : ?cause:Types.workflow_execution_terminated_cause -> ?details:Types.data -> ?reason:Types.terminate_reason -> child_policy:Types.child_policy -> unit -> Types.workflow_execution_terminated_event_attributes
val make_workflow_execution : run_id:Types.workflow_run_id -> workflow_id:Types.workflow_id -> unit -> Types.workflow_execution
val make_workflow_execution_started_event_attributes : ?lambda_role:Types.arn -> ?parent_initiated_event_id:Types.event_id -> ?parent_workflow_execution:Types.workflow_execution -> ?continued_execution_run_id:Types.workflow_run_id_optional -> ?tag_list:Types.tag_list -> ?task_priority:Types.task_priority -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> workflow_type:Types.workflow_type -> task_list:Types.task_list -> child_policy:Types.child_policy -> unit -> Types.workflow_execution_started_event_attributes
val make_workflow_execution_signaled_event_attributes : ?external_initiated_event_id:Types.event_id -> ?external_workflow_execution:Types.workflow_execution -> ?input:Types.data -> signal_name:Types.signal_name -> unit -> Types.workflow_execution_signaled_event_attributes
val make_workflow_execution_open_counts : ?open_lambda_functions:Types.count -> open_child_workflow_executions:Types.count -> open_timers:Types.count -> open_decision_tasks:Types.open_decision_tasks_count -> open_activity_tasks:Types.count -> unit -> Types.workflow_execution_open_counts
val make_workflow_execution_info : ?cancel_requested:Types.canceled -> ?tag_list:Types.tag_list -> ?parent:Types.workflow_execution -> ?close_status:Types.close_status -> ?close_timestamp:Types.timestamp -> execution_status:Types.execution_status -> start_timestamp:Types.timestamp -> workflow_type:Types.workflow_type -> execution:Types.workflow_execution -> unit -> Types.workflow_execution_info
val make_workflow_execution_infos : ?next_page_token:Types.page_token -> execution_infos:Types.workflow_execution_info_list -> unit -> Types.workflow_execution_infos
val make_workflow_execution_filter : workflow_id:Types.workflow_id -> unit -> Types.workflow_execution_filter
val make_workflow_execution_failed_event_attributes : ?details:Types.data -> ?reason:Types.failure_reason -> decision_task_completed_event_id:Types.event_id -> unit -> Types.workflow_execution_failed_event_attributes
val make_workflow_execution_configuration : ?lambda_role:Types.arn -> ?task_priority:Types.task_priority -> child_policy:Types.child_policy -> task_list:Types.task_list -> execution_start_to_close_timeout:Types.duration_in_seconds -> task_start_to_close_timeout:Types.duration_in_seconds -> unit -> Types.workflow_execution_configuration
val make_workflow_execution_detail : ?latest_execution_context:Types.data -> ?latest_activity_task_timestamp:Types.timestamp -> open_counts:Types.workflow_execution_open_counts -> execution_configuration:Types.workflow_execution_configuration -> execution_info:Types.workflow_execution_info -> unit -> Types.workflow_execution_detail
val make_workflow_execution_count : ?truncated:Types.truncated -> count:Types.count -> unit -> Types.workflow_execution_count
val make_workflow_execution_continued_as_new_event_attributes : ?lambda_role:Types.arn -> ?tag_list:Types.tag_list -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> workflow_type:Types.workflow_type -> child_policy:Types.child_policy -> task_list:Types.task_list -> new_execution_run_id:Types.workflow_run_id -> decision_task_completed_event_id:Types.event_id -> unit -> Types.workflow_execution_continued_as_new_event_attributes
val make_workflow_execution_completed_event_attributes : ?result:Types.data -> decision_task_completed_event_id:Types.event_id -> unit -> Types.workflow_execution_completed_event_attributes
val make_workflow_execution_canceled_event_attributes : ?details:Types.data -> decision_task_completed_event_id:Types.event_id -> unit -> Types.workflow_execution_canceled_event_attributes
val make_workflow_execution_cancel_requested_event_attributes : ?cause:Types.workflow_execution_cancel_requested_cause -> ?external_initiated_event_id:Types.event_id -> ?external_workflow_execution:Types.workflow_execution -> unit -> Types.workflow_execution_cancel_requested_event_attributes
val make_untag_resource_input : tag_keys:Types.resource_tag_key_list -> resource_arn:Types.arn -> unit -> Types.untag_resource_input
val make_undeprecate_workflow_type_input : workflow_type:Types.workflow_type -> domain:Types.domain_name -> unit -> Types.undeprecate_workflow_type_input
val make_undeprecate_domain_input : name:Types.domain_name -> unit -> Types.undeprecate_domain_input
val make_activity_type : version:Types.version -> name:Types.name -> unit -> Types.activity_type
val make_undeprecate_activity_type_input : activity_type:Types.activity_type -> domain:Types.domain_name -> unit -> Types.undeprecate_activity_type_input
val make_timer_started_event_attributes : ?control:Types.data -> decision_task_completed_event_id:Types.event_id -> start_to_fire_timeout:Types.duration_in_seconds -> timer_id:Types.timer_id -> unit -> Types.timer_started_event_attributes
val make_timer_fired_event_attributes : started_event_id:Types.event_id -> timer_id:Types.timer_id -> unit -> Types.timer_fired_event_attributes
val make_timer_canceled_event_attributes : decision_task_completed_event_id:Types.event_id -> started_event_id:Types.event_id -> timer_id:Types.timer_id -> unit -> Types.timer_canceled_event_attributes
val make_terminate_workflow_execution_input : ?child_policy:Types.child_policy -> ?details:Types.data -> ?reason:Types.terminate_reason -> ?run_id:Types.workflow_run_id_optional -> workflow_id:Types.workflow_id -> domain:Types.domain_name -> unit -> Types.terminate_workflow_execution_input
val make_resource_tag : ?value:Types.resource_tag_value -> key:Types.resource_tag_key -> unit -> Types.resource_tag
val make_tag_resource_input : tags:Types.resource_tag_list -> resource_arn:Types.arn -> unit -> Types.tag_resource_input
val make_tag_filter : tag:Types.tag -> unit -> Types.tag_filter
val make_start_workflow_execution_input : ?lambda_role:Types.arn -> ?child_policy:Types.child_policy -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?tag_list:Types.tag_list -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> ?task_priority:Types.task_priority -> ?task_list:Types.task_list -> workflow_type:Types.workflow_type -> workflow_id:Types.workflow_id -> domain:Types.domain_name -> unit -> Types.start_workflow_execution_input
val make_run : ?run_id:Types.workflow_run_id -> unit -> Types.run
val make_start_timer_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.start_timer_failed_cause -> timer_id:Types.timer_id -> unit -> Types.start_timer_failed_event_attributes
val make_start_timer_decision_attributes : ?control:Types.data -> start_to_fire_timeout:Types.duration_in_seconds -> timer_id:Types.timer_id -> unit -> Types.start_timer_decision_attributes
val make_start_lambda_function_failed_event_attributes : ?message:Types.cause_message -> ?cause:Types.start_lambda_function_failed_cause -> ?scheduled_event_id:Types.event_id -> unit -> Types.start_lambda_function_failed_event_attributes
val make_start_child_workflow_execution_initiated_event_attributes : ?lambda_role:Types.arn -> ?tag_list:Types.tag_list -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> ?control:Types.data -> child_policy:Types.child_policy -> decision_task_completed_event_id:Types.event_id -> task_list:Types.task_list -> workflow_type:Types.workflow_type -> workflow_id:Types.workflow_id -> unit -> Types.start_child_workflow_execution_initiated_event_attributes
val make_start_child_workflow_execution_failed_event_attributes : ?control:Types.data -> decision_task_completed_event_id:Types.event_id -> initiated_event_id:Types.event_id -> workflow_id:Types.workflow_id -> cause:Types.start_child_workflow_execution_failed_cause -> workflow_type:Types.workflow_type -> unit -> Types.start_child_workflow_execution_failed_event_attributes
val make_start_child_workflow_execution_decision_attributes : ?lambda_role:Types.arn -> ?tag_list:Types.tag_list -> ?child_policy:Types.child_policy -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?task_list:Types.task_list -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> ?control:Types.data -> workflow_id:Types.workflow_id -> workflow_type:Types.workflow_type -> unit -> Types.start_child_workflow_execution_decision_attributes
val make_signal_workflow_execution_input : ?input:Types.data -> ?run_id:Types.workflow_run_id_optional -> signal_name:Types.signal_name -> workflow_id:Types.workflow_id -> domain:Types.domain_name -> unit -> Types.signal_workflow_execution_input
val make_schedule_activity_task_decision_attributes : ?heartbeat_timeout:Types.duration_in_seconds_optional -> ?start_to_close_timeout:Types.duration_in_seconds_optional -> ?schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?task_list:Types.task_list -> ?schedule_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> ?control:Types.data -> activity_id:Types.activity_id -> activity_type:Types.activity_type -> unit -> Types.schedule_activity_task_decision_attributes
val make_request_cancel_activity_task_decision_attributes : activity_id:Types.activity_id -> unit -> Types.request_cancel_activity_task_decision_attributes
val make_complete_workflow_execution_decision_attributes : ?result:Types.data -> unit -> Types.complete_workflow_execution_decision_attributes
val make_fail_workflow_execution_decision_attributes : ?details:Types.data -> ?reason:Types.failure_reason -> unit -> Types.fail_workflow_execution_decision_attributes
val make_cancel_workflow_execution_decision_attributes : ?details:Types.data -> unit -> Types.cancel_workflow_execution_decision_attributes
val make_continue_as_new_workflow_execution_decision_attributes : ?lambda_role:Types.arn -> ?workflow_type_version:Types.version -> ?tag_list:Types.tag_list -> ?child_policy:Types.child_policy -> ?task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?task_list:Types.task_list -> ?execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.data -> unit -> Types.continue_as_new_workflow_execution_decision_attributes
val make_record_marker_decision_attributes : ?details:Types.data -> marker_name:Types.marker_name -> unit -> Types.record_marker_decision_attributes
val make_cancel_timer_decision_attributes : timer_id:Types.timer_id -> unit -> Types.cancel_timer_decision_attributes
val make_signal_external_workflow_execution_decision_attributes : ?control:Types.data -> ?input:Types.data -> ?run_id:Types.workflow_run_id_optional -> signal_name:Types.signal_name -> workflow_id:Types.workflow_id -> unit -> Types.signal_external_workflow_execution_decision_attributes
val make_request_cancel_external_workflow_execution_decision_attributes : ?control:Types.data -> ?run_id:Types.workflow_run_id_optional -> workflow_id:Types.workflow_id -> unit -> Types.request_cancel_external_workflow_execution_decision_attributes
val make_schedule_lambda_function_decision_attributes : ?start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.function_input -> ?control:Types.data -> name:Types.function_name -> id:Types.function_id -> unit -> Types.schedule_lambda_function_decision_attributes
val make_decision : ?schedule_lambda_function_decision_attributes: Types.schedule_lambda_function_decision_attributes -> ?start_child_workflow_execution_decision_attributes: Types.start_child_workflow_execution_decision_attributes -> ?request_cancel_external_workflow_execution_decision_attributes: Types.request_cancel_external_workflow_execution_decision_attributes -> ?signal_external_workflow_execution_decision_attributes: Types.signal_external_workflow_execution_decision_attributes -> ?cancel_timer_decision_attributes:Types.cancel_timer_decision_attributes -> ?start_timer_decision_attributes:Types.start_timer_decision_attributes -> ?record_marker_decision_attributes:Types.record_marker_decision_attributes -> ?continue_as_new_workflow_execution_decision_attributes: Types.continue_as_new_workflow_execution_decision_attributes -> ?cancel_workflow_execution_decision_attributes: Types.cancel_workflow_execution_decision_attributes -> ?fail_workflow_execution_decision_attributes: Types.fail_workflow_execution_decision_attributes -> ?complete_workflow_execution_decision_attributes: Types.complete_workflow_execution_decision_attributes -> ?request_cancel_activity_task_decision_attributes: Types.request_cancel_activity_task_decision_attributes -> ?schedule_activity_task_decision_attributes: Types.schedule_activity_task_decision_attributes -> decision_type:Types.decision_type -> unit -> Types.decision
val make_respond_decision_task_completed_input : ?task_list_schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?task_list:Types.task_list -> ?execution_context:Types.data -> ?decisions:Types.decision_list -> task_token:Types.task_token -> unit -> Types.respond_decision_task_completed_input
val make_respond_activity_task_failed_input : ?details:Types.data -> ?reason:Types.failure_reason -> task_token:Types.task_token -> unit -> Types.respond_activity_task_failed_input
val make_respond_activity_task_completed_input : ?result:Types.data -> task_token:Types.task_token -> unit -> Types.respond_activity_task_completed_input
val make_respond_activity_task_canceled_input : ?details:Types.data -> task_token:Types.task_token -> unit -> Types.respond_activity_task_canceled_input
val make_request_cancel_workflow_execution_input : ?run_id:Types.workflow_run_id_optional -> workflow_id:Types.workflow_id -> domain:Types.domain_name -> unit -> Types.request_cancel_workflow_execution_input
val make_register_workflow_type_input : ?default_lambda_role:Types.arn -> ?default_child_policy:Types.child_policy -> ?default_task_priority:Types.task_priority -> ?default_task_list:Types.task_list -> ?default_execution_start_to_close_timeout:Types.duration_in_seconds_optional -> ?default_task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?description:Types.description -> version:Types.version -> name:Types.name -> domain:Types.domain_name -> unit -> Types.register_workflow_type_input
val make_register_domain_input : ?tags:Types.resource_tag_list -> ?description:Types.description -> workflow_execution_retention_period_in_days:Types.duration_in_days -> name:Types.domain_name -> unit -> Types.register_domain_input
val make_register_activity_type_input : ?default_task_schedule_to_close_timeout:Types.duration_in_seconds_optional -> ?default_task_schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?default_task_priority:Types.task_priority -> ?default_task_list:Types.task_list -> ?default_task_heartbeat_timeout:Types.duration_in_seconds_optional -> ?default_task_start_to_close_timeout:Types.duration_in_seconds_optional -> ?description:Types.description -> version:Types.version -> name:Types.name -> domain:Types.domain_name -> unit -> Types.register_activity_type_input
val make_activity_task_status : cancel_requested:Types.canceled -> unit -> Types.activity_task_status
val make_record_activity_task_heartbeat_input : ?details:Types.limited_data -> task_token:Types.task_token -> unit -> Types.record_activity_task_heartbeat_input
val make_complete_workflow_execution_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.complete_workflow_execution_failed_cause -> unit -> Types.complete_workflow_execution_failed_event_attributes
val make_fail_workflow_execution_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.fail_workflow_execution_failed_cause -> unit -> Types.fail_workflow_execution_failed_event_attributes
val make_cancel_workflow_execution_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.cancel_workflow_execution_failed_cause -> unit -> Types.cancel_workflow_execution_failed_event_attributes
val make_continue_as_new_workflow_execution_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.continue_as_new_workflow_execution_failed_cause -> unit -> Types.continue_as_new_workflow_execution_failed_event_attributes
val make_decision_task_scheduled_event_attributes : ?schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?start_to_close_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> task_list:Types.task_list -> unit -> Types.decision_task_scheduled_event_attributes
val make_decision_task_started_event_attributes : ?identity:Types.identity -> scheduled_event_id:Types.event_id -> unit -> Types.decision_task_started_event_attributes
val make_decision_task_completed_event_attributes : ?task_list_schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?task_list:Types.task_list -> ?execution_context:Types.data -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.decision_task_completed_event_attributes
val make_decision_task_timed_out_event_attributes : started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> timeout_type:Types.decision_task_timeout_type -> unit -> Types.decision_task_timed_out_event_attributes
val make_activity_task_scheduled_event_attributes : ?heartbeat_timeout:Types.duration_in_seconds_optional -> ?task_priority:Types.task_priority -> ?start_to_close_timeout:Types.duration_in_seconds_optional -> ?schedule_to_close_timeout:Types.duration_in_seconds_optional -> ?schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?control:Types.data -> ?input:Types.data -> decision_task_completed_event_id:Types.event_id -> task_list:Types.task_list -> activity_id:Types.activity_id -> activity_type:Types.activity_type -> unit -> Types.activity_task_scheduled_event_attributes
val make_activity_task_started_event_attributes : ?identity:Types.identity -> scheduled_event_id:Types.event_id -> unit -> Types.activity_task_started_event_attributes
val make_activity_task_completed_event_attributes : ?result:Types.data -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.activity_task_completed_event_attributes
val make_activity_task_failed_event_attributes : ?details:Types.data -> ?reason:Types.failure_reason -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.activity_task_failed_event_attributes
val make_activity_task_timed_out_event_attributes : ?details:Types.limited_data -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> timeout_type:Types.activity_task_timeout_type -> unit -> Types.activity_task_timed_out_event_attributes
val make_activity_task_canceled_event_attributes : ?latest_cancel_requested_event_id:Types.event_id -> ?details:Types.data -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.activity_task_canceled_event_attributes
val make_activity_task_cancel_requested_event_attributes : activity_id:Types.activity_id -> decision_task_completed_event_id:Types.event_id -> unit -> Types.activity_task_cancel_requested_event_attributes
val make_marker_recorded_event_attributes : ?details:Types.data -> decision_task_completed_event_id:Types.event_id -> marker_name:Types.marker_name -> unit -> Types.marker_recorded_event_attributes
val make_record_marker_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.record_marker_failed_cause -> marker_name:Types.marker_name -> unit -> Types.record_marker_failed_event_attributes
val make_child_workflow_execution_started_event_attributes : initiated_event_id:Types.event_id -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_started_event_attributes
val make_child_workflow_execution_completed_event_attributes : ?result:Types.data -> started_event_id:Types.event_id -> initiated_event_id:Types.event_id -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_completed_event_attributes
val make_child_workflow_execution_failed_event_attributes : ?details:Types.data -> ?reason:Types.failure_reason -> started_event_id:Types.event_id -> initiated_event_id:Types.event_id -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_failed_event_attributes
val make_child_workflow_execution_timed_out_event_attributes : started_event_id:Types.event_id -> initiated_event_id:Types.event_id -> timeout_type:Types.workflow_execution_timeout_type -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_timed_out_event_attributes
val make_child_workflow_execution_canceled_event_attributes : ?details:Types.data -> started_event_id:Types.event_id -> initiated_event_id:Types.event_id -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_canceled_event_attributes
val make_child_workflow_execution_terminated_event_attributes : started_event_id:Types.event_id -> initiated_event_id:Types.event_id -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> unit -> Types.child_workflow_execution_terminated_event_attributes
val make_signal_external_workflow_execution_initiated_event_attributes : ?control:Types.data -> ?input:Types.data -> ?run_id:Types.workflow_run_id_optional -> decision_task_completed_event_id:Types.event_id -> signal_name:Types.signal_name -> workflow_id:Types.workflow_id -> unit -> Types.signal_external_workflow_execution_initiated_event_attributes
val make_external_workflow_execution_signaled_event_attributes : initiated_event_id:Types.event_id -> workflow_execution:Types.workflow_execution -> unit -> Types.external_workflow_execution_signaled_event_attributes
val make_signal_external_workflow_execution_failed_event_attributes : ?control:Types.data -> ?run_id:Types.workflow_run_id_optional -> decision_task_completed_event_id:Types.event_id -> initiated_event_id:Types.event_id -> cause:Types.signal_external_workflow_execution_failed_cause -> workflow_id:Types.workflow_id -> unit -> Types.signal_external_workflow_execution_failed_event_attributes
val make_external_workflow_execution_cancel_requested_event_attributes : initiated_event_id:Types.event_id -> workflow_execution:Types.workflow_execution -> unit -> Types.external_workflow_execution_cancel_requested_event_attributes
val make_request_cancel_external_workflow_execution_initiated_event_attributes : ?control:Types.data -> ?run_id:Types.workflow_run_id_optional -> decision_task_completed_event_id:Types.event_id -> workflow_id:Types.workflow_id -> unit -> Types.request_cancel_external_workflow_execution_initiated_event_attributes
val make_request_cancel_external_workflow_execution_failed_event_attributes : ?control:Types.data -> ?run_id:Types.workflow_run_id_optional -> decision_task_completed_event_id:Types.event_id -> initiated_event_id:Types.event_id -> cause:Types.request_cancel_external_workflow_execution_failed_cause -> workflow_id:Types.workflow_id -> unit -> Types.request_cancel_external_workflow_execution_failed_event_attributes
val make_schedule_activity_task_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.schedule_activity_task_failed_cause -> activity_id:Types.activity_id -> activity_type:Types.activity_type -> unit -> Types.schedule_activity_task_failed_event_attributes
val make_request_cancel_activity_task_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.request_cancel_activity_task_failed_cause -> activity_id:Types.activity_id -> unit -> Types.request_cancel_activity_task_failed_event_attributes
val make_cancel_timer_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.cancel_timer_failed_cause -> timer_id:Types.timer_id -> unit -> Types.cancel_timer_failed_event_attributes
val make_lambda_function_scheduled_event_attributes : ?start_to_close_timeout:Types.duration_in_seconds_optional -> ?input:Types.function_input -> ?control:Types.data -> decision_task_completed_event_id:Types.event_id -> name:Types.function_name -> id:Types.function_id -> unit -> Types.lambda_function_scheduled_event_attributes
val make_lambda_function_started_event_attributes : scheduled_event_id:Types.event_id -> unit -> Types.lambda_function_started_event_attributes
val make_lambda_function_completed_event_attributes : ?result:Types.data -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.lambda_function_completed_event_attributes
val make_lambda_function_failed_event_attributes : ?details:Types.data -> ?reason:Types.failure_reason -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.lambda_function_failed_event_attributes
val make_lambda_function_timed_out_event_attributes : ?timeout_type:Types.lambda_function_timeout_type -> started_event_id:Types.event_id -> scheduled_event_id:Types.event_id -> unit -> Types.lambda_function_timed_out_event_attributes
val make_schedule_lambda_function_failed_event_attributes : decision_task_completed_event_id:Types.event_id -> cause:Types.schedule_lambda_function_failed_cause -> name:Types.function_name -> id:Types.function_id -> unit -> Types.schedule_lambda_function_failed_event_attributes
val make_history_event : ?start_lambda_function_failed_event_attributes: Types.start_lambda_function_failed_event_attributes -> ?schedule_lambda_function_failed_event_attributes: Types.schedule_lambda_function_failed_event_attributes -> ?lambda_function_timed_out_event_attributes: Types.lambda_function_timed_out_event_attributes -> ?lambda_function_failed_event_attributes: Types.lambda_function_failed_event_attributes -> ?lambda_function_completed_event_attributes: Types.lambda_function_completed_event_attributes -> ?lambda_function_started_event_attributes: Types.lambda_function_started_event_attributes -> ?lambda_function_scheduled_event_attributes: Types.lambda_function_scheduled_event_attributes -> ?start_child_workflow_execution_failed_event_attributes: Types.start_child_workflow_execution_failed_event_attributes -> ?cancel_timer_failed_event_attributes: Types.cancel_timer_failed_event_attributes -> ?start_timer_failed_event_attributes: Types.start_timer_failed_event_attributes -> ?request_cancel_activity_task_failed_event_attributes: Types.request_cancel_activity_task_failed_event_attributes -> ?schedule_activity_task_failed_event_attributes: Types.schedule_activity_task_failed_event_attributes -> ?request_cancel_external_workflow_execution_failed_event_attributes: Types.request_cancel_external_workflow_execution_failed_event_attributes -> ?request_cancel_external_workflow_execution_initiated_event_attributes: Types.request_cancel_external_workflow_execution_initiated_event_attributes -> ?external_workflow_execution_cancel_requested_event_attributes: Types.external_workflow_execution_cancel_requested_event_attributes -> ?signal_external_workflow_execution_failed_event_attributes: Types.signal_external_workflow_execution_failed_event_attributes -> ?external_workflow_execution_signaled_event_attributes: Types.external_workflow_execution_signaled_event_attributes -> ?signal_external_workflow_execution_initiated_event_attributes: Types.signal_external_workflow_execution_initiated_event_attributes -> ?child_workflow_execution_terminated_event_attributes: Types.child_workflow_execution_terminated_event_attributes -> ?child_workflow_execution_canceled_event_attributes: Types.child_workflow_execution_canceled_event_attributes -> ?child_workflow_execution_timed_out_event_attributes: Types.child_workflow_execution_timed_out_event_attributes -> ?child_workflow_execution_failed_event_attributes: Types.child_workflow_execution_failed_event_attributes -> ?child_workflow_execution_completed_event_attributes: Types.child_workflow_execution_completed_event_attributes -> ?child_workflow_execution_started_event_attributes: Types.child_workflow_execution_started_event_attributes -> ?start_child_workflow_execution_initiated_event_attributes: Types.start_child_workflow_execution_initiated_event_attributes -> ?timer_canceled_event_attributes:Types.timer_canceled_event_attributes -> ?timer_fired_event_attributes:Types.timer_fired_event_attributes -> ?timer_started_event_attributes:Types.timer_started_event_attributes -> ?record_marker_failed_event_attributes: Types.record_marker_failed_event_attributes -> ?marker_recorded_event_attributes:Types.marker_recorded_event_attributes -> ?workflow_execution_signaled_event_attributes: Types.workflow_execution_signaled_event_attributes -> ?activity_task_cancel_requested_event_attributes: Types.activity_task_cancel_requested_event_attributes -> ?activity_task_canceled_event_attributes: Types.activity_task_canceled_event_attributes -> ?activity_task_timed_out_event_attributes: Types.activity_task_timed_out_event_attributes -> ?activity_task_failed_event_attributes: Types.activity_task_failed_event_attributes -> ?activity_task_completed_event_attributes: Types.activity_task_completed_event_attributes -> ?activity_task_started_event_attributes: Types.activity_task_started_event_attributes -> ?activity_task_scheduled_event_attributes: Types.activity_task_scheduled_event_attributes -> ?decision_task_timed_out_event_attributes: Types.decision_task_timed_out_event_attributes -> ?decision_task_completed_event_attributes: Types.decision_task_completed_event_attributes -> ?decision_task_started_event_attributes: Types.decision_task_started_event_attributes -> ?decision_task_scheduled_event_attributes: Types.decision_task_scheduled_event_attributes -> ?workflow_execution_cancel_requested_event_attributes: Types.workflow_execution_cancel_requested_event_attributes -> ?workflow_execution_terminated_event_attributes: Types.workflow_execution_terminated_event_attributes -> ?continue_as_new_workflow_execution_failed_event_attributes: Types.continue_as_new_workflow_execution_failed_event_attributes -> ?workflow_execution_continued_as_new_event_attributes: Types.workflow_execution_continued_as_new_event_attributes -> ?cancel_workflow_execution_failed_event_attributes: Types.cancel_workflow_execution_failed_event_attributes -> ?workflow_execution_canceled_event_attributes: Types.workflow_execution_canceled_event_attributes -> ?workflow_execution_timed_out_event_attributes: Types.workflow_execution_timed_out_event_attributes -> ?fail_workflow_execution_failed_event_attributes: Types.fail_workflow_execution_failed_event_attributes -> ?workflow_execution_failed_event_attributes: Types.workflow_execution_failed_event_attributes -> ?complete_workflow_execution_failed_event_attributes: Types.complete_workflow_execution_failed_event_attributes -> ?workflow_execution_completed_event_attributes: Types.workflow_execution_completed_event_attributes -> ?workflow_execution_started_event_attributes: Types.workflow_execution_started_event_attributes -> event_id:Types.event_id -> event_type:Types.event_type -> event_timestamp:Types.timestamp -> unit -> Types.history_event
val make_decision_task : ?previous_started_event_id:Types.event_id -> ?next_page_token:Types.page_token -> events:Types.history_event_list -> workflow_type:Types.workflow_type -> workflow_execution:Types.workflow_execution -> started_event_id:Types.event_id -> task_token:Types.task_token -> unit -> Types.decision_task
val make_poll_for_decision_task_input : ?start_at_previous_started_event:Types.start_at_previous_started_event -> ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> ?identity:Types.identity -> task_list:Types.task_list -> domain:Types.domain_name -> unit -> Types.poll_for_decision_task_input
val make_activity_task : ?input:Types.data -> activity_type:Types.activity_type -> workflow_execution:Types.workflow_execution -> started_event_id:Types.event_id -> activity_id:Types.activity_id -> task_token:Types.task_token -> unit -> Types.activity_task
val make_poll_for_activity_task_input : ?identity:Types.identity -> task_list:Types.task_list -> domain:Types.domain_name -> unit -> Types.poll_for_activity_task_input
val make_list_workflow_types_input : ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> ?name:Types.name -> registration_status:Types.registration_status -> domain:Types.domain_name -> unit -> Types.list_workflow_types_input
val make_list_tags_for_resource_output : ?tags:Types.resource_tag_list -> unit -> Types.list_tags_for_resource_output
val make_list_tags_for_resource_input : resource_arn:Types.arn -> unit -> Types.list_tags_for_resource_input
val make_execution_time_filter : ?latest_date:Types.timestamp -> oldest_date:Types.timestamp -> unit -> Types.execution_time_filter
val make_list_open_workflow_executions_input : ?execution_filter:Types.workflow_execution_filter -> ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> ?tag_filter:Types.tag_filter -> ?type_filter:Types.workflow_type_filter -> start_time_filter:Types.execution_time_filter -> domain:Types.domain_name -> unit -> Types.list_open_workflow_executions_input
val make_domain_info : ?arn:Types.arn -> ?description:Types.description -> status:Types.registration_status -> name:Types.domain_name -> unit -> Types.domain_info
val make_domain_infos : ?next_page_token:Types.page_token -> domain_infos:Types.domain_info_list -> unit -> Types.domain_infos
val make_list_domains_input : ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> registration_status:Types.registration_status -> unit -> Types.list_domains_input
val make_close_status_filter : status:Types.close_status -> unit -> Types.close_status_filter
val make_list_closed_workflow_executions_input : ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> ?tag_filter:Types.tag_filter -> ?type_filter:Types.workflow_type_filter -> ?close_status_filter:Types.close_status_filter -> ?execution_filter:Types.workflow_execution_filter -> ?close_time_filter:Types.execution_time_filter -> ?start_time_filter:Types.execution_time_filter -> domain:Types.domain_name -> unit -> Types.list_closed_workflow_executions_input
val make_activity_type_info : ?deprecation_date:Types.timestamp -> ?description:Types.description -> creation_date:Types.timestamp -> status:Types.registration_status -> activity_type:Types.activity_type -> unit -> Types.activity_type_info
val make_activity_type_infos : ?next_page_token:Types.page_token -> type_infos:Types.activity_type_info_list -> unit -> Types.activity_type_infos
val make_list_activity_types_input : ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> ?name:Types.name -> registration_status:Types.registration_status -> domain:Types.domain_name -> unit -> Types.list_activity_types_input
val make_history : ?next_page_token:Types.page_token -> events:Types.history_event_list -> unit -> Types.history
val make_get_workflow_execution_history_input : ?reverse_order:Types.reverse_order -> ?maximum_page_size:Types.page_size -> ?next_page_token:Types.page_token -> execution:Types.workflow_execution -> domain:Types.domain_name -> unit -> Types.get_workflow_execution_history_input
val make_describe_workflow_type_input : workflow_type:Types.workflow_type -> domain:Types.domain_name -> unit -> Types.describe_workflow_type_input
val make_describe_workflow_execution_input : execution:Types.workflow_execution -> domain:Types.domain_name -> unit -> Types.describe_workflow_execution_input
val make_domain_configuration : workflow_execution_retention_period_in_days:Types.duration_in_days -> unit -> Types.domain_configuration
val make_domain_detail : configuration:Types.domain_configuration -> domain_info:Types.domain_info -> unit -> Types.domain_detail
val make_describe_domain_input : name:Types.domain_name -> unit -> Types.describe_domain_input
val make_activity_type_configuration : ?default_task_schedule_to_close_timeout:Types.duration_in_seconds_optional -> ?default_task_schedule_to_start_timeout:Types.duration_in_seconds_optional -> ?default_task_priority:Types.task_priority -> ?default_task_list:Types.task_list -> ?default_task_heartbeat_timeout:Types.duration_in_seconds_optional -> ?default_task_start_to_close_timeout:Types.duration_in_seconds_optional -> unit -> Types.activity_type_configuration
val make_activity_type_detail : configuration:Types.activity_type_configuration -> type_info:Types.activity_type_info -> unit -> Types.activity_type_detail
val make_describe_activity_type_input : activity_type:Types.activity_type -> domain:Types.domain_name -> unit -> Types.describe_activity_type_input
val make_deprecate_workflow_type_input : workflow_type:Types.workflow_type -> domain:Types.domain_name -> unit -> Types.deprecate_workflow_type_input
val make_deprecate_domain_input : name:Types.domain_name -> unit -> Types.deprecate_domain_input
val make_deprecate_activity_type_input : activity_type:Types.activity_type -> domain:Types.domain_name -> unit -> Types.deprecate_activity_type_input
val make_delete_workflow_type_input : workflow_type:Types.workflow_type -> domain:Types.domain_name -> unit -> Types.delete_workflow_type_input
val make_delete_activity_type_input : activity_type:Types.activity_type -> domain:Types.domain_name -> unit -> Types.delete_activity_type_input
val make_pending_task_count : ?truncated:Types.truncated -> count:Types.count -> unit -> Types.pending_task_count
val make_count_pending_decision_tasks_input : task_list:Types.task_list -> domain:Types.domain_name -> unit -> Types.count_pending_decision_tasks_input
val make_count_pending_activity_tasks_input : task_list:Types.task_list -> domain:Types.domain_name -> unit -> Types.count_pending_activity_tasks_input
val make_count_open_workflow_executions_input : ?execution_filter:Types.workflow_execution_filter -> ?tag_filter:Types.tag_filter -> ?type_filter:Types.workflow_type_filter -> start_time_filter:Types.execution_time_filter -> domain:Types.domain_name -> unit -> Types.count_open_workflow_executions_input
val make_count_closed_workflow_executions_input : ?close_status_filter:Types.close_status_filter -> ?tag_filter:Types.tag_filter -> ?type_filter:Types.workflow_type_filter -> ?execution_filter:Types.workflow_execution_filter -> ?close_time_filter:Types.execution_time_filter -> ?start_time_filter:Types.execution_time_filter -> domain:Types.domain_name -> unit -> Types.count_closed_workflow_executions_input

Operations

module CountClosedWorkflowExecutions : sig ... end

Returns the number of closed workflow executions within the given domain that meet the specified filtering criteria.

module CountOpenWorkflowExecutions : sig ... end

Returns the number of open workflow executions within the given domain that meet the specified filtering criteria.

module CountPendingActivityTasks : sig ... end

Returns the estimated number of activity tasks in the specified task list. The count returned is an approximation and isn't guaranteed to be exact. If you specify a task list that no activity task was ever scheduled in then 0 is returned.

module CountPendingDecisionTasks : sig ... end

Returns the estimated number of decision tasks in the specified task list. The count returned is an approximation and isn't guaranteed to be exact. If you specify a task list that no decision task was ever scheduled in then 0 is returned.

module DeleteActivityType : sig ... end

Deletes the specified activity type.

module DeleteWorkflowType : sig ... end

Deletes the specified workflow type.

module DeprecateActivityType : sig ... end

Deprecates the specified activity type. After an activity type has been deprecated, you cannot create new tasks of that activity type. Tasks of this type that were scheduled before the type was deprecated continue to run.

module DeprecateDomain : sig ... end

Deprecates the specified domain. After a domain has been deprecated it cannot be used to create new workflow executions or register new types. However, you can still use visibility actions on this domain. Deprecating a domain also deprecates all activity and workflow types registered in the domain. Executions that were started before the domain was deprecated continues to run.

module DeprecateWorkflowType : sig ... end

Deprecates the specified workflow type. After a workflow type has been deprecated, you cannot create new executions of that type. Executions that were started before the type was deprecated continues to run. A deprecated workflow type may still be used when calling visibility actions.

module DescribeActivityType : sig ... end

Returns information about the specified activity type. This includes configuration settings provided when the type was registered and other general information about the type.

module DescribeDomain : sig ... end

Returns information about the specified domain, including description and status.

module DescribeWorkflowExecution : sig ... end

Returns information about the specified workflow execution including its type and some statistics.

module DescribeWorkflowType : sig ... end

Returns information about the specified workflow type. This includes configuration settings specified when the type was registered and other information such as creation date, current status, etc.

module GetWorkflowExecutionHistory : sig ... end

Returns the history of the specified workflow execution. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call.

module ListActivityTypes : sig ... end

Returns information about all activities registered in the specified domain that match the specified name and registration status. The result includes information like creation date, current status of the activity, etc. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call.

module ListClosedWorkflowExecutions : sig ... end

Returns a list of closed workflow executions in the specified domain that meet the filtering criteria. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call.

module ListDomains : sig ... end

Returns the list of domains registered in the account. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call.

module ListOpenWorkflowExecutions : sig ... end

Returns a list of open workflow executions in the specified domain that meet the filtering criteria. The results may be split into multiple pages. To retrieve subsequent pages, make the call again using the nextPageToken returned by the initial call.

module ListTagsForResource : sig ... end

List tags for a given domain.

module ListWorkflowTypes : sig ... end

Returns information about workflow types in the specified domain. The results may be split into multiple pages that can be retrieved by making the call repeatedly.

module PollForActivityTask : sig ... end

Used by workers to get an ActivityTask from the specified activity taskList. This initiates a long poll, where the service holds the HTTP connection open and responds as soon as a task becomes available. The maximum time the service holds on to the request before responding is 60 seconds. If no task is available within 60 seconds, the poll returns an empty result. An empty result, in this context, means that an ActivityTask is returned, but that the value of taskToken is an empty string. If a task is returned, the worker should use its type to identify and process it correctly.

module PollForDecisionTask : sig ... end

Used by deciders to get a DecisionTask from the specified decision taskList. A decision task may be returned for any open workflow execution that is using the specified task list. The task includes a paginated view of the history of the workflow execution. The decider should use the workflow type and the history to determine how to properly handle the task.

module RecordActivityTaskHeartbeat : sig ... end

Used by activity workers to report to the service that the ActivityTask represented by the specified taskToken is still making progress. The worker can also specify details of the progress, for example percent complete, using the details parameter. This action can also be used by the worker as a mechanism to check if cancellation is being requested for the activity task. If a cancellation is being attempted for the specified task, then the boolean cancelRequested flag returned by the service is set to true.

module RegisterActivityType : sig ... end

Registers a new activity type along with its configuration settings in the specified domain.

module RegisterDomain : sig ... end

Registers a new domain.

module RegisterWorkflowType : sig ... end

Registers a new workflow type and its configuration settings in the specified domain.

module RequestCancelWorkflowExecution : sig ... end

Records a WorkflowExecutionCancelRequested event in the currently running workflow execution identified by the given domain, workflowId, and runId. This logically requests the cancellation of the workflow execution as a whole. It is up to the decider to take appropriate actions when it receives an execution history with this event.

module RespondActivityTaskCanceled : sig ... end

Used by workers to tell the service that the ActivityTask identified by the taskToken was successfully canceled. Additional details can be provided using the details argument.

module RespondActivityTaskCompleted : sig ... end

Used by workers to tell the service that the ActivityTask identified by the taskToken completed successfully with a result (if provided). The result appears in the ActivityTaskCompleted event in the workflow history.

module RespondActivityTaskFailed : sig ... end

Used by workers to tell the service that the ActivityTask identified by the taskToken has failed with reason (if specified). The reason and details appear in the ActivityTaskFailed event added to the workflow history.

module RespondDecisionTaskCompleted : sig ... end

Used by deciders to tell the service that the DecisionTask identified by the taskToken has successfully completed. The decisions argument specifies the list of decisions made while processing the task.

module SignalWorkflowExecution : sig ... end

Records a WorkflowExecutionSignaled event in the workflow execution history and creates a decision task for the workflow execution identified by the given domain, workflowId and runId. The event is recorded with the specified user defined signalName and input (if provided).

module StartWorkflowExecution : sig ... end

Starts an execution of the workflow type in the specified domain using the provided workflowId and input data.

module TagResource : sig ... end

Add a tag to a Amazon SWF domain.

module TerminateWorkflowExecution : sig ... end

Records a WorkflowExecutionTerminated event and forces closure of the workflow execution identified by the given domain, runId, and workflowId. The child policy, registered with the workflow type or specified when starting this execution, is applied to any open child workflow executions of this workflow execution.

module UndeprecateActivityType : sig ... end

Undeprecates a previously deprecated activity type. After an activity type has been undeprecated, you can create new tasks of that activity type.

module UndeprecateDomain : sig ... end

Undeprecates a previously deprecated domain. After a domain has been undeprecated it can be used to create new workflow executions or register new types.

module UndeprecateWorkflowType : sig ... end

Undeprecates a previously deprecated workflow type. After a workflow type has been undeprecated, you can create new executions of that type.

module UntagResource : sig ... end

Remove a tag from a Amazon SWF domain.

module Json_serializers : sig ... end
module Json_deserializers : sig ... end