| // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT. |
| // source: etcdserver/api/v3lock/v3lockpb/v3lock.proto |
| |
| /* |
| Package v3lockpb is a reverse proxy. |
| |
| It translates gRPC into RESTful JSON APIs. |
| */ |
| package gw |
| |
| import ( |
| "go.etcd.io/etcd/etcdserver/api/v3lock/v3lockpb" |
| "io" |
| "net/http" |
| |
| "github.com/golang/protobuf/proto" |
| "github.com/grpc-ecosystem/grpc-gateway/runtime" |
| "github.com/grpc-ecosystem/grpc-gateway/utilities" |
| "golang.org/x/net/context" |
| "google.golang.org/grpc" |
| "google.golang.org/grpc/codes" |
| "google.golang.org/grpc/grpclog" |
| "google.golang.org/grpc/status" |
| ) |
| |
| var _ codes.Code |
| var _ io.Reader |
| var _ status.Status |
| var _ = runtime.String |
| var _ = utilities.NewDoubleArray |
| |
| func request_Lock_Lock_0(ctx context.Context, marshaler runtime.Marshaler, client v3lockpb.LockClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3lockpb.LockRequest |
| var metadata runtime.ServerMetadata |
| |
| if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { |
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) |
| } |
| |
| msg, err := client.Lock(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| func request_Lock_Unlock_0(ctx context.Context, marshaler runtime.Marshaler, client v3lockpb.LockClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3lockpb.UnlockRequest |
| var metadata runtime.ServerMetadata |
| |
| if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { |
| return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) |
| } |
| |
| msg, err := client.Unlock(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| // RegisterLockHandlerFromEndpoint is same as RegisterLockHandler but |
| // automatically dials to "endpoint" and closes the connection when "ctx" gets done. |
| func RegisterLockHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) { |
| conn, err := grpc.Dial(endpoint, opts...) |
| if err != nil { |
| return err |
| } |
| defer func() { |
| if err != nil { |
| if cerr := conn.Close(); cerr != nil { |
| grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) |
| } |
| return |
| } |
| go func() { |
| <-ctx.Done() |
| if cerr := conn.Close(); cerr != nil { |
| grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) |
| } |
| }() |
| }() |
| |
| return RegisterLockHandler(ctx, mux, conn) |
| } |
| |
| // RegisterLockHandler registers the http handlers for service Lock to "mux". |
| // The handlers forward requests to the grpc endpoint over "conn". |
| func RegisterLockHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error { |
| return RegisterLockHandlerClient(ctx, mux, v3lockpb.NewLockClient(conn)) |
| } |
| |
| // RegisterLockHandler registers the http handlers for service Lock to "mux". |
| // The handlers forward requests to the grpc endpoint over the given implementation of "LockClient". |
| // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "LockClient" |
| // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in |
| // "LockClient" to call the correct interceptors. |
| func RegisterLockHandlerClient(ctx context.Context, mux *runtime.ServeMux, client v3lockpb.LockClient) error { |
| |
| mux.Handle("POST", pattern_Lock_Lock_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { |
| ctx, cancel := context.WithCancel(req.Context()) |
| defer cancel() |
| if cn, ok := w.(http.CloseNotifier); ok { |
| go func(done <-chan struct{}, closed <-chan bool) { |
| select { |
| case <-done: |
| case <-closed: |
| cancel() |
| } |
| }(ctx.Done(), cn.CloseNotify()) |
| } |
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) |
| rctx, err := runtime.AnnotateContext(ctx, mux, req) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| resp, md, err := request_Lock_Lock_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Lock_Lock_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| mux.Handle("POST", pattern_Lock_Unlock_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { |
| ctx, cancel := context.WithCancel(req.Context()) |
| defer cancel() |
| if cn, ok := w.(http.CloseNotifier); ok { |
| go func(done <-chan struct{}, closed <-chan bool) { |
| select { |
| case <-done: |
| case <-closed: |
| cancel() |
| } |
| }(ctx.Done(), cn.CloseNotify()) |
| } |
| inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) |
| rctx, err := runtime.AnnotateContext(ctx, mux, req) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| resp, md, err := request_Lock_Unlock_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Lock_Unlock_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| return nil |
| } |
| |
| var ( |
| pattern_Lock_Lock_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 1}, []string{"v3", "lock"}, "")) |
| |
| pattern_Lock_Unlock_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "lock", "unlock"}, "")) |
| ) |
| |
| var ( |
| forward_Lock_Lock_0 = runtime.ForwardResponseMessage |
| |
| forward_Lock_Unlock_0 = runtime.ForwardResponseMessage |
| ) |