Skip to main content

run_worker

forge_worker_sdk::server

Function run_worker 

Source 
pub async fn run_worker<H: WorkerHandler>(
    socket_path: &str,
    handler: H,
    encoding: Encoding,
) -> Result<()>
Expand description

Start the IPC server. Blocks until the process exits (or an unrecoverable listener error occurs).

Spawns a background GC task that evicts old completed-job records every 60 s.