Struct ResourceBasedTuner 

pub struct ResourceBasedTuner<MI> { /* private fields */ }

Implements crate::worker::WorkerTuner and attempts to maintain certain levels of resource usage when under load.

It does so by using two PID controllers, one for memory and one for CPU, which are fed the current usage levels of their respective resource as measurements. The user specifies a target threshold for each, and slots are handed out if the output of both PID controllers is above some defined threshold. See ResourceBasedSlotsOptions for the default PID controller settings.

Note that different slot types make decisions independently of each other, though they use the same underlying system information.

Implementations

impl ResourceBasedTuner<RealSysInfo>

pub fn new( target_mem_usage: f64, target_cpu_usage: f64, ) -> ResourceBasedTuner<RealSysInfo>

Create an instance attempting to target the provided memory and cpu thresholds as values between 0 and 1.

pub fn new_from_options( options: ResourceBasedSlotsOptions, ) -> ResourceBasedTuner<RealSysInfo>

Create an instance using the fully configurable set of PID controller options

impl<MI> ResourceBasedTuner<MI>

pub fn with_workflow_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut ResourceBasedTuner<MI>

Set workflow slot options

pub fn with_activity_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut ResourceBasedTuner<MI>

Set activity slot options

pub fn with_local_activity_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut ResourceBasedTuner<MI>

Set local activity slot options

pub fn with_nexus_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut ResourceBasedTuner<MI>

Set nexus slot options

pub fn sys_info(&self) -> Arc<MI>

Get sys info

Trait Implementations

impl<MI> WorkerTuner for ResourceBasedTuner<MI>

where MI: SystemResourceInfo + Sync + Send + 'static,

fn workflow_task_slot_supplier( &self, ) -> Arc<dyn SlotSupplier<SlotKind = WorkflowSlotKind> + Sync + Send>

Return a SlotSupplier for workflow tasks. Note that workflow task slot suppliers must be willing to hand out a minimum of one non-sticky slot and one sticky slot if workflow caching is enabled, otherwise the worker may fail to process new tasks.

fn activity_task_slot_supplier( &self, ) -> Arc<dyn SlotSupplier<SlotKind = ActivitySlotKind> + Sync + Send>

Return a SlotSupplier for activity tasks

fn local_activity_slot_supplier( &self, ) -> Arc<dyn SlotSupplier<SlotKind = LocalActivitySlotKind> + Sync + Send>

Return a SlotSupplier for local activities

fn nexus_task_slot_supplier( &self, ) -> Arc<dyn SlotSupplier<SlotKind = NexusSlotKind> + Sync + Send>

Return a SlotSupplier for nexus tasks