Struct TunnelManager 

pub struct TunnelManager {
    pub(crate) task_tracker: TaskTracker,
    pub(crate) cancel_guard: Option<DropGuard>,
}

Fields

task_tracker: TaskTracker

cancel_guard: Option<DropGuard>

Implementations

impl TunnelManager

pub async fn new(mqtt: MqttClient, thing_name: &str) -> Result<Self, Error>

Runs a new tunnel service in response to a tunnel notification.

This function is spawned as a new task when a tunnel notification is received. It creates a new Service instance and starts the tunnel using the payload from the received MQTT packet.

Arguments

• mqtt - The MqttClient instance to use for the MQTT subscription.
• thing_name - The name of the AWS IoT thing to subscribe to.

pub async fn shutdown(&mut self)

Graceful shutdown of the tunnel manager.