Struct Worker

pub struct Worker { /* private fields */ }

Distributed task worker

Implementations

impl Worker

pub fn new(config: Config) -> Self

Creates a new worker with the given configuration

Arguments

• config - Worker configuration

Example

use go_server_rust_sdk::worker::{Worker, Config};
 
let config = Config {
    scheduler_url: "ws://localhost:8080/api/worker/connect/123456".to_string(),
    worker_group: "math".to_string(),
    max_retry: 5,
    ping_interval: 5,
};
 
let worker = Worker::new(config);

pub fn register_method<F>( &mut self, name: impl Into<String>, handler: F, docs: Vec<String>, )

where F: Fn(Value) -> Result<Value> + Send + Sync + 'static,

Registers a method handler with the worker

Arguments

• name - Method name
• handler - Function that handles the method call
• docs - Documentation strings for the method

Example

use go_server_rust_sdk::worker::{Worker, Config};
use serde_json::{json, Value};
 
let mut worker = Worker::new(config);
 
worker.register_method("add", |params: Value| {
    let a = params["a"].as_f64().unwrap_or(0.0);
    let b = params["b"].as_f64().unwrap_or(0.0);
    Ok(json!(a + b))
}, vec!["Add two numbers".to_string()]);

pub async fn start(&mut self) -> Result<()>

Starts the worker with automatic reconnection support

This method will block until the worker is stopped.

Returns

A Result indicating success or failure

Example

use go_server_rust_sdk::worker::{Worker, Config};
 
let mut worker = Worker::new(config);
// Register methods...
worker.start().await?;

pub async fn stop(&mut self)

Stops the worker

This method will signal the worker to stop and close all connections.

Example

use go_server_rust_sdk::worker::{Worker, Config};
 
let mut worker = Worker::new(config);
 
// In another task or signal handler:
worker.stop().await;