Struct RuntimeState 

pub struct RuntimeState {

    pub snapshot: Arc<ArcSwap<CompiledRuntimeSnapshot>>,
    pub routing: Arc<SharedRoutingService>,
    pub metrics: Arc<dyn SessionMetrics>,
    pub readiness: Arc<AtomicBool>,
    pub start_time: Instant,
    pub active_connections: Arc<AtomicU64>,
    pub connection_counter: Arc<AtomicU64>,
    pub admin_local_addr: Arc<Mutex<Option<SocketAddr>>>,
    pub listener_addrs: Arc<Mutex<Vec<Option<SocketAddr>>>>,
    pub health: Arc<Mutex<Option<HealthManager>>>,
    pub health_cancel: CancellationToken,
    pub health_runtime: Mutex<Option<Handle>>,
    pub udp_registry: Arc<UdpAssociationRegistry>,
    pub udp_metrics: Arc<UdpMetrics>,
    pub shadowsocks_metrics: Arc<ShadowsocksMetrics>,
    pub udp_tasks: TaskTracker,
    pub transparent_accepted_total: Arc<AtomicU64>,
    pub transparent_original_dst_failed_total: Arc<AtomicU64>,
    pub reverse_registry: Arc<ReverseRegistry>,
    pub reverse_metrics: Arc<ReverseMetrics>,
    /* private fields */
}

Fields

snapshot: Arc<ArcSwap<CompiledRuntimeSnapshot>>

routing: Arc<SharedRoutingService>

metrics: Arc<dyn SessionMetrics>

readiness: Arc<AtomicBool>

start_time: Instant

active_connections: Arc<AtomicU64>

connection_counter: Arc<AtomicU64>

admin_local_addr: Arc<Mutex<Option<SocketAddr>>>

listener_addrs: Arc<Mutex<Vec<Option<SocketAddr>>>>

health: Arc<Mutex<Option<HealthManager>>>

health_cancel: CancellationToken

health_runtime: Mutex<Option<Handle>>

udp_registry: Arc<UdpAssociationRegistry>

udp_metrics: Arc<UdpMetrics>

shadowsocks_metrics: Arc<ShadowsocksMetrics>

udp_tasks: TaskTracker

transparent_accepted_total: Arc<AtomicU64>

transparent_original_dst_failed_total: Arc<AtomicU64>

reverse_registry: Arc<ReverseRegistry>

reverse_metrics: Arc<ReverseMetrics>

Implementations

impl RuntimeState

pub fn generation(&self) -> u64

pub fn restart_health_probes(&self)

Restart health probes for the upstreams in the current snapshot.