Struct ResourceBasedTuner 

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

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

Implementations

impl ResourceBasedTuner<RealSysInfo>

pub fn new(target_mem_usage: f64, target_cpu_usage: f64) -> Self

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) -> Self

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 Self

Set workflow slot options

pub fn with_activity_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut Self

Set activity slot options

pub fn with_local_activity_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut Self

Set local activity slot options

pub fn with_nexus_slots_options( &mut self, opts: ResourceSlotOptions, ) -> &mut Self

Set nexus slot options

Trait Implementations

impl<MI: SystemResourceInfo + Sync + Send + 'static> WorkerTuner for ResourceBasedTuner<MI>

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

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> + Send + Sync>

Return a SlotSupplier for activity tasks

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

Return a SlotSupplier for local activities

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

Return a SlotSupplier for nexus tasks