| // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT. |
| // source: etcdserver/api/v3election/v3electionpb/v3election.proto |
| |
| /* |
| Package v3electionpb is a reverse proxy. |
| |
| It translates gRPC into RESTful JSON APIs. |
| */ |
| package gw |
| |
| import ( |
| "go.etcd.io/etcd/etcdserver/api/v3election/v3electionpb" |
| "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_Election_Campaign_0(ctx context.Context, marshaler runtime.Marshaler, client v3electionpb.ElectionClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3electionpb.CampaignRequest |
| 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.Campaign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| func request_Election_Proclaim_0(ctx context.Context, marshaler runtime.Marshaler, client v3electionpb.ElectionClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3electionpb.ProclaimRequest |
| 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.Proclaim(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| func request_Election_Leader_0(ctx context.Context, marshaler runtime.Marshaler, client v3electionpb.ElectionClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3electionpb.LeaderRequest |
| 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.Leader(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| func request_Election_Observe_0(ctx context.Context, marshaler runtime.Marshaler, client v3electionpb.ElectionClient, req *http.Request, pathParams map[string]string) (v3electionpb.Election_ObserveClient, runtime.ServerMetadata, error) { |
| var protoReq v3electionpb.LeaderRequest |
| 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) |
| } |
| |
| stream, err := client.Observe(ctx, &protoReq) |
| if err != nil { |
| return nil, metadata, err |
| } |
| header, err := stream.Header() |
| if err != nil { |
| return nil, metadata, err |
| } |
| metadata.HeaderMD = header |
| return stream, metadata, nil |
| |
| } |
| |
| func request_Election_Resign_0(ctx context.Context, marshaler runtime.Marshaler, client v3electionpb.ElectionClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) { |
| var protoReq v3electionpb.ResignRequest |
| 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.Resign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) |
| return msg, metadata, err |
| |
| } |
| |
| // RegisterElectionHandlerFromEndpoint is same as RegisterElectionHandler but |
| // automatically dials to "endpoint" and closes the connection when "ctx" gets done. |
| func RegisterElectionHandlerFromEndpoint(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 RegisterElectionHandler(ctx, mux, conn) |
| } |
| |
| // RegisterElectionHandler registers the http handlers for service Election to "mux". |
| // The handlers forward requests to the grpc endpoint over "conn". |
| func RegisterElectionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error { |
| return RegisterElectionHandlerClient(ctx, mux, v3electionpb.NewElectionClient(conn)) |
| } |
| |
| // RegisterElectionHandler registers the http handlers for service Election to "mux". |
| // The handlers forward requests to the grpc endpoint over the given implementation of "ElectionClient". |
| // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ElectionClient" |
| // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in |
| // "ElectionClient" to call the correct interceptors. |
| func RegisterElectionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client v3electionpb.ElectionClient) error { |
| |
| mux.Handle("POST", pattern_Election_Campaign_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_Election_Campaign_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Election_Campaign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| mux.Handle("POST", pattern_Election_Proclaim_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_Election_Proclaim_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Election_Proclaim_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| mux.Handle("POST", pattern_Election_Leader_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_Election_Leader_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Election_Leader_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| mux.Handle("POST", pattern_Election_Observe_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_Election_Observe_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Election_Observe_0(ctx, mux, outboundMarshaler, w, req, func() (proto.Message, error) { return resp.Recv() }, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| mux.Handle("POST", pattern_Election_Resign_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_Election_Resign_0(rctx, inboundMarshaler, client, req, pathParams) |
| ctx = runtime.NewServerMetadataContext(ctx, md) |
| if err != nil { |
| runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) |
| return |
| } |
| |
| forward_Election_Resign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) |
| |
| }) |
| |
| return nil |
| } |
| |
| var ( |
| pattern_Election_Campaign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "campaign"}, "")) |
| |
| pattern_Election_Proclaim_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "proclaim"}, "")) |
| |
| pattern_Election_Leader_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "leader"}, "")) |
| |
| pattern_Election_Observe_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "observe"}, "")) |
| |
| pattern_Election_Resign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "resign"}, "")) |
| ) |
| |
| var ( |
| forward_Election_Campaign_0 = runtime.ForwardResponseMessage |
| |
| forward_Election_Proclaim_0 = runtime.ForwardResponseMessage |
| |
| forward_Election_Leader_0 = runtime.ForwardResponseMessage |
| |
| forward_Election_Observe_0 = runtime.ForwardResponseStream |
| |
| forward_Election_Resign_0 = runtime.ForwardResponseMessage |
| ) |