Struct PoolRoundRobinPlacement 

pub struct PoolRoundRobinPlacement<Events: EngineEventBatch> { /* private fields */ }

Implementations

impl<Events: EngineEventBatch> PoolRoundRobinPlacement<Events>

pub fn new(workers: Vec<WorkerTopology>) -> Self

Trait Implementations

impl<Events: Debug + EngineEventBatch> Debug for PoolRoundRobinPlacement<Events>

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

Formats the value using the given formatter.

impl<Request, Events> PlacementPolicy<Request> for PoolRoundRobinPlacement<Events>

where Request: RequestIdentity, Events: EngineEventBatch,

type Metadata = ()

type Observation = Events

fn place( &mut self, request: &Request, _metadata: Self::Metadata, _session_id: Option<String>, _now_ms: f64, ) -> Result<PlacementEffects>

fn observe( &mut self, _observation: Events, _now_ms: f64, ) -> Result<Vec<Placement>>

fn cancel_pending(&mut self, _request_id: Uuid) -> bool

fn request_terminal( &mut self, _request_id: Uuid, _now_ms: f64, ) -> Result<Vec<Placement>>

fn prefill_completed( &mut self, _request_id: Uuid, _now_ms: f64, ) -> Result<Vec<Placement>>

fn pending_count(&self) -> usize

fn worker_ready( &mut self, worker: WorkerTopology, _now_ms: f64, ) -> Result<Vec<Placement>>

fn worker_draining( &mut self, worker: WorkerTopology, _now_ms: f64, ) -> Result<Vec<Placement>>

fn worker_removed( &mut self, worker: WorkerTopology, _now_ms: f64, ) -> Result<Vec<Placement>>

fn topology_settled(&mut self, _now_ms: f64) -> Result<Vec<Placement>>