v3election.pb.gw.go

Documentation: go.etcd.io/etcd/server/v3/etcdserver/api/v3election/v3electionpb/gw

     1  // Code generated by protoc-gen-grpc-gateway. DO NOT EDIT.
     2  // source: server/etcdserver/api/v3election/v3electionpb/v3election.proto
     3  
     4  /*
     5  Package v3electionpb is a reverse proxy.
     6  
     7  It translates gRPC into RESTful JSON APIs.
     8  */
     9  package gw
    10  
    11  import (
    12  	"context"
    13  	"go.etcd.io/etcd/server/v3/etcdserver/api/v3election/v3electionpb"
    14  	"io"
    15  	"net/http"
    16  
    17  	"github.com/golang/protobuf/descriptor"
    18  	"github.com/golang/protobuf/proto"
    19  	"github.com/grpc-ecosystem/grpc-gateway/runtime"
    20  	"github.com/grpc-ecosystem/grpc-gateway/utilities"
    21  	"google.golang.org/grpc"
    22  	"google.golang.org/grpc/codes"
    23  	"google.golang.org/grpc/grpclog"
    24  	"google.golang.org/grpc/status"
    25  )
    26  
    27  // Suppress "imported and not used" errors
    28  var _ codes.Code
    29  var _ io.Reader
    30  var _ status.Status
    31  var _ = runtime.String
    32  var _ = utilities.NewDoubleArray
    33  var _ = descriptor.ForMessage
    34  
    35  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) {
    36  	var protoReq v3electionpb.CampaignRequest
    37  	var metadata runtime.ServerMetadata
    38  
    39  	newReader, berr := utilities.IOReaderFactory(req.Body)
    40  	if berr != nil {
    41  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    42  	}
    43  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    44  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    45  	}
    46  
    47  	msg, err := client.Campaign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
    48  	return msg, metadata, err
    49  
    50  }
    51  
    52  func local_request_Election_Campaign_0(ctx context.Context, marshaler runtime.Marshaler, server v3electionpb.ElectionServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
    53  	var protoReq v3electionpb.CampaignRequest
    54  	var metadata runtime.ServerMetadata
    55  
    56  	newReader, berr := utilities.IOReaderFactory(req.Body)
    57  	if berr != nil {
    58  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    59  	}
    60  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    61  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    62  	}
    63  
    64  	msg, err := server.Campaign(ctx, &protoReq)
    65  	return msg, metadata, err
    66  
    67  }
    68  
    69  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) {
    70  	var protoReq v3electionpb.ProclaimRequest
    71  	var metadata runtime.ServerMetadata
    72  
    73  	newReader, berr := utilities.IOReaderFactory(req.Body)
    74  	if berr != nil {
    75  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    76  	}
    77  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    78  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    79  	}
    80  
    81  	msg, err := client.Proclaim(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
    82  	return msg, metadata, err
    83  
    84  }
    85  
    86  func local_request_Election_Proclaim_0(ctx context.Context, marshaler runtime.Marshaler, server v3electionpb.ElectionServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
    87  	var protoReq v3electionpb.ProclaimRequest
    88  	var metadata runtime.ServerMetadata
    89  
    90  	newReader, berr := utilities.IOReaderFactory(req.Body)
    91  	if berr != nil {
    92  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
    93  	}
    94  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
    95  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
    96  	}
    97  
    98  	msg, err := server.Proclaim(ctx, &protoReq)
    99  	return msg, metadata, err
   100  
   101  }
   102  
   103  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) {
   104  	var protoReq v3electionpb.LeaderRequest
   105  	var metadata runtime.ServerMetadata
   106  
   107  	newReader, berr := utilities.IOReaderFactory(req.Body)
   108  	if berr != nil {
   109  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
   110  	}
   111  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
   112  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
   113  	}
   114  
   115  	msg, err := client.Leader(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
   116  	return msg, metadata, err
   117  
   118  }
   119  
   120  func local_request_Election_Leader_0(ctx context.Context, marshaler runtime.Marshaler, server v3electionpb.ElectionServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
   121  	var protoReq v3electionpb.LeaderRequest
   122  	var metadata runtime.ServerMetadata
   123  
   124  	newReader, berr := utilities.IOReaderFactory(req.Body)
   125  	if berr != nil {
   126  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
   127  	}
   128  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
   129  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
   130  	}
   131  
   132  	msg, err := server.Leader(ctx, &protoReq)
   133  	return msg, metadata, err
   134  
   135  }
   136  
   137  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) {
   138  	var protoReq v3electionpb.LeaderRequest
   139  	var metadata runtime.ServerMetadata
   140  
   141  	newReader, berr := utilities.IOReaderFactory(req.Body)
   142  	if berr != nil {
   143  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
   144  	}
   145  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
   146  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
   147  	}
   148  
   149  	stream, err := client.Observe(ctx, &protoReq)
   150  	if err != nil {
   151  		return nil, metadata, err
   152  	}
   153  	header, err := stream.Header()
   154  	if err != nil {
   155  		return nil, metadata, err
   156  	}
   157  	metadata.HeaderMD = header
   158  	return stream, metadata, nil
   159  
   160  }
   161  
   162  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) {
   163  	var protoReq v3electionpb.ResignRequest
   164  	var metadata runtime.ServerMetadata
   165  
   166  	newReader, berr := utilities.IOReaderFactory(req.Body)
   167  	if berr != nil {
   168  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
   169  	}
   170  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
   171  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
   172  	}
   173  
   174  	msg, err := client.Resign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
   175  	return msg, metadata, err
   176  
   177  }
   178  
   179  func local_request_Election_Resign_0(ctx context.Context, marshaler runtime.Marshaler, server v3electionpb.ElectionServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
   180  	var protoReq v3electionpb.ResignRequest
   181  	var metadata runtime.ServerMetadata
   182  
   183  	newReader, berr := utilities.IOReaderFactory(req.Body)
   184  	if berr != nil {
   185  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
   186  	}
   187  	if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
   188  		return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
   189  	}
   190  
   191  	msg, err := server.Resign(ctx, &protoReq)
   192  	return msg, metadata, err
   193  
   194  }
   195  
   196  // v3electionpb.RegisterElectionHandlerServer registers the http handlers for service Election to "mux".
   197  // UnaryRPC     :call v3electionpb.ElectionServer directly.
   198  // StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.
   199  func RegisterElectionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server v3electionpb.ElectionServer) error {
   200  
   201  	mux.Handle("POST", pattern_Election_Campaign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   202  		ctx, cancel := context.WithCancel(req.Context())
   203  		defer cancel()
   204  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   205  		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
   206  		if err != nil {
   207  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   208  			return
   209  		}
   210  		resp, md, err := local_request_Election_Campaign_0(rctx, inboundMarshaler, server, req, pathParams)
   211  		ctx = runtime.NewServerMetadataContext(ctx, md)
   212  		if err != nil {
   213  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   214  			return
   215  		}
   216  
   217  		forward_Election_Campaign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   218  
   219  	})
   220  
   221  	mux.Handle("POST", pattern_Election_Proclaim_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   222  		ctx, cancel := context.WithCancel(req.Context())
   223  		defer cancel()
   224  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   225  		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
   226  		if err != nil {
   227  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   228  			return
   229  		}
   230  		resp, md, err := local_request_Election_Proclaim_0(rctx, inboundMarshaler, server, req, pathParams)
   231  		ctx = runtime.NewServerMetadataContext(ctx, md)
   232  		if err != nil {
   233  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   234  			return
   235  		}
   236  
   237  		forward_Election_Proclaim_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   238  
   239  	})
   240  
   241  	mux.Handle("POST", pattern_Election_Leader_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   242  		ctx, cancel := context.WithCancel(req.Context())
   243  		defer cancel()
   244  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   245  		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
   246  		if err != nil {
   247  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   248  			return
   249  		}
   250  		resp, md, err := local_request_Election_Leader_0(rctx, inboundMarshaler, server, req, pathParams)
   251  		ctx = runtime.NewServerMetadataContext(ctx, md)
   252  		if err != nil {
   253  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   254  			return
   255  		}
   256  
   257  		forward_Election_Leader_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   258  
   259  	})
   260  
   261  	mux.Handle("POST", pattern_Election_Observe_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   262  		err := status.Error(codes.Unimplemented, "streaming calls are not yet supported in the in-process transport")
   263  		_, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   264  		runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   265  		return
   266  	})
   267  
   268  	mux.Handle("POST", pattern_Election_Resign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   269  		ctx, cancel := context.WithCancel(req.Context())
   270  		defer cancel()
   271  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   272  		rctx, err := runtime.AnnotateIncomingContext(ctx, mux, req)
   273  		if err != nil {
   274  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   275  			return
   276  		}
   277  		resp, md, err := local_request_Election_Resign_0(rctx, inboundMarshaler, server, req, pathParams)
   278  		ctx = runtime.NewServerMetadataContext(ctx, md)
   279  		if err != nil {
   280  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   281  			return
   282  		}
   283  
   284  		forward_Election_Resign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   285  
   286  	})
   287  
   288  	return nil
   289  }
   290  
   291  // RegisterElectionHandlerFromEndpoint is same as RegisterElectionHandler but
   292  // automatically dials to "endpoint" and closes the connection when "ctx" gets done.
   293  func RegisterElectionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
   294  	conn, err := grpc.Dial(endpoint, opts...)
   295  	if err != nil {
   296  		return err
   297  	}
   298  	defer func() {
   299  		if err != nil {
   300  			if cerr := conn.Close(); cerr != nil {
   301  				grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
   302  			}
   303  			return
   304  		}
   305  		go func() {
   306  			<-ctx.Done()
   307  			if cerr := conn.Close(); cerr != nil {
   308  				grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
   309  			}
   310  		}()
   311  	}()
   312  
   313  	return RegisterElectionHandler(ctx, mux, conn)
   314  }
   315  
   316  // RegisterElectionHandler registers the http handlers for service Election to "mux".
   317  // The handlers forward requests to the grpc endpoint over "conn".
   318  func RegisterElectionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error {
   319  	return RegisterElectionHandlerClient(ctx, mux, v3electionpb.NewElectionClient(conn))
   320  }
   321  
   322  // v3electionpb.RegisterElectionHandlerClient registers the http handlers for service Election
   323  // to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ElectionClient".
   324  // Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ElectionClient"
   325  // doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in
   326  // "ElectionClient" to call the correct interceptors.
   327  func RegisterElectionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client v3electionpb.ElectionClient) error {
   328  
   329  	mux.Handle("POST", pattern_Election_Campaign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   330  		ctx, cancel := context.WithCancel(req.Context())
   331  		defer cancel()
   332  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   333  		rctx, err := runtime.AnnotateContext(ctx, mux, req)
   334  		if err != nil {
   335  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   336  			return
   337  		}
   338  		resp, md, err := request_Election_Campaign_0(rctx, inboundMarshaler, client, req, pathParams)
   339  		ctx = runtime.NewServerMetadataContext(ctx, md)
   340  		if err != nil {
   341  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   342  			return
   343  		}
   344  
   345  		forward_Election_Campaign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   346  
   347  	})
   348  
   349  	mux.Handle("POST", pattern_Election_Proclaim_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   350  		ctx, cancel := context.WithCancel(req.Context())
   351  		defer cancel()
   352  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   353  		rctx, err := runtime.AnnotateContext(ctx, mux, req)
   354  		if err != nil {
   355  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   356  			return
   357  		}
   358  		resp, md, err := request_Election_Proclaim_0(rctx, inboundMarshaler, client, req, pathParams)
   359  		ctx = runtime.NewServerMetadataContext(ctx, md)
   360  		if err != nil {
   361  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   362  			return
   363  		}
   364  
   365  		forward_Election_Proclaim_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   366  
   367  	})
   368  
   369  	mux.Handle("POST", pattern_Election_Leader_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   370  		ctx, cancel := context.WithCancel(req.Context())
   371  		defer cancel()
   372  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   373  		rctx, err := runtime.AnnotateContext(ctx, mux, req)
   374  		if err != nil {
   375  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   376  			return
   377  		}
   378  		resp, md, err := request_Election_Leader_0(rctx, inboundMarshaler, client, req, pathParams)
   379  		ctx = runtime.NewServerMetadataContext(ctx, md)
   380  		if err != nil {
   381  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   382  			return
   383  		}
   384  
   385  		forward_Election_Leader_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   386  
   387  	})
   388  
   389  	mux.Handle("POST", pattern_Election_Observe_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   390  		ctx, cancel := context.WithCancel(req.Context())
   391  		defer cancel()
   392  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   393  		rctx, err := runtime.AnnotateContext(ctx, mux, req)
   394  		if err != nil {
   395  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   396  			return
   397  		}
   398  		resp, md, err := request_Election_Observe_0(rctx, inboundMarshaler, client, req, pathParams)
   399  		ctx = runtime.NewServerMetadataContext(ctx, md)
   400  		if err != nil {
   401  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   402  			return
   403  		}
   404  
   405  		forward_Election_Observe_0(ctx, mux, outboundMarshaler, w, req, func() (proto.Message, error) { return resp.Recv() }, mux.GetForwardResponseOptions()...)
   406  
   407  	})
   408  
   409  	mux.Handle("POST", pattern_Election_Resign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
   410  		ctx, cancel := context.WithCancel(req.Context())
   411  		defer cancel()
   412  		inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
   413  		rctx, err := runtime.AnnotateContext(ctx, mux, req)
   414  		if err != nil {
   415  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   416  			return
   417  		}
   418  		resp, md, err := request_Election_Resign_0(rctx, inboundMarshaler, client, req, pathParams)
   419  		ctx = runtime.NewServerMetadataContext(ctx, md)
   420  		if err != nil {
   421  			runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
   422  			return
   423  		}
   424  
   425  		forward_Election_Resign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
   426  
   427  	})
   428  
   429  	return nil
   430  }
   431  
   432  var (
   433  	pattern_Election_Campaign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "campaign"}, "", runtime.AssumeColonVerbOpt(true)))
   434  
   435  	pattern_Election_Proclaim_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "proclaim"}, "", runtime.AssumeColonVerbOpt(true)))
   436  
   437  	pattern_Election_Leader_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "leader"}, "", runtime.AssumeColonVerbOpt(true)))
   438  
   439  	pattern_Election_Observe_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "observe"}, "", runtime.AssumeColonVerbOpt(true)))
   440  
   441  	pattern_Election_Resign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "resign"}, "", runtime.AssumeColonVerbOpt(true)))
   442  )
   443  
   444  var (
   445  	forward_Election_Campaign_0 = runtime.ForwardResponseMessage
   446  
   447  	forward_Election_Proclaim_0 = runtime.ForwardResponseMessage
   448  
   449  	forward_Election_Leader_0 = runtime.ForwardResponseMessage
   450  
   451  	forward_Election_Observe_0 = runtime.ForwardResponseStream
   452  
   453  	forward_Election_Resign_0 = runtime.ForwardResponseMessage
   454  )
   455
View as plain text