framework/

directory
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 23, 2026 License: Apache-2.0

Directories

Path Synopsis
common
interface
flowcontrol
Package flowcontrol defines the core plugin interfaces for extending the Flow Control layer.
Package flowcontrol defines the core plugin interfaces for extending the Flow Control layer.
plugins
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.
datalayer/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.
datalayer/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.
flowcontrol/fairness
Package fairness provides the standard implementations of the FairnessPolicy interface.
Package fairness provides the standard implementations of the FairnessPolicy interface.
flowcontrol/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.
flowcontrol/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.
flowcontrol/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.
flowcontrol/ordering
Package ordering provides the standard implementations of the OrderingPolicy interface.
Package ordering provides the standard implementations of the OrderingPolicy interface.
flowcontrol/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).
flowcontrol/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).
flowcontrol/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.
requestcontrol
Package requestcontrol holds definitions shared by all requestcontrol framework plugins.
Package requestcontrol holds definitions shared by all requestcontrol framework plugins.
requestcontrol/admitter/probabilisticadmitter
Package probabilisticadmitter implements a binary-tier probabilistic admission control plugin.
Package probabilisticadmitter implements a binary-tier probabilistic admission control plugin.
requestcontrol/dataproducer/multimodal
Package multimodal provides a data producer for multimodal encoder-cache affinity.
Package multimodal provides a data producer for multimodal encoder-cache affinity.
requestcontrol/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.
requestcontrol/dataproducer/predictedlatency
Package requestcontrol contains helpers to decouple latency-predictor logic.
Package requestcontrol contains helpers to decouple latency-predictor logic.
requestcontrol/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.
requestcontrol/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).
requestcontrol/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.
scheduling
Package scheduling holds definitions shared by all scheduling framework plugins.
Package scheduling holds definitions shared by all scheduling framework plugins.
scheduling/filter/bylabel
Package bylabel provides filter plugins for the epp.
Package bylabel provides filter plugins for the epp.
scheduling/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).
scheduling/filter/sessionaffinity
Package sessionaffinity provides a session affinity filter plugin for the epp.
Package sessionaffinity provides a session affinity filter plugin for the epp.
scheduling/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).
scheduling/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.
scheduling/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.
scheduling/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.
scheduling/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.
scheduling/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.
scheduling/profilehandler/disagg
Package disagg provides profile handler plugins for the epp.
Package disagg provides profile handler plugins for the epp.
scheduling/scorer/activerequest
Package activerequest provides an active request scorer plugin for the epp.
Package activerequest provides an active request scorer plugin for the epp.
scheduling/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).
scheduling/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.
scheduling/scorer/loadaware
Package loadaware provides a load-aware scorer plugin for the epp.
Package loadaware provides a load-aware scorer plugin for the epp.
scheduling/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.
scheduling/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.
scheduling/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.
scheduling/scorer/sessionaffinity
Package sessionaffinity provides a session affinity scorer plugin for the epp.
Package sessionaffinity provides a session affinity scorer plugin for the epp.
scheduling/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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL