tasker-orchestration 0.1.7

Orchestration system for tasker workflow coordination
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! # Orchestration Queues - Queue-Level Event Coordination
//!
//! This module provides focused components for orchestration queue event handling,
//! creating architectural consistency with the database-level task_readiness components.
//!
//! ## Architecture
//!
//! - **listener**: tasker-pgmq listener for real-time orchestration queue events
//! - **fallback_poller**: Polling fallback for queue messages when events fail
//! - **events**: Event type definitions for orchestration queue messages
//!
//! ## Deployment Mode Support
//!
//! - **PollingOnly**: Only fallback_poller active
//! - **Hybrid**: listener (primary) + fallback_poller (backup)
//! - **EventDrivenOnly**: Only listener active
//!
//! ## Integration
//!
//! These components are used directly by OrchestrationEventSystem, following the same
//! architectural patterns as task_readiness components for consistent modularity.

pub mod events;
pub mod fallback_poller;
pub mod listener;

// Re-export key types for external usage
pub use events::OrchestrationQueueEvent;
pub use fallback_poller::{
    OrchestrationFallbackPoller, OrchestrationPollerConfig, OrchestrationPollerStats,
};
pub use listener::{
    OrchestrationListenerConfig, OrchestrationListenerStats, OrchestrationNotification,
    OrchestrationQueueListener,
};