We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a73776c commit de03eb3Copy full SHA for de03eb3
pkg/epp/handlers/streamingserver.go
@@ -90,6 +90,7 @@ func (s *StreamingServer) Process(srv extProcPb.ExternalProcessor_ProcessServer)
90
91
switch v := req.Request.(type) {
92
case *extProcPb.ProcessingRequest_RequestHeaders:
93
+ reqCtx.RequestReceivedTimestamp = time.Now()
94
// Do nothing. Header info is handled in the HandleRequestBody func
95
case *extProcPb.ProcessingRequest_RequestBody:
96
loggerVerbose.Info("Incoming body chunk", "body", string(v.RequestBody.Body), "EoS", v.RequestBody.EndOfStream)
0 commit comments