Module Values.DecisionTaskSource

A structure that represents a decision task. Decision tasks are sent to deciders in order for them to make decisions.

Sourcetype nonrec t = {
  1. taskToken : TaskToken.t option;
    (*

    The opaque string used as a handle on the task. This token is used by workers to communicate progress and response information back to the system about the task.

    *)
  2. startedEventId : EventId.t option;
    (*

    The ID of the DecisionTaskStarted event recorded in the history.

    *)
  3. workflowExecution : WorkflowExecution.t option;
    (*

    The workflow execution for which this decision task was created.

    *)
  4. workflowType : WorkflowType.t option;
    (*

    The type of the workflow execution for which this decision task was created.

    *)
  5. events : HistoryEventList.t option;
    (*

    A paginated list of history events of the workflow execution. The decider uses this during the processing of the decision task.

    *)
  6. nextPageToken : PageToken.t option;
    (*

    If a NextPageToken was returned by a previous call, there are more results available. To retrieve the next page of results, make the call again using the returned token in nextPageToken. Keep all other arguments unchanged. The configured maximumPageSize determines how many results can be returned in a single call.

    *)
  7. previousStartedEventId : EventId.t option;
    (*

    The ID of the DecisionTaskStarted event of the previous decision task of this workflow execution that was processed by the decider. This can be used to determine the events in the history new since the last decision task received by the decider.

    *)
}
Sourcetype nonrec error = [
  1. | `LimitExceededFault of LimitExceededFault.t
  2. | `OperationNotPermittedFault of OperationNotPermittedFault.t
  3. | `UnknownResourceFault of UnknownResourceFault.t
  4. | `Unknown_operation_error of string * string option
]
Sourceval make : ?taskToken:??? -> ?startedEventId:??? -> ?workflowExecution:??? -> ?workflowType:??? -> ?events:??? -> ?nextPageToken:??? -> ?previousStartedEventId:??? -> unit -> t
Sourceval error_of_json : string -> Yojson.Safe.t -> [> `LimitExceededFault of LimitExceededFault.t | `OperationNotPermittedFault of OperationNotPermittedFault.t | `UnknownResourceFault of UnknownResourceFault.t | `Unknown_operation_error of string * string option ]
Sourceval error_of_xml : string -> Awso.Xml.t -> [> `LimitExceededFault of LimitExceededFault.t | `OperationNotPermittedFault of OperationNotPermittedFault.t | `UnknownResourceFault of UnknownResourceFault.t | `Unknown_operation_error of string * string option ]
Sourceval error_to_json : error -> Yojson.Safe.t
Sourceval to_value : t -> [> `Structure of (string * [> `List of [> `Structure of (string * [> `Enum of string | `Long of EventId.t | `Structure of (string * [> `Enum of string | `List of [> `String of Tag.t ] list | `Long of EventId.t | `String of Data.t | `Structure of (string * [> `String of Name.t ]) list ]) list | `Timestamp of Timestamp.t ]) list ] list | `Long of EventId.t | `String of TaskToken.t | `Structure of (string * [> `String of WorkflowId.t ]) list ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t