File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -12,6 +12,9 @@ function envoy_on_request(request_handle)
12
12
local msg = body :sub (6 )
13
13
14
14
-- protobuf wire format for field 1, wire type 2: tag = 0x0A
15
+ -- field 1 is the model name - we know it from here:
16
+ -- https://github.com/kserve/open-inference-protocol/blob/main/specification/protocol/inference_grpc.md#inference
17
+ -- wire type 2 means that the field is length-delimited
15
18
if msg :byte (1 ) == 0x0A then
16
19
-- next byte is a varint length (assumes <128 bytes)
17
20
local name_len = msg :byte (2 )
@@ -23,11 +26,12 @@ function envoy_on_request(request_handle)
23
26
if model_name then
24
27
local hostHeader = model_name .. " .NAMESPACE.svc.cluster.local:8001"
25
28
request_handle :logInfo (" route-to = " .. hostHeader )
29
+ -- add header
26
30
request_handle :headers ():add (" route-to" , hostHeader )
27
31
end
28
- for k , v in pairs (request_handle :headers ()) do
29
- request_handle :logInfo (" Header " .. k .. " : " .. v )
30
- end
32
+ -- for k, v in pairs(request_handle:headers()) do
33
+ -- request_handle:logInfo("Header " .. k .. ": " .. v)
34
+ -- end
31
35
else
32
36
request_handle :logErr (" Unexpected protobuf tag: " .. string.format (" 0x%02X" , msg :byte (1 )))
33
37
end
You can’t perform that action at this time.
0 commit comments