Directories
¶
| Path | Synopsis |
|---|---|
|
datalayer
|
|
|
attribute/session
Package session declares the SessionID attribute that carries per-request session identity for affinity scoring and filtering.
|
Package session declares the SessionID attribute that carries per-request session identity for affinity scoring and filtering. |
|
discovery/file
Package file provides a file-based EndpointDiscovery implementation that reads a YAML (or JSON) file listing inference endpoints.
|
Package file provides a file-based EndpointDiscovery implementation that reads a YAML (or JSON) file listing inference endpoints. |
|
source/http/httptest
Package httptest provides test helpers for HTTPDataSource parser implementations.
|
Package httptest provides test helpers for HTTPDataSource parser implementations. |
|
flowcontrol
|
|
|
eviction/filtering
Package filtering provides built-in EvictionFilterPolicy implementations.
|
Package filtering provides built-in EvictionFilterPolicy implementations. |
|
fairness
Package fairness provides the standard implementations of the FairnessPolicy interface.
|
Package fairness provides the standard implementations of the FairnessPolicy interface. |
|
fairness/globalstrict
Package globalstrict implements a greedy fairness policy that enforces a strict global ordering across all flows within a priority band, ignoring flow boundaries.
|
Package globalstrict implements a greedy fairness policy that enforces a strict global ordering across all flows within a priority band, ignoring flow boundaries. |
|
fairness/program-aware
Package programaware implements a flow-control fairness policy that schedules per-program queues using a swappable scoring strategy.
|
Package programaware implements a flow-control fairness policy that schedules per-program queues using a swappable scoring strategy. |
|
fairness/roundrobin
Package roundrobin implements a fairness policy that selects queues from a priority band using a round-robin strategy, cycling through active flows one by one to guarantee that no single flow can starve others.
|
Package roundrobin implements a fairness policy that selects queues from a priority band using a round-robin strategy, cycling through active flows one by one to guarantee that no single flow can starve others. |
|
ordering
Package ordering provides the standard implementations of the OrderingPolicy interface.
|
Package ordering provides the standard implementations of the OrderingPolicy interface. |
|
ordering/edf
Package edf implements an ordering policy that selects requests based on their absolute deadlines (Earliest Deadline First).
|
Package edf implements an ordering policy that selects requests based on their absolute deadlines (Earliest Deadline First). |
|
ordering/fcfs
Package fcfs implements an ordering policy that selects requests based on their arrival order at the Flow Control layer (First-Come, First-Served).
|
Package fcfs implements an ordering policy that selects requests based on their arrival order at the Flow Control layer (First-Come, First-Served). |
|
ordering/slodeadline
Package slodeadline implements an ordering policy that selects requests based on an SLO-based deadline derived from request headers.
|
Package slodeadline implements an ordering policy that selects requests based on an SLO-based deadline derived from request headers. |
|
Package requestcontrol holds definitions shared by all requestcontrol framework plugins.
|
Package requestcontrol holds definitions shared by all requestcontrol framework plugins. |
|
admitter/probabilisticadmitter
Package probabilisticadmitter implements a binary-tier probabilistic admission control plugin.
|
Package probabilisticadmitter implements a binary-tier probabilistic admission control plugin. |
|
dataproducer/multimodal
Package multimodal provides a data producer for multimodal encoder-cache affinity.
|
Package multimodal provides a data producer for multimodal encoder-cache affinity. |
|
dataproducer/preciseprefixcache
Package preciseprefixcache hashes TokenizedPrompt into KV-block keys, looks them up in the index, and writes per-endpoint PrefixCacheMatchInfo.
|
Package preciseprefixcache hashes TokenizedPrompt into KV-block keys, looks them up in the index, and writes per-endpoint PrefixCacheMatchInfo. |
|
dataproducer/predictedlatency
Package requestcontrol contains helpers to decouple latency-predictor logic.
|
Package requestcontrol contains helpers to decouple latency-predictor logic. |
|
dataproducer/sessionid
Package sessionid provides a DataProducer that extracts a session identifier from a configured request header or named cookie and publishes it as a SessionID attribute on the InferenceRequest attribute store, so that affinity-aware scorers and filters can read it without knowing how the session was carried on the wire.
|
Package sessionid provides a DataProducer that extracts a session identifier from a configured request header or named cookie and publishes it as a SessionID attribute on the InferenceRequest attribute store, so that affinity-aware scorers and filters can read it without knowing how the session was carried on the wire. |
|
dataproducer/tokenizer
Package tokenizer provides a DataProducer plugin that tokenizes the request prompt and publishes the result on InferenceRequestBody.TokenizedPrompt for downstream consumers (scorers, filters, other data producers).
|
Package tokenizer provides a DataProducer plugin that tokenizes the request prompt and publishes the result on InferenceRequestBody.TokenizedPrompt for downstream consumers (scorers, filters, other data producers). |
|
preadmitter/agentidentity
Package agentidentity provides a PreAdmitter plugin that resolves agent identity from provider-specific headers into the FairnessID field.
|
Package agentidentity provides a PreAdmitter plugin that resolves agent identity from provider-specific headers into the FairnessID field. |
|
requesthandling
|
|
|
parsers/vllmhttp
Package vllmhttp provides a request parser for vLLM HTTP endpoints that are not part of the OpenAI-compatible API surface — specifically /inference/v1/generate.
|
Package vllmhttp provides a request parser for vLLM HTTP endpoints that are not part of the OpenAI-compatible API surface — specifically /inference/v1/generate. |
|
Package scheduling holds definitions shared by all scheduling framework plugins.
|
Package scheduling holds definitions shared by all scheduling framework plugins. |
|
filter/bylabel
Package bylabel provides filter plugins for the epp.
|
Package bylabel provides filter plugins for the epp. |
|
filter/prefixcacheaffinity
Package prefixcacheaffinity provides a probabilistic filter that narrows candidates to "sticky" endpoints (those with high prefix cache scores).
|
Package prefixcacheaffinity provides a probabilistic filter that narrows candidates to "sticky" endpoints (those with high prefix cache scores). |
|
filter/sessionaffinity
Package sessionaffinity provides a session affinity filter plugin for the epp.
|
Package sessionaffinity provides a session affinity filter plugin for the epp. |
|
filter/sloheadroomtier
Package headroomtier provides a probabilistic filter that selects endpoints based on predicted latency headroom (SLO - predicted).
|
Package headroomtier provides a probabilistic filter that selects endpoints based on predicted latency headroom (SLO - predicted). |
|
picker
Package picker provides the standard implementations of the Picker interface for the scheduling framework.
|
Package picker provides the standard implementations of the Picker interface for the scheduling framework. |
|
picker/maxscore
Package maxscore implements a scheduling picker that selects the endpoint(s) with the highest score calculated during the scoring phase.
|
Package maxscore implements a scheduling picker that selects the endpoint(s) with the highest score calculated during the scoring phase. |
|
picker/random
Package random implements a scheduling picker that selects endpoints uniformly at random, ignoring any scores calculated by scorer plugins.
|
Package random implements a scheduling picker that selects endpoints uniformly at random, ignoring any scores calculated by scorer plugins. |
|
picker/weightedrandom
Package weightedrandom implements a scheduling picker that selects endpoints randomly, where the probability of an endpoint being selected is proportional to its score.
|
Package weightedrandom implements a scheduling picker that selects endpoints randomly, where the probability of an endpoint being selected is proportional to its score. |
|
profilehandler/dataparallel
Package dataparallel provides a data-parallel profile handler plugin for the epp.
|
Package dataparallel provides a data-parallel profile handler plugin for the epp. |
|
profilehandler/disagg
Package disagg provides profile handler plugins for the epp.
|
Package disagg provides profile handler plugins for the epp. |
|
scorer/activerequest
Package activerequest provides an active request scorer plugin for the epp.
|
Package activerequest provides an active request scorer plugin for the epp. |
|
scorer/contextlengthaware
Package contextlengthaware provides plugins that implement multiple extension points (e.g., both Filter and Scorer interfaces).
|
Package contextlengthaware provides plugins that implement multiple extension points (e.g., both Filter and Scorer interfaces). |
|
scorer/latency
Package latency provides a scorer that scores endpoints based on predicted latency headroom.
|
Package latency provides a scorer that scores endpoints based on predicted latency headroom. |
|
scorer/loadaware
Package loadaware provides a load-aware scorer plugin for the epp.
|
Package loadaware provides a load-aware scorer plugin for the epp. |
|
scorer/mmcacheaffinity
Package mmcacheaffinity scores endpoints from multimodal encoder-cache match info produced by the request-control multimodal data producer.
|
Package mmcacheaffinity scores endpoints from multimodal encoder-cache match info produced by the request-control multimodal data producer. |
|
scorer/nohitlru
Package nohitlru provides a no-hit LRU scorer plugin for the epp.
|
Package nohitlru provides a no-hit LRU scorer plugin for the epp. |
|
scorer/preciseprefixcache
Package preciseprefixcache provides a precise prefix cache scorer plugin for the epp.
|
Package preciseprefixcache provides a precise prefix cache scorer plugin for the epp. |
|
scorer/sessionaffinity
Package sessionaffinity provides a session affinity scorer plugin for the epp.
|
Package sessionaffinity provides a session affinity scorer plugin for the epp. |
|
util/sessionaffinity
Package sessionaffinity provides the session header helpers shared by the session-affinity scorer and filter plugins.
|
Package sessionaffinity provides the session header helpers shared by the session-affinity scorer and filter plugins. |
Click to show internal directories.
Click to hide internal directories.