Struct ExternalIntegrationRegistry 

pub struct ExternalIntegrationRegistry { /* private fields */ }

External integration registry.

Implementations

impl ExternalIntegrationRegistry

pub fn new() -> Self

Create a new external integration registry.

pub async fn register_callback(&self, handler: Arc<dyn CallbackHandler>)

Register a callback handler.

pub async fn dispatch_callback(&self, payload: CallbackPayload) -> Result<()>

Dispatch a callback to all registered handlers.

pub fn webhooks(&self) -> &Arc<WebhookRegistry>

Get the webhook registry.

pub async fn register_emitter(&self, emitter: Arc<dyn EventEmitter>)

Register an event emitter.

pub async fn emit_event(&self, event: ExternalEvent) -> Result<()>

Emit an event to all registered emitters.

pub async fn emit_workflow_started(&self, state: &WorkflowState) -> Result<()>

Emit workflow started event.

pub async fn emit_workflow_completed(&self, state: &WorkflowState) -> Result<()>

Emit workflow completed event.

pub async fn emit_workflow_failed( &self, state: &WorkflowState, error: &str, ) -> Result<()>

Emit workflow failed event.

pub async fn emit_task_started( &self, workflow_id: &str, task: &TaskState, ) -> Result<()>

Emit task started event.

pub async fn emit_task_completed( &self, workflow_id: &str, task: &TaskState, ) -> Result<()>

Emit task completed event.

pub async fn emit_task_failed( &self, workflow_id: &str, task: &TaskState, ) -> Result<()>

Emit task failed event.

Trait Implementations

impl Default for ExternalIntegrationRegistry

fn default() -> Self

Returns the “default value” for a type.