Struct pidgeon_cli::service::modbus::worker::Worker

pub(crate) struct Worker {
    sender: Sender<TaskRequest>,
    handle: Arc<Mutex<Option<JoinHandle<()>>>>,
    termination_timeout: Duration,
}

Fields

sender: Sender<TaskRequest>

handle: Arc<Mutex<Option<JoinHandle<()>>>>

termination_timeout: Duration

Implementations

impl Worker

pub(crate) fn new( request_timeout: Duration, termination_timeout: Duration, congestion_backoff: Duration, partial_retries: u32, ) -> Self

impl Worker

pub(crate) async fn read<TSpan: Span, TIntoIterator: IntoIterator<Item = TSpan>>( &self, destination: Destination, spans: TIntoIterator, ) -> Result<Vec<ReadResponseEntry>, SendError>

pub(crate) async fn write<TRecord: Record, TIntoIterator: IntoIterator<Item = TRecord>>( &self, destination: Destination, records: TIntoIterator, ) -> Result<Vec<WriteResponseEntry>, SendError>

pub(crate) async fn stream<TSpan: Span, TIntoIterator: IntoIterator<Item = TSpan>>( &self, destination: Destination, spans: TIntoIterator, ) -> Result<impl Stream<Item = Result<Vec<ReadResponseEntry>, SendError>> + Send + Sync, StreamError>

pub(crate) async fn terminate(&self) -> Result<(), TerminateError>

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Worker

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Worker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.