Struct Worker 

pub struct Worker { /* private fields */ }

Asset worker for subscribing to asset updates via the OKX WebSocket API.

The Worker manages asynchronous WebSocket connections for asset updates and ensures resources are properly cleaned up when dropped.

Trait Implementations

impl AssetWorker for Worker

fn name(&self) -> &'static str

Returns the name identifier for the worker.

This method provides a unique identifier for the OKX worker, which is used for metrics collection and logging.

Returns

A static string slice containing the worker name “okx”.

fn build<'life0, 'async_trait, S>( opts: Self::Opts, store: &'life0 S, ids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<Self, AssetWorkerError>> + Send + 'async_trait>>

where S: 'async_trait + Store + 'static, Self: 'async_trait, 'life0: 'async_trait,

Builds and starts the OKXWorker.

This method creates an OKX WebSocket client, spawns an asynchronous task to subscribe to asset updates, and returns the running Worker instance.

Parameters

• opts: Configuration options for the worker, including URL
• store: The store instance for persisting asset data
• ids: A vector of asset identifiers to monitor

Returns

Returns a Result containing a Worker instance on success, or an AssetWorkerError if the worker cannot be built.

type Opts = WorkerOpts

Configuration options for the worker.