1 // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
2 // source: opencensus/proto/agent/trace/v1/trace_service.proto
5 Package v1 is a reverse proxy.
7 It translates gRPC into RESTful JSON APIs.
15 "github.com/golang/protobuf/proto"
16 "github.com/grpc-ecosystem/grpc-gateway/runtime"
17 "github.com/grpc-ecosystem/grpc-gateway/utilities"
18 "golang.org/x/net/context"
19 "google.golang.org/grpc"
20 "google.golang.org/grpc/codes"
21 "google.golang.org/grpc/grpclog"
22 "google.golang.org/grpc/status"
28 var _ = runtime.String
29 var _ = utilities.NewDoubleArray
31 func request_TraceService_Export_0(ctx context.Context, marshaler runtime.Marshaler, client TraceServiceClient, req *http.Request, pathParams map[string]string) (TraceService_ExportClient, runtime.ServerMetadata, error) {
32 var metadata runtime.ServerMetadata
33 stream, err := client.Export(ctx)
35 grpclog.Infof("Failed to start streaming: %v", err)
36 return nil, metadata, err
38 newReader, berr := utilities.IOReaderFactory(req.Body)
40 return nil, metadata, berr
42 dec := marshaler.NewDecoder(newReader())
43 handleSend := func() error {
44 var protoReq ExportTraceServiceRequest
45 err := dec.Decode(&protoReq)
50 grpclog.Infof("Failed to decode request: %v", err)
53 if err := stream.Send(&protoReq); err != nil {
54 grpclog.Infof("Failed to send request: %v", err)
59 if err := handleSend(); err != nil {
60 if cerr := stream.CloseSend(); cerr != nil {
61 grpclog.Infof("Failed to terminate client stream: %v", cerr)
64 return stream, metadata, nil
66 return nil, metadata, err
70 if err := handleSend(); err != nil {
74 if err := stream.CloseSend(); err != nil {
75 grpclog.Infof("Failed to terminate client stream: %v", err)
78 header, err := stream.Header()
80 grpclog.Infof("Failed to get header from client: %v", err)
81 return nil, metadata, err
83 metadata.HeaderMD = header
84 return stream, metadata, nil
87 // RegisterTraceServiceHandlerFromEndpoint is same as RegisterTraceServiceHandler but
88 // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
89 func RegisterTraceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
90 conn, err := grpc.Dial(endpoint, opts...)
96 if cerr := conn.Close(); cerr != nil {
97 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
103 if cerr := conn.Close(); cerr != nil {
104 grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
109 return RegisterTraceServiceHandler(ctx, mux, conn)
112 // RegisterTraceServiceHandler registers the http handlers for service TraceService to "mux".
113 // The handlers forward requests to the grpc endpoint over "conn".
114 func RegisterTraceServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
115 return RegisterTraceServiceHandlerClient(ctx, mux, NewTraceServiceClient(conn))
118 // RegisterTraceServiceHandlerClient registers the http handlers for service TraceService
119 // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "TraceServiceClient".
120 // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "TraceServiceClient"
121 // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
122 // "TraceServiceClient" to call the correct interceptors.
123 func RegisterTraceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client TraceServiceClient) error {
125 mux.Handle("POST", pattern_TraceService_Export_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
126 ctx, cancel := context.WithCancel(req.Context())
128 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
129 rctx, err := runtime.AnnotateContext(ctx, mux, req)
131 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
134 resp, md, err := request_TraceService_Export_0(rctx, inboundMarshaler, client, req, pathParams)
135 ctx = runtime.NewServerMetadataContext(ctx, md)
137 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
141 forward_TraceService_Export_0(ctx, mux, outboundMarshaler, w, req, func() (proto.Message, error) { return resp.Recv() }, mux.GetForwardResponseOptions()...)
149 pattern_TraceService_Export_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1}, []string{"v1", "trace"}, ""))
153 forward_TraceService_Export_0 = runtime.ForwardResponseStream