Function spawn_log_push_task

crates/openshell-supervisor-process/src/log_push.rs:97–106

Spawn a background task that batches and pushes log lines to the server. Returns the sender half of the channel (for the [`LogPushLayer`]) and the task handle. The task runs until the sender is dropped or the gRPC stream breaks.

(
    endpoint: String,
    sandbox_id: String,
)

/// task handle. The task runs until the sender is dropped or the gRPC stream
/// breaks.
pub fn spawn_log_push_task(
    endpoint: String,
    sandbox_id: String,
) -> (mpsc::Sender<SandboxLogLine>, tokio::task::JoinHandle<()>) {
    let (tx, rx) = mpsc::channel::<SandboxLogLine>(1024);

    let handle = tokio::spawn(run_push_loop(endpoint, sandbox_id, rx));

    (tx, handle)
}

/// Maximum backoff delay between reconnection attempts.
const MAX_BACKOFF: tokio::time::Duration = tokio::time::Duration::from_secs(30);