vane 0.9.2

A flow-based reverse proxy with multi-layer routing and programmable pipelines.
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
36
37
38
39
40
41
42

/* src/common/sys/lifecycle.rs */

use crate::common::config::file_loader;
use crate::layers::l4::{health, session};
use crate::layers::l4p::quic::session as quic_session;
use once_cell::sync::Lazy;
use std::time::Instant;

pub static START_TIME: Lazy<Instant> = Lazy::new(Instant::now);

#[derive(Debug, thiserror::Error)]
pub enum Error {
	#[error("IO Error: {0}")]
	Io(String),
	#[error("TLS Error: {0}")]
	Tls(String),
	#[error("Configuration Error: {0}")]
	Configuration(String),
	#[error("System Error: {0}")]
	System(String),
	#[error("Not Implemented: {0}")]
	NotImplemented(String),
	#[error("Anyhow: {0}")]
	Anyhow(#[from] anyhow::Error),
}

pub type Result<T> = std::result::Result<T, Error>;

/// Ensures all mandatory configuration directories and files exist.
pub async fn ensure_config_files_exist() {
	file_loader::init_config_dirs(vec!["listener", "resolver", "certs", "application", "bin"]).await;
	file_loader::init_config_files(vec!["listener/unixsocket.yml", "nodes.yml", "plugins.json"])
		.await;
}

/// Spawns essential background maintenance tasks.
pub async fn start_background_tasks() {
	health::initial_health_check().await;
	health::start_periodic_health_checkers();
	session::start_session_cleanup_task();
	quic_session::start_cleanup_task();
}