etcd-io/etcd

42    metadata runtime.ServerMetadata
43)
44if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
45    return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
46}
47if req.Body != nil {
48    _, _ = io.Copy(io.Discard, req.Body)
49}
50msg, err := client.Range(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))

69    metadata runtime.ServerMetadata
70)
71if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && !errors.Is(err, io.EOF) {
72    return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
73}
74if req.Body != nil {
75    _, _ = io.Copy(io.Discard, req.Body)
76}
77msg, err := client.Put(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))

1261mux.Handle(http.MethodPost, pattern_KV_Range_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1262    ctx, cancel := context.WithCancel(req.Context())
1263    defer cancel()
1264    var stream runtime.ServerTransportStream
1265    ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
1266    inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1267    annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/etcdserverpb.KV/Range", runtime.WithHTTPPathPattern("/v3/kv/range"))

1281mux.Handle(http.MethodPost, pattern_KV_Put_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
1282    ctx, cancel := context.WithCancel(req.Context())
1283    defer cancel()
1284    var stream runtime.ServerTransportStream
1285    ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
1286    inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
1287    annotatedContext, err := runtime.AnnotateIncomingContext(ctx, mux, req, "/etcdserverpb.KV/Put", runtime.WithHTTPPathPattern("/v3/kv/put"))