Struct Worker 

pub struct Worker { /* private fields */ }

Asset worker for polling asset updates via the Bitfinex REST API.

The Worker manages asynchronous REST API polling 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 Bitfinex worker, which is used for metrics collection and logging.

Returns

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

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 BitfinexWorker.

This method creates a Bitfinex REST API client, spawns an asynchronous task to poll for asset updates at the configured interval, and returns the running Worker instance.

Parameters

• opts: Configuration options for the worker, including URL and update interval
• 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.