Struct AppState 

pub struct AppState {
    pub config: Arc<Config>,
    pub token: String,
    pub dedup: DedupStore,
    pub event_logger: EventLogger,
    pub privacy_filter: PrivacyFilter,
    pub event_counter: AtomicU64,
    pub shutdown_tx: Mutex<Option<Sender<()>>>,
    pub started_at: Instant,
    pub available_update: Mutex<Option<String>>,
}

Shared state injected into every axum handler via Arc<AppState>.

Fields are either inherently thread-safe (AtomicU64, DashMap, mpsc::Sender) or wrapped in appropriate synchronization primitives.

Fields

config: Arc<Config>

Resolved daemon configuration (port, log dir, retention, etc.)

token: String

Bearer token for authenticating POST requests. SECURITY: Never log this value.

dedup: DedupStore

In-memory dedup store with 100ms TTL.

event_logger: EventLogger

Async event logger (sends to background writer task via mpsc).

privacy_filter: PrivacyFilter

Pre-compiled privacy filter for credential masking.

event_counter: AtomicU64

Total events processed (not counting deduped duplicates).

shutdown_tx: Mutex<Option<Sender<()>>>

Oneshot sender for triggering graceful shutdown via POST /shutdown. Wrapped in Mutex so the handler can take ownership without &mut self.

started_at: Instant

Wall-clock time when the daemon started (for uptime reporting).

available_update: Mutex<Option<String>>

Latest available version string, populated by the async update check on startup. None means either the check has not completed yet, or the current version is latest.

Implementations

impl AppState

pub fn set_available_update(&self, version: String)

Store a newly discovered available version.

pub fn get_available_update(&self) -> Option<String>

Return the latest available version, if one has been discovered.