Struct pidgeon_cli::service::modbus::worker::Task

struct Task {
    connections: HashMap<Device, Connection>,
    receiver: Receiver<TaskRequest>,
    reads: Vec<ReadRequestStorage>,
    writes: Vec<WriteRequestStorage>,
    streams: Vec<ReadRequestStorage>,
    terminate: bool,
    timeout: Duration,
    congestion_backoff: Duration,
    partial_retries: u32,
}

Fields

connections: HashMap<Device, Connection>

receiver: Receiver<TaskRequest>

reads: Vec<ReadRequestStorage>

writes: Vec<WriteRequestStorage>

streams: Vec<ReadRequestStorage>

terminate: bool

timeout: Duration

congestion_backoff: Duration

partial_retries: u32

Implementations

impl Task

pub(crate) fn new( read_timeout: Duration, receiver: Receiver<TaskRequest>, congestion_backoff: Duration, partial_retries: u32, ) -> Self

pub(crate) async fn execute(self)

async fn process_reads(&mut self, metrics: &mut Metrics)

async fn process_writes(&mut self, metrics: &mut Metrics)

async fn process_streams(&mut self, metrics: &mut Metrics, generation: u64)

fn try_recv_new_request(&mut self) -> Result<(), TryRecvError>

async fn recv_async_new_request(&mut self) -> Result<(), RecvError>

fn add_new_read_request(&mut self, request: ReadTaskRequest)

fn add_new_write_request(&mut self, request: WriteTaskRequest)

impl Task

async fn attempt_connection<'a>( connections: &'a mut HashMap<Device, Connection>, destination: &Destination, sender: Either<&Sender<Result<Vec<ReadResponseEntry>, SendError>>, &Sender<Result<Vec<WriteResponseEntry>, SendError>>>, ) -> ConnectionAttempt<'a>

impl Task

async fn read( storage: &ReadRequestStorage, metrics: &mut Metrics, connection: &mut Connection, timeout: Duration, congestion_backoff: Duration, ) -> Either<ReadPartial, Vec<ReadResponseEntry>>

async fn write( storage: &WriteRequestStorage, metrics: &mut Metrics, connection: &mut Connection, timeout: Duration, congestion_backoff: Duration, ) -> Either<WritePartial, Vec<WriteResponseEntry>>

Trait Implementations

impl Debug for Task

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

Formats the value using the given formatter.