Struct SecondaryWorkerState

struct SecondaryWorkerState {
    pub assigned_incomplete_works: Option<Vec<IncompleteWork>>,
    assigned_incomplete_work_batch_timeout_task_handle: Option<JoinHandle<()>>,
    high_priority_incomplete_works_buffer: Arc<Mutex<Vec<IncompleteWork>>>,
}

The view of Secondary Worker from the POV of primary worker, it only carries the state of the Secondary Worker Worker and the work they are doing for the primary worker

Fields

assigned_incomplete_works: Option<Vec<IncompleteWork>>

The IncompleteWorkBatch that’s currently assigned to the Secondary Worker to finish and whose primary worker is expecting CompletedWorkBatch

assigned_incomplete_work_batch_timeout_task_handle: Option<JoinHandle<()>>

The task we spawned to expire the batch of work we had assigned to the Secondary Worker

high_priority_incomplete_works_buffer: Arc<Mutex<Vec<IncompleteWork>>>

The clone of the high_priority_incomplete_works_buffer of PrimaryWorkerService

Implementations

impl SecondaryWorkerState

pub fn new( high_priority_incomplete_works_buffer: Arc<Mutex<Vec<IncompleteWork>>>, ) -> Arc<RwLock<Self>>

pub fn assign_incomplete_works(&mut self, batch: Vec<IncompleteWork>)

pub async fn start_incomplete_works_timeout_task( self_arc: Arc<RwLock<Self>>, timeout_duration: u64, )

Start the task that expires the batch of IncompleteWork(s) assigned to the Secondary Worker

On Expiration the IncompleteWork moves to the high priority queue

fn stop_incomplete_work_batch_timeout_task(&mut self)

Drop the timeout task that was spawned

fn remove_assigned_incomplete_work_batch(&mut self)

Trait Implementations

impl Debug for SecondaryWorkerState

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

Formats the value using the given formatter.