GoodAnalytics.Connectors.PostCommit.FlowRunner (GoodAnalytics v0.1.1)

Copy Markdown View Source

Default flow runner for post-commit connector dispatch.

Delegates to PgFlow when its supervisor is running, providing durable out-of-transaction dispatch scheduling. Used as the configurable default for GoodAnalytics.Connectors.PostCommit.

Summary

Functions

available?()

Returns true when the PgFlow.Supervisor process is running.

start_flow(flow_module, input)

Starts a PgFlow flow for the given module and input map.

Functions

available?()

@spec available?() :: boolean()

Returns true when the PgFlow.Supervisor process is running.

start_flow(flow_module, input)

@spec start_flow(module(), map()) :: {:ok, term()} | {:error, term()}

Starts a PgFlow flow for the given module and input map.