CMDCGateway.WorkflowReplay (cmdc_gateway v0.6.0)

Copy Markdown View Source

Workflow RunEvent 只读 replay 接口。

Gateway 不拥有 RunStore,也不启动 workflow executor。事件来源必须由宿主 应用通过 config :cmdc_gateway, :workflow_event_source, ... 显式配置。

Summary

Functions

从服务端配置的 event source 读取 run event ledger 并投影为 Gateway 事件。

把 HTTP query params 转为 event source 支持的 replay opts。

Types

replay_result()

@type replay_result() :: %{runId: String.t(), events: [map()], page: map()}

Functions

replay(run_id, params \\ %{})

@spec replay(String.t(), map() | keyword()) ::
  {:ok, replay_result()} | {:error, term()}

从服务端配置的 event source 读取 run event ledger 并投影为 Gateway 事件。

replay_opts(params)

@spec replay_opts(map() | keyword()) :: keyword()

把 HTTP query params 转为 event source 支持的 replay opts。