System Initiative

use std::{ sync::Arc, time::Duration, }; use dal::DalContextBuilder; use edda_client::EddaClient; use nats_dead_letter_queue::DeadLetterQueue; use pinga_client::PingaClient; use si_data_nats::{ NatsClient, async_nats::jetstream, }; use tokio_util::{ sync::CancellationToken, task::TaskTracker, }; use crate::{ Features, ServerMetadata, }; /// Application state. #[derive(Clone, Debug)] pub(crate) struct AppState { pub(crate) metadata: Arc<ServerMetadata>, pub(crate) nats: NatsClient, pub(crate) pinga: PingaClient, pub(crate) edda: EddaClient, pub(crate) requests_stream: jetstream::stream::Stream, pub(crate) dead_letter_queue: DeadLetterQueue, pub(crate) ctx_builder: DalContextBuilder, pub(crate) quiescent_period: Duration, pub(crate) token: CancellationToken, pub(crate) server_tracker: TaskTracker, pub(crate) features: Features, } impl AppState { /// Creates a new [`AppState`]. #[allow(clippy::too_many_arguments)] pub(crate) fn new( metadata: Arc<ServerMetadata>, nats: NatsClient, pinga: PingaClient, edda: EddaClient, requests_stream: jetstream::stream::Stream, dead_letter_queue: DeadLetterQueue, ctx_builder: DalContextBuilder, quiescent_period: Duration, token: CancellationToken, server_tracker: TaskTracker, features: Features, ) -> Self { Self { metadata, nats, pinga, edda, requests_stream, dead_letter_queue, ctx_builder, quiescent_period, token, server_tracker, features, } } }