go-grpc-middleware/retry/retry.go

43 			callCtx := perCallContext(parentCtx, callOpts, attempt)
44 			lastErr = invoker(callCtx, method, req, reply, cc, grpcOpts...)
96 			callCtx := perCallContext(parentCtx, callOpts, 0)
99 			newStreamer, lastErr = streamer(callCtx, desc, cc, method, grpcOpts...)
191 		callCtx := perCallContext(s.parentCtx, s.callOpts, attempt)
192 		newStream, err := s.reestablishStreamAndResendBuffer(callCtx)
235 func (s *serverStreamingRetryingStream) reestablishStreamAndResendBuffer(callCtx context.Context) (…
239 	newStream, err := s.streamerCall(callCtx)
241 		logTrace(callCtx, "grpc_retry failed redialing new stream: %v", err)
246 			logTrace(callCtx, "grpc_retry failed resending message: %v", err)
251 		logTrace(callCtx, "grpc_retry failed CloseSend on new stream %v", err)