Skip to content

Commit d07d9b2

Browse files
zetxqxzetxqx
committed
import igw@c5a0052
Signed-off-by: bobzetian <bobzetian@google.com>
1 parent 92d7253 commit d07d9b2

File tree

8 files changed

+153
-109
lines changed

8 files changed

+153
-109
lines changed

‎go.mod‎

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,13 @@ require (
1616
github.com/spf13/pflag v1.0.10
1717
github.com/stretchr/testify v1.11.1
1818
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.67.0
19-
go.opentelemetry.io/otel v1.42.0
20-
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.42.0
21-
go.opentelemetry.io/otel/sdk v1.42.0
22-
go.opentelemetry.io/otel/trace v1.42.0
19+
go.opentelemetry.io/otel v1.43.0
20+
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0
21+
go.opentelemetry.io/otel/sdk v1.43.0
22+
go.opentelemetry.io/otel/trace v1.43.0
2323
go.uber.org/zap v1.27.1
2424
golang.org/x/sync v0.20.0
25-
google.golang.org/grpc v1.79.3
25+
google.golang.org/grpc v1.80.0
2626
k8s.io/api v0.35.3
2727
k8s.io/apiextensions-apiserver v0.35.3
2828
k8s.io/apimachinery v0.35.3
@@ -31,7 +31,7 @@ require (
3131
k8s.io/utils v0.0.0-20260108192941-914a6e750570
3232
sigs.k8s.io/controller-runtime v0.23.3
3333
sigs.k8s.io/gateway-api v1.5.1
34-
sigs.k8s.io/gateway-api-inference-extension v1.4.0
34+
sigs.k8s.io/gateway-api-inference-extension v0.0.0-20260324083816-c5a0052e14a4
3535
)
3636

3737
require (
@@ -95,7 +95,7 @@ require (
9595
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
9696
github.com/prometheus/client_model v0.6.2 // indirect
9797
github.com/prometheus/common v0.67.5 // indirect
98-
github.com/prometheus/procfs v0.17.0 // indirect
98+
github.com/prometheus/procfs v0.19.2 // indirect
9999
github.com/prometheus/prometheus v0.310.0 // indirect
100100
github.com/redis/go-redis/v9 v9.11.0 // indirect
101101
github.com/spf13/cobra v1.10.2 // indirect
@@ -109,26 +109,26 @@ require (
109109
github.com/x448/float16 v0.8.4 // indirect
110110
github.com/xlab/treeprint v1.2.0 // indirect
111111
go.opentelemetry.io/auto/sdk v1.2.1 // indirect
112-
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.42.0 // indirect
112+
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0 // indirect
113113
go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.42.0 // indirect
114-
go.opentelemetry.io/otel/metric v1.42.0 // indirect
115-
go.opentelemetry.io/proto/otlp v1.9.0 // indirect
114+
go.opentelemetry.io/otel/metric v1.43.0 // indirect
115+
go.opentelemetry.io/proto/otlp v1.10.0 // indirect
116116
go.uber.org/atomic v1.11.0 // indirect
117117
go.uber.org/multierr v1.11.0 // indirect
118118
go.yaml.in/yaml/v2 v2.4.3 // indirect
119119
go.yaml.in/yaml/v3 v3.0.4 // indirect
120120
golang.org/x/exp v0.0.0-20260112195511-716be5621a96 // indirect
121-
golang.org/x/mod v0.32.0 // indirect
122-
golang.org/x/net v0.51.0 // indirect
121+
golang.org/x/mod v0.33.0 // indirect
122+
golang.org/x/net v0.52.0 // indirect
123123
golang.org/x/oauth2 v0.35.0 // indirect
124-
golang.org/x/sys v0.41.0 // indirect
125-
golang.org/x/term v0.40.0 // indirect
126-
golang.org/x/text v0.34.0 // indirect
127-
golang.org/x/time v0.14.0 // indirect
128-
golang.org/x/tools v0.41.0 // indirect
124+
golang.org/x/sys v0.42.0 // indirect
125+
golang.org/x/term v0.41.0 // indirect
126+
golang.org/x/text v0.35.0 // indirect
127+
golang.org/x/time v0.15.0 // indirect
128+
golang.org/x/tools v0.42.0 // indirect
129129
gomodules.xyz/jsonpatch/v2 v2.4.0 // indirect
130-
google.golang.org/genproto/googleapis/api v0.0.0-20260209200024-4cfbd4190f57 // indirect
131-
google.golang.org/genproto/googleapis/rpc v0.0.0-20260209200024-4cfbd4190f57 // indirect
130+
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 // indirect
131+
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 // indirect
132132
google.golang.org/protobuf v1.36.11 // indirect
133133
gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect
134134
gopkg.in/inf.v0 v0.9.1 // indirect

‎go.sum‎

Lines changed: 46 additions & 48 deletions
Original file line numberDiff line numberDiff line change
@@ -209,10 +209,6 @@ github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
209209
github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
210210
github.com/kylelemons/godebug v1.1.0 h1:RPNrshWIDI6G2gRW9EHilWtl7Z6Sb1BR0xunSBf0SNc=
211211
github.com/kylelemons/godebug v1.1.0/go.mod h1:9/0rRGxNHcop5bhtWyNeEfOS8JIWk580+fNqagV/RAw=
212-
github.com/llm-d/llm-d-kv-cache v0.7.0 h1:K2EVGvmAkvjv6UgsX3cY7uKSBzmd+IBfvVKvz81wj14=
213-
github.com/llm-d/llm-d-kv-cache v0.7.0/go.mod h1:3gTTm6+Vpevnh8TvtxoIerCaVBQiBB5CvbuXk31Pohg=
214-
github.com/llm-d/llm-d-kv-cache v0.7.1-0.20260402165240-96fdbab4abf4 h1:a3Q6Z6rZaH7r2E0Ix2tMkv8C6NdrpAjoAbMNyjucY3k=
215-
github.com/llm-d/llm-d-kv-cache v0.7.1-0.20260402165240-96fdbab4abf4/go.mod h1:3gTTm6+Vpevnh8TvtxoIerCaVBQiBB5CvbuXk31Pohg=
216212
github.com/llm-d/llm-d-kv-cache v0.7.1 h1:86bKidK10h5b39rGLuoJ0nXWoaNiXdjZdcK4FIUOVhw=
217213
github.com/llm-d/llm-d-kv-cache v0.7.1/go.mod h1:3gTTm6+Vpevnh8TvtxoIerCaVBQiBB5CvbuXk31Pohg=
218214
github.com/maruel/natural v1.1.1 h1:Hja7XhhmvEFhcByqDoHz9QZbkWey+COd9xWfCfn1ioo=
@@ -263,8 +259,8 @@ github.com/prometheus/common v0.67.5 h1:pIgK94WWlQt1WLwAC5j2ynLaBRDiinoAb86HZHTU
263259
github.com/prometheus/common v0.67.5/go.mod h1:SjE/0MzDEEAyrdr5Gqc6G+sXI67maCxzaT3A2+HqjUw=
264260
github.com/prometheus/otlptranslator v1.0.0 h1:s0LJW/iN9dkIH+EnhiD3BlkkP5QVIUVEoIwkU+A6qos=
265261
github.com/prometheus/otlptranslator v1.0.0/go.mod h1:vRYWnXvI6aWGpsdY/mOT/cbeVRBlPWtBNDb7kGR3uKM=
266-
github.com/prometheus/procfs v0.17.0 h1:FuLQ+05u4ZI+SS/w9+BWEM2TXiHKsUQ9TADiRH7DuK0=
267-
github.com/prometheus/procfs v0.17.0/go.mod h1:oPQLaDAMRbA+u8H5Pbfq+dl3VDAvHxMUOVhe0wYB2zw=
262+
github.com/prometheus/procfs v0.19.2 h1:zUMhqEW66Ex7OXIiDkll3tl9a1ZdilUOd/F6ZXw4Vws=
263+
github.com/prometheus/procfs v0.19.2/go.mod h1:M0aotyiemPhBCM0z5w87kL22CxfcH05ZpYlu+b4J7mw=
268264
github.com/prometheus/prometheus v0.310.0 h1:iS0Uul/dHjy8ifBnqo3YEOhRxlTOWantRoDWwmIowwA=
269265
github.com/prometheus/prometheus v0.310.0/go.mod h1:rs6XoWKvgAStqxHxb2Twh1BR6rp7qw7fmUgW+gaXjbw=
270266
github.com/prometheus/sigv4 v0.4.1 h1:EIc3j+8NBea9u1iV6O5ZAN8uvPq2xOIUPcqCTivHuXs=
@@ -319,24 +315,24 @@ go.opentelemetry.io/auto/sdk v1.2.1 h1:jXsnJ4Lmnqd11kwkBV2LgLoFMZKizbCi5fNZ/ipaZ
319315
go.opentelemetry.io/auto/sdk v1.2.1/go.mod h1:KRTj+aOaElaLi+wW1kO/DZRXwkF4C5xPbEe3ZiIhN7Y=
320316
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.67.0 h1:OyrsyzuttWTSur2qN/Lm0m2a8yqyIjUVBZcxFPuXq2o=
321317
go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.67.0/go.mod h1:C2NGBr+kAB4bk3xtMXfZ94gqFDtg/GkI7e9zqGh5Beg=
322-
go.opentelemetry.io/otel v1.42.0 h1:lSQGzTgVR3+sgJDAU/7/ZMjN9Z+vUip7leaqBKy4sho=
323-
go.opentelemetry.io/otel v1.42.0/go.mod h1:lJNsdRMxCUIWuMlVJWzecSMuNjE7dOYyWlqOXWkdqCc=
324-
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.42.0 h1:THuZiwpQZuHPul65w4WcwEnkX2QIuMT+UFoOrygtoJw=
325-
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.42.0/go.mod h1:J2pvYM5NGHofZ2/Ru6zw/TNWnEQp5crgyDeSrYpXkAw=
326-
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.42.0 h1:zWWrB1U6nqhS/k6zYB74CjRpuiitRtLLi68VcgmOEto=
327-
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.42.0/go.mod h1:2qXPNBX1OVRC0IwOnfo1ljoid+RD0QK3443EaqVlsOU=
318+
go.opentelemetry.io/otel v1.43.0 h1:mYIM03dnh5zfN7HautFE4ieIig9amkNANT+xcVxAj9I=
319+
go.opentelemetry.io/otel v1.43.0/go.mod h1:JuG+u74mvjvcm8vj8pI5XiHy1zDeoCS2LB1spIq7Ay0=
320+
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0 h1:88Y4s2C8oTui1LGM6bTWkw0ICGcOLCAI5l6zsD1j20k=
321+
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.43.0/go.mod h1:Vl1/iaggsuRlrHf/hfPJPvVag77kKyvrLeD10kpMl+A=
322+
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0 h1:RAE+JPfvEmvy+0LzyUA25/SGawPwIUbZ6u0Wug54sLc=
323+
go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracegrpc v1.43.0/go.mod h1:AGmbycVGEsRx9mXMZ75CsOyhSP6MFIcj/6dnG+vhVjk=
328324
go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.42.0 h1:s/1iRkCKDfhlh1JF26knRneorus8aOwVIDhvYx9WoDw=
329325
go.opentelemetry.io/otel/exporters/stdout/stdouttrace v1.42.0/go.mod h1:UI3wi0FXg1Pofb8ZBiBLhtMzgoTm1TYkMvn71fAqDzs=
330-
go.opentelemetry.io/otel/metric v1.42.0 h1:2jXG+3oZLNXEPfNmnpxKDeZsFI5o4J+nz6xUlaFdF/4=
331-
go.opentelemetry.io/otel/metric v1.42.0/go.mod h1:RlUN/7vTU7Ao/diDkEpQpnz3/92J9ko05BIwxYa2SSI=
332-
go.opentelemetry.io/otel/sdk v1.42.0 h1:LyC8+jqk6UJwdrI/8VydAq/hvkFKNHZVIWuslJXYsDo=
333-
go.opentelemetry.io/otel/sdk v1.42.0/go.mod h1:rGHCAxd9DAph0joO4W6OPwxjNTYWghRWmkHuGbayMts=
334-
go.opentelemetry.io/otel/sdk/metric v1.42.0 h1:D/1QR46Clz6ajyZ3G8SgNlTJKBdGp84q9RKCAZ3YGuA=
335-
go.opentelemetry.io/otel/sdk/metric v1.42.0/go.mod h1:Ua6AAlDKdZ7tdvaQKfSmnFTdHx37+J4ba8MwVCYM5hc=
336-
go.opentelemetry.io/otel/trace v1.42.0 h1:OUCgIPt+mzOnaUTpOQcBiM/PLQ/Op7oq6g4LenLmOYY=
337-
go.opentelemetry.io/otel/trace v1.42.0/go.mod h1:f3K9S+IFqnumBkKhRJMeaZeNk9epyhnCmQh/EysQCdc=
338-
go.opentelemetry.io/proto/otlp v1.9.0 h1:l706jCMITVouPOqEnii2fIAuO3IVGBRPV5ICjceRb/A=
339-
go.opentelemetry.io/proto/otlp v1.9.0/go.mod h1:xE+Cx5E/eEHw+ISFkwPLwCZefwVjY+pqKg1qcK03+/4=
326+
go.opentelemetry.io/otel/metric v1.43.0 h1:d7638QeInOnuwOONPp4JAOGfbCEpYb+K6DVWvdxGzgM=
327+
go.opentelemetry.io/otel/metric v1.43.0/go.mod h1:RDnPtIxvqlgO8GRW18W6Z/4P462ldprJtfxHxyKd2PY=
328+
go.opentelemetry.io/otel/sdk v1.43.0 h1:pi5mE86i5rTeLXqoF/hhiBtUNcrAGHLKQdhg4h4V9Dg=
329+
go.opentelemetry.io/otel/sdk v1.43.0/go.mod h1:P+IkVU3iWukmiit/Yf9AWvpyRDlUeBaRg6Y+C58QHzg=
330+
go.opentelemetry.io/otel/sdk/metric v1.43.0 h1:S88dyqXjJkuBNLeMcVPRFXpRw2fuwdvfCGLEo89fDkw=
331+
go.opentelemetry.io/otel/sdk/metric v1.43.0/go.mod h1:C/RJtwSEJ5hzTiUz5pXF1kILHStzb9zFlIEe85bhj6A=
332+
go.opentelemetry.io/otel/trace v1.43.0 h1:BkNrHpup+4k4w+ZZ86CZoHHEkohws8AY+WTX09nk+3A=
333+
go.opentelemetry.io/otel/trace v1.43.0/go.mod h1:/QJhyVBUUswCphDVxq+8mld+AvhXZLhe+8WVFxiFff0=
334+
go.opentelemetry.io/proto/otlp v1.10.0 h1:IQRWgT5srOCYfiWnpqUYz9CVmbO8bFmKcwYxpuCSL2g=
335+
go.opentelemetry.io/proto/otlp v1.10.0/go.mod h1:/CV4QoCR/S9yaPj8utp3lvQPoqMtxXdzn7ozvvozVqk=
340336
go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
341337
go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
342338
go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
@@ -349,40 +345,40 @@ go.yaml.in/yaml/v2 v2.4.3 h1:6gvOSjQoTB3vt1l+CU+tSyi/HOjfOjRLJ4YwYZGwRO0=
349345
go.yaml.in/yaml/v2 v2.4.3/go.mod h1:zSxWcmIDjOzPXpjlTTbAsKokqkDNAVtZO0WOMiT90s8=
350346
go.yaml.in/yaml/v3 v3.0.4 h1:tfq32ie2Jv2UxXFdLJdh3jXuOzWiL1fo0bu/FbuKpbc=
351347
go.yaml.in/yaml/v3 v3.0.4/go.mod h1:DhzuOOF2ATzADvBadXxruRBLzYTpT36CKvDb3+aBEFg=
352-
golang.org/x/crypto v0.48.0 h1:/VRzVqiRSggnhY7gNRxPauEQ5Drw9haKdM0jqfcCFts=
353-
golang.org/x/crypto v0.48.0/go.mod h1:r0kV5h3qnFPlQnBSrULhlsRfryS2pmewsg+XfMgkVos=
348+
golang.org/x/crypto v0.49.0 h1:+Ng2ULVvLHnJ/ZFEq4KdcDd/cfjrrjjNSXNzxg0Y4U4=
349+
golang.org/x/crypto v0.49.0/go.mod h1:ErX4dUh2UM+CFYiXZRTcMpEcN8b/1gxEuv3nODoYtCA=
354350
golang.org/x/exp v0.0.0-20260112195511-716be5621a96 h1:Z/6YuSHTLOHfNFdb8zVZomZr7cqNgTJvA8+Qz75D8gU=
355351
golang.org/x/exp v0.0.0-20260112195511-716be5621a96/go.mod h1:nzimsREAkjBCIEFtHiYkrJyT+2uy9YZJB7H1k68CXZU=
356-
golang.org/x/mod v0.32.0 h1:9F4d3PHLljb6x//jOyokMv3eX+YDeepZSEo3mFJy93c=
357-
golang.org/x/mod v0.32.0/go.mod h1:SgipZ/3h2Ci89DlEtEXWUk/HteuRin+HHhN+WbNhguU=
358-
golang.org/x/net v0.51.0 h1:94R/GTO7mt3/4wIKpcR5gkGmRLOuE/2hNGeWq/GBIFo=
359-
golang.org/x/net v0.51.0/go.mod h1:aamm+2QF5ogm02fjy5Bb7CQ0WMt1/WVM7FtyaTLlA9Y=
352+
golang.org/x/mod v0.33.0 h1:tHFzIWbBifEmbwtGz65eaWyGiGZatSrT9prnU8DbVL8=
353+
golang.org/x/mod v0.33.0/go.mod h1:swjeQEj+6r7fODbD2cqrnje9PnziFuw4bmLbBZFrQ5w=
354+
golang.org/x/net v0.52.0 h1:He/TN1l0e4mmR3QqHMT2Xab3Aj3L9qjbhRm78/6jrW0=
355+
golang.org/x/net v0.52.0/go.mod h1:R1MAz7uMZxVMualyPXb+VaqGSa3LIaUqk0eEt3w36Sw=
360356
golang.org/x/oauth2 v0.35.0 h1:Mv2mzuHuZuY2+bkyWXIHMfhNdJAdwW3FuWeCPYN5GVQ=
361357
golang.org/x/oauth2 v0.35.0/go.mod h1:lzm5WQJQwKZ3nwavOZ3IS5Aulzxi68dUSgRHujetwEA=
362358
golang.org/x/sync v0.20.0 h1:e0PTpb7pjO8GAtTs2dQ6jYa5BWYlMuX047Dco/pItO4=
363359
golang.org/x/sync v0.20.0/go.mod h1:9xrNwdLfx4jkKbNva9FpL6vEN7evnE43NNNJQ2LF3+0=
364-
golang.org/x/sys v0.41.0 h1:Ivj+2Cp/ylzLiEU89QhWblYnOE9zerudt9Ftecq2C6k=
365-
golang.org/x/sys v0.41.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
366-
golang.org/x/term v0.40.0 h1:36e4zGLqU4yhjlmxEaagx2KuYbJq3EwY8K943ZsHcvg=
367-
golang.org/x/term v0.40.0/go.mod h1:w2P8uVp06p2iyKKuvXIm7N/y0UCRt3UfJTfZ7oOpglM=
368-
golang.org/x/text v0.34.0 h1:oL/Qq0Kdaqxa1KbNeMKwQq0reLCCaFtqu2eNuSeNHbk=
369-
golang.org/x/text v0.34.0/go.mod h1:homfLqTYRFyVYemLBFl5GgL/DWEiH5wcsQ5gSh1yziA=
370-
golang.org/x/time v0.14.0 h1:MRx4UaLrDotUKUdCIqzPC48t1Y9hANFKIRpNx+Te8PI=
371-
golang.org/x/time v0.14.0/go.mod h1:eL/Oa2bBBK0TkX57Fyni+NgnyQQN4LitPmob2Hjnqw4=
372-
golang.org/x/tools v0.41.0 h1:a9b8iMweWG+S0OBnlU36rzLp20z1Rp10w+IY2czHTQc=
373-
golang.org/x/tools v0.41.0/go.mod h1:XSY6eDqxVNiYgezAVqqCeihT4j1U2CCsqvH3WhQpnlg=
360+
golang.org/x/sys v0.42.0 h1:omrd2nAlyT5ESRdCLYdm3+fMfNFE/+Rf4bDIQImRJeo=
361+
golang.org/x/sys v0.42.0/go.mod h1:4GL1E5IUh+htKOUEOaiffhrAeqysfVGipDYzABqnCmw=
362+
golang.org/x/term v0.41.0 h1:QCgPso/Q3RTJx2Th4bDLqML4W6iJiaXFq2/ftQF13YU=
363+
golang.org/x/term v0.41.0/go.mod h1:3pfBgksrReYfZ5lvYM0kSO0LIkAl4Yl2bXOkKP7Ec2A=
364+
golang.org/x/text v0.35.0 h1:JOVx6vVDFokkpaq1AEptVzLTpDe9KGpj5tR4/X+ybL8=
365+
golang.org/x/text v0.35.0/go.mod h1:khi/HExzZJ2pGnjenulevKNX1W67CUy0AsXcNubPGCA=
366+
golang.org/x/time v0.15.0 h1:bbrp8t3bGUeFOx08pvsMYRTCVSMk89u4tKbNOZbp88U=
367+
golang.org/x/time v0.15.0/go.mod h1:Y4YMaQmXwGQZoFaVFk4YpCt4FLQMYKZe9oeV/f4MSno=
368+
golang.org/x/tools v0.42.0 h1:uNgphsn75Tdz5Ji2q36v/nsFSfR/9BRFvqhGBaJGd5k=
369+
golang.org/x/tools v0.42.0/go.mod h1:Ma6lCIwGZvHK6XtgbswSoWroEkhugApmsXyrUmBhfr0=
374370
gomodules.xyz/jsonpatch/v2 v2.4.0 h1:Ci3iUJyx9UeRx7CeFN8ARgGbkESwJK+KB9lLcWxY/Zw=
375371
gomodules.xyz/jsonpatch/v2 v2.4.0/go.mod h1:AH3dM2RI6uoBZxn3LVrfvJ3E0/9dG4cSrbuBJT4moAY=
376-
gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk=
377-
gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E=
372+
gonum.org/v1/gonum v0.17.0 h1:VbpOemQlsSMrYmn7T2OUvQ4dqxQXU+ouZFQsZOx50z4=
373+
gonum.org/v1/gonum v0.17.0/go.mod h1:El3tOrEuMpv2UdMrbNlKEh9vd86bmQ6vqIcDwxEOc1E=
378374
google.golang.org/api v0.265.0 h1:FZvfUdI8nfmuNrE34aOWFPmLC+qRBEiNm3JdivTvAAU=
379375
google.golang.org/api v0.265.0/go.mod h1:uAvfEl3SLUj/7n6k+lJutcswVojHPp2Sp08jWCu8hLY=
380-
google.golang.org/genproto/googleapis/api v0.0.0-20260209200024-4cfbd4190f57 h1:JLQynH/LBHfCTSbDWl+py8C+Rg/k1OVH3xfcaiANuF0=
381-
google.golang.org/genproto/googleapis/api v0.0.0-20260209200024-4cfbd4190f57/go.mod h1:kSJwQxqmFXeo79zOmbrALdflXQeAYcUbgS7PbpMknCY=
382-
google.golang.org/genproto/googleapis/rpc v0.0.0-20260209200024-4cfbd4190f57 h1:mWPCjDEyshlQYzBpMNHaEof6UX1PmHcaUODUywQ0uac=
383-
google.golang.org/genproto/googleapis/rpc v0.0.0-20260209200024-4cfbd4190f57/go.mod h1:j9x/tPzZkyxcgEFkiKEEGxfvyumM01BEtsW8xzOahRQ=
384-
google.golang.org/grpc v1.79.3 h1:sybAEdRIEtvcD68Gx7dmnwjZKlyfuc61Dyo9pGXXkKE=
385-
google.golang.org/grpc v1.79.3/go.mod h1:KmT0Kjez+0dde/v2j9vzwoAScgEPx/Bw1CYChhHLrHQ=
376+
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9 h1:VPWxll4HlMw1Vs/qXtN7BvhZqsS9cdAittCNvVENElA=
377+
google.golang.org/genproto/googleapis/api v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:7QBABkRtR8z+TEnmXTqIqwJLlzrZKVfAUm7tY3yGv0M=
378+
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9 h1:m8qni9SQFH0tJc1X0vmnpw/0t+AImlSvp30sEupozUg=
379+
google.golang.org/genproto/googleapis/rpc v0.0.0-20260401024825-9d38bb4040a9/go.mod h1:4Hqkh8ycfw05ld/3BWL7rJOSfebL2Q+DVDeRgYgxUU8=
380+
google.golang.org/grpc v1.80.0 h1:Xr6m2WmWZLETvUNvIUmeD5OAagMw3FiKmMlTdViWsHM=
381+
google.golang.org/grpc v1.80.0/go.mod h1:ho/dLnxwi3EDJA4Zghp7k2Ec1+c2jqup0bFkw07bwF4=
386382
google.golang.org/protobuf v1.36.11 h1:fV6ZwhNocDyBLK0dj+fg8ektcVegBBuEolpbTQyBNVE=
387383
google.golang.org/protobuf v1.36.11/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco=
388384
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
@@ -419,8 +415,10 @@ sigs.k8s.io/controller-runtime v0.23.3 h1:VjB/vhoPoA9l1kEKZHBMnQF33tdCLQKJtydy4i
419415
sigs.k8s.io/controller-runtime v0.23.3/go.mod h1:B6COOxKptp+YaUT5q4l6LqUJTRpizbgf9KSRNdQGns0=
420416
sigs.k8s.io/gateway-api v1.5.1 h1:RqVRIlkhLhUO8wOHKTLnTJA6o/1un4po4/6M1nRzdd0=
421417
sigs.k8s.io/gateway-api v1.5.1/go.mod h1:GvCETiaMAlLym5CovLxGjS0NysqFk3+Yuq3/rh6QL2o=
422-
sigs.k8s.io/gateway-api-inference-extension v1.4.0 h1:V+5u0J64qDbLYx4M/PkpsGa5bjeRjWUVybQ00axEkE0=
423-
sigs.k8s.io/gateway-api-inference-extension v1.4.0/go.mod h1:Z9MZpf6wdjn9iCT5Xu6Ugqh88zSa0zuDra0VqJXT7eM=
418+
sigs.k8s.io/gateway-api-inference-extension v0.0.0-20260324083816-c5a0052e14a4 h1:2AQPAuxKvnOJ17sGfR2MqljMtgPj8nIhBo5j42Mys7k=
419+
sigs.k8s.io/gateway-api-inference-extension v0.0.0-20260324083816-c5a0052e14a4/go.mod h1:YlphzyBistlqQxXY2T5TwAL4BVS4uAYvYnH5Mh4QKEg=
420+
sigs.k8s.io/gateway-api-inference-extension v1.5.0-rc.1 h1:NTLjtrLlQrZDxn0xZBGKCvWeP3HhdFfcFHQi8dg+L/s=
421+
sigs.k8s.io/gateway-api-inference-extension v1.5.0-rc.1/go.mod h1:ZeIlzI43XH2qWKipFq/Qa12yB2s/D+Xp1XJVlpMxklA=
424422
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 h1:IpInykpT6ceI+QxKBbEflcR5EXP7sU1kvOlxwZh5txg=
425423
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730/go.mod h1:mdzfpAEoE6DHQEN0uh9ZbOCuHbLK5wOm7dK4ctXE9Tg=
426424
sigs.k8s.io/kustomize/api v0.21.1 h1:lzqbzvz2CSvsjIUZUBNFKtIMsEw7hVLJp0JeSIVmuJs=

‎pkg/plugins/datalayer/models/datasource_test.go‎

Lines changed: 17 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import (
66
"testing"
77
"time"
88

9+
"github.com/go-logr/logr"
910
"github.com/stretchr/testify/assert"
1011
"k8s.io/apimachinery/pkg/types"
1112
"sigs.k8s.io/gateway-api-inference-extension/pkg/epp/datalayer"
@@ -20,31 +21,34 @@ func TestDatasource(t *testing.T) {
2021
extractor, err := NewModelExtractor()
2122
assert.Nil(t, err, "failed to create extractor")
2223

23-
err = source.AddExtractor(extractor)
24-
assert.Nil(t, err, "failed to add extractor")
25-
26-
err = source.AddExtractor(extractor)
27-
assert.NotNil(t, err, "expected to fail to add the same extractor twice")
24+
cfg := &datalayer.Config{
25+
Sources: []datalayer.DataSourceConfig{
26+
{
27+
Plugin: source,
28+
Extractors: []fwkdl.Extractor{extractor},
29+
},
30+
},
31+
}
2832

29-
extractors := source.Extractors()
30-
assert.Len(t, extractors, 1)
31-
assert.Equal(t, extractor.TypedName().String(), extractors[0])
33+
pollingInterval := 50 * time.Millisecond
34+
runtime := datalayer.NewRuntime(pollingInterval)
3235

33-
err = datalayer.RegisterSource(source)
34-
assert.Nil(t, err, "failed to register")
36+
err = runtime.Configure(cfg, true, "", logr.Logger{})
37+
assert.Nil(t, err, "failed to configure runtime")
3538

3639
ctx := context.Background()
37-
factory := datalayer.NewEndpointFactory([]fwkdl.DataSource{source}, 100*time.Hour)
3840
pod := &fwkdl.EndpointMetadata{
3941
NamespacedName: types.NamespacedName{
4042
Name: "pod1",
4143
Namespace: "default",
4244
},
4345
Address: "1.2.3.4:5678",
4446
}
45-
endpoint := factory.NewEndpoint(ctx, pod, nil)
47+
48+
endpoint := runtime.NewEndpoint(ctx, pod, nil)
4649
assert.NotNil(t, endpoint, "failed to create endpoint")
4750

48-
err = source.Poll(ctx, endpoint)
51+
data, err := source.Poll(ctx, endpoint)
4952
assert.NotNil(t, err, "expected to fail to collect metrics")
53+
assert.Nil(t, data)
5054
}

‎pkg/plugins/scorer/active_request.go‎

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func (s endpointScores) MarshalLog() interface{} {
7676
// compile-time type assertion
7777
var _ scheduling.Scorer = &ActiveRequest{}
7878
var _ requestcontrol.PreRequest = &ActiveRequest{}
79-
var _ requestcontrol.ResponseComplete = &ActiveRequest{}
79+
var _ requestcontrol.ResponseBody = &ActiveRequest{}
8080

8181
// ActiveRequestFactory defines the factory function for the ActiveRequest scorer.
8282
func ActiveRequestFactory(name string, rawParameters json.RawMessage, handle plugin.Handle) (plugin.Plugin, error) {
@@ -260,18 +260,22 @@ func (s *ActiveRequest) PreRequest(
260260
s.requestCache.Set(request.RequestId, &requestEntry{PodNames: endpointNames, RequestID: request.RequestId}, 0) // Use default TTL
261261
}
262262

263-
// ResponseComplete is called after a response is sent to the client.
263+
// ResponseBody is called after a response is sent to the client.
264264
// It removes the specific request entry from the cache and decrements
265265
// the endpoint count.
266-
func (s *ActiveRequest) ResponseComplete(
266+
func (s *ActiveRequest) ResponseBody(
267267
ctx context.Context,
268268
request *scheduling.LLMRequest,
269-
_ *requestcontrol.Response,
269+
resp *requestcontrol.Response,
270270
targetPod *datalayer.EndpointMetadata,
271271
) {
272-
debugLogger := log.FromContext(ctx).V(logutil.DEBUG).WithName("ActiveRequest.ResponseComplete")
272+
debugLogger := log.FromContext(ctx).V(logutil.DEBUG).WithName("ActiveRequest.ResponseBody")
273+
if !resp.EndOfStream {
274+
debugLogger.Info("Skipping ResponseBody because EndOfStream is false")
275+
return
276+
}
273277
if targetPod == nil {
274-
debugLogger.Info("Skipping ResponseComplete because targetPod is nil")
278+
debugLogger.Info("Skipping ResponseBody because targetPod is nil")
275279
return
276280
}
277281

0 commit comments

Comments
 (0)