Struct NotificationRouter 

pub struct NotificationRouter { /* private fields */ }

複数の通知手段をオーケストレートし、リソースに基づいて適切な通知先にルーティングする

各種Sender（Slack, Mock等）を保持し、通知設定の種類に応じて適切なSenderに委譲します。

Implementations

impl NotificationRouter

pub fn new( config: ResourceConfig, identity_repo: Arc<dyn IdentityLinkRepository>, ) -> Self

Examples found in repository

examples/mock_usage.rs (line 32)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (mock example)");
    println!("This example uses mock implementations - no credentials required!\n");

    // Load configuration
    let config = load_config("config/resources.toml")?;

    // Create identity link repository
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(
        "data/identity_links.json".into(),
    ));

    // Create mock repository and notification router
    let repository = MockUsageRepository::new();
    let notifier = NotificationRouter::new(config, identity_repo);

    println!("✅ Mock repository and notification router initialized");

    // Create use case
    let usecase = NotifyResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Poll once to demonstrate
    println!("📊 Polling for changes...\n");
    usecase.poll_once().await?;

    println!("\n✅ Example completed successfully!");
    println!("💡 Note: Mock repository returns empty results by default.");
    println!(
        "   To see actual notifications, configure mock notifications in config/resources.toml"
    );

    Ok(())
}

examples/basic_usage.rs (line 60)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (basic example)");

    // Load resource configuration
    let dotenv_path = dotenv::dotenv().ok();
    let project_root = dotenv_path
        .as_ref()
        .and_then(|p| p.parent())
        .map(|p| p.to_path_buf())
        .unwrap_or_else(|| std::env::current_dir().expect("Failed to get current directory"));

    let config_path =
        std::env::var("RESOURCE_CONFIG").unwrap_or_else(|_| "config/resources.toml".to_string());
    let absolute_config_path = project_root.join(&config_path);

    let config = load_config(
        absolute_config_path
            .to_str()
            .expect("Failed to convert path"),
    )?;
    println!("✅ Configuration loaded");

    // Create repository
    let service_account_key = std::env::var("GOOGLE_SERVICE_ACCOUNT_KEY")
        .expect("GOOGLE_SERVICE_ACCOUNT_KEY must be set");
    let absolute_key_path = project_root.join(&service_account_key);

    let repository = GoogleCalendarUsageRepository::new(
        absolute_key_path.to_str().expect("Failed to convert path"),
        config.clone(),
    )
    .await?;
    println!("✅ Google Calendar repository initialized");

    // Create identity link repository
    let identity_links_path = std::env::var("IDENTITY_LINKS_FILE")
        .map(|p| project_root.join(p))
        .unwrap_or_else(|_| project_root.join("data/identity_links.json"));
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(identity_links_path));

    // Create notification router (uses configured notification destinations and identity_repo)
    let notifier = NotificationRouter::new(config, identity_repo);
    println!("✅ Notification router initialized (using configured destinations)");

    // Create use case
    let usecase = NotifyResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Run polling loop
    let interval = Duration::from_secs(60);
    println!("🔍 Starting monitoring loop (interval: {:?})", interval);
    println!("Press Ctrl+C to stop\n");

    loop {
        match usecase.poll_once().await {
            Ok(_) => {
                println!("✅ Poll completed successfully");
            }
            Err(e) => {
                eprintln!("❌ Polling error: {}", e);
            }
        }

        tokio::time::sleep(interval).await;
    }
}

Trait Implementations

impl Notifier for NotificationRouter

fn notify<'life0, 'async_trait>( &'life0 self, event: NotificationEvent, ) -> Pin<Box<dyn Future<Output = Result<(), NotificationError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,