1// Code generated by protoc-gen-grpc-gateway. DO NOT EDIT. 2// source: etcdserver/api/v3election/v3electionpb/v3election.proto 3 4/* 5Package v3electionpb is a reverse proxy. 6 7It translates gRPC into RESTful JSON APIs. 8*/ 9package gw 10 11import ( 12 "go.etcd.io/etcd/etcdserver/api/v3election/v3electionpb" 13 "io" 14 "net/http" 15 16 "github.com/golang/protobuf/proto" 17 "github.com/grpc-ecosystem/grpc-gateway/runtime" 18 "github.com/grpc-ecosystem/grpc-gateway/utilities" 19 "golang.org/x/net/context" 20 "google.golang.org/grpc" 21 "google.golang.org/grpc/codes" 22 "google.golang.org/grpc/grpclog" 23 "google.golang.org/grpc/status" 24) 25 26var _ codes.Code 27var _ io.Reader 28var _ status.Status 29var _ = runtime.String 30var _ = utilities.NewDoubleArray 31 32func 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) { 33 var protoReq v3electionpb.CampaignRequest 34 var metadata runtime.ServerMetadata 35 36 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { 37 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) 38 } 39 40 msg, err := client.Campaign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) 41 return msg, metadata, err 42 43} 44 45func 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) { 46 var protoReq v3electionpb.ProclaimRequest 47 var metadata runtime.ServerMetadata 48 49 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { 50 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) 51 } 52 53 msg, err := client.Proclaim(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) 54 return msg, metadata, err 55 56} 57 58func 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) { 59 var protoReq v3electionpb.LeaderRequest 60 var metadata runtime.ServerMetadata 61 62 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { 63 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) 64 } 65 66 msg, err := client.Leader(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) 67 return msg, metadata, err 68 69} 70 71func 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) { 72 var protoReq v3electionpb.LeaderRequest 73 var metadata runtime.ServerMetadata 74 75 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { 76 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) 77 } 78 79 stream, err := client.Observe(ctx, &protoReq) 80 if err != nil { 81 return nil, metadata, err 82 } 83 header, err := stream.Header() 84 if err != nil { 85 return nil, metadata, err 86 } 87 metadata.HeaderMD = header 88 return stream, metadata, nil 89 90} 91 92func 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) { 93 var protoReq v3electionpb.ResignRequest 94 var metadata runtime.ServerMetadata 95 96 if err := marshaler.NewDecoder(req.Body).Decode(&protoReq); err != nil && err != io.EOF { 97 return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err) 98 } 99 100 msg, err := client.Resign(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD)) 101 return msg, metadata, err 102 103} 104 105// RegisterElectionHandlerFromEndpoint is same as RegisterElectionHandler but 106// automatically dials to "endpoint" and closes the connection when "ctx" gets done. 107func RegisterElectionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) { 108 conn, err := grpc.Dial(endpoint, opts...) 109 if err != nil { 110 return err 111 } 112 defer func() { 113 if err != nil { 114 if cerr := conn.Close(); cerr != nil { 115 grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) 116 } 117 return 118 } 119 go func() { 120 <-ctx.Done() 121 if cerr := conn.Close(); cerr != nil { 122 grpclog.Printf("Failed to close conn to %s: %v", endpoint, cerr) 123 } 124 }() 125 }() 126 127 return RegisterElectionHandler(ctx, mux, conn) 128} 129 130// RegisterElectionHandler registers the http handlers for service Election to "mux". 131// The handlers forward requests to the grpc endpoint over "conn". 132func RegisterElectionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error { 133 return RegisterElectionHandlerClient(ctx, mux, v3electionpb.NewElectionClient(conn)) 134} 135 136// RegisterElectionHandler registers the http handlers for service Election to "mux". 137// The handlers forward requests to the grpc endpoint over the given implementation of "ElectionClient". 138// Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ElectionClient" 139// doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in 140// "ElectionClient" to call the correct interceptors. 141func RegisterElectionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client v3electionpb.ElectionClient) error { 142 143 mux.Handle("POST", pattern_Election_Campaign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { 144 ctx, cancel := context.WithCancel(req.Context()) 145 defer cancel() 146 if cn, ok := w.(http.CloseNotifier); ok { 147 go func(done <-chan struct{}, closed <-chan bool) { 148 select { 149 case <-done: 150 case <-closed: 151 cancel() 152 } 153 }(ctx.Done(), cn.CloseNotify()) 154 } 155 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) 156 rctx, err := runtime.AnnotateContext(ctx, mux, req) 157 if err != nil { 158 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 159 return 160 } 161 resp, md, err := request_Election_Campaign_0(rctx, inboundMarshaler, client, req, pathParams) 162 ctx = runtime.NewServerMetadataContext(ctx, md) 163 if err != nil { 164 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 165 return 166 } 167 168 forward_Election_Campaign_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) 169 170 }) 171 172 mux.Handle("POST", pattern_Election_Proclaim_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { 173 ctx, cancel := context.WithCancel(req.Context()) 174 defer cancel() 175 if cn, ok := w.(http.CloseNotifier); ok { 176 go func(done <-chan struct{}, closed <-chan bool) { 177 select { 178 case <-done: 179 case <-closed: 180 cancel() 181 } 182 }(ctx.Done(), cn.CloseNotify()) 183 } 184 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) 185 rctx, err := runtime.AnnotateContext(ctx, mux, req) 186 if err != nil { 187 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 188 return 189 } 190 resp, md, err := request_Election_Proclaim_0(rctx, inboundMarshaler, client, req, pathParams) 191 ctx = runtime.NewServerMetadataContext(ctx, md) 192 if err != nil { 193 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 194 return 195 } 196 197 forward_Election_Proclaim_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) 198 199 }) 200 201 mux.Handle("POST", pattern_Election_Leader_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { 202 ctx, cancel := context.WithCancel(req.Context()) 203 defer cancel() 204 if cn, ok := w.(http.CloseNotifier); ok { 205 go func(done <-chan struct{}, closed <-chan bool) { 206 select { 207 case <-done: 208 case <-closed: 209 cancel() 210 } 211 }(ctx.Done(), cn.CloseNotify()) 212 } 213 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) 214 rctx, err := runtime.AnnotateContext(ctx, mux, req) 215 if err != nil { 216 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 217 return 218 } 219 resp, md, err := request_Election_Leader_0(rctx, inboundMarshaler, client, req, pathParams) 220 ctx = runtime.NewServerMetadataContext(ctx, md) 221 if err != nil { 222 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 223 return 224 } 225 226 forward_Election_Leader_0(ctx, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...) 227 228 }) 229 230 mux.Handle("POST", pattern_Election_Observe_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { 231 ctx, cancel := context.WithCancel(req.Context()) 232 defer cancel() 233 if cn, ok := w.(http.CloseNotifier); ok { 234 go func(done <-chan struct{}, closed <-chan bool) { 235 select { 236 case <-done: 237 case <-closed: 238 cancel() 239 } 240 }(ctx.Done(), cn.CloseNotify()) 241 } 242 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) 243 rctx, err := runtime.AnnotateContext(ctx, mux, req) 244 if err != nil { 245 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 246 return 247 } 248 resp, md, err := request_Election_Observe_0(rctx, inboundMarshaler, client, req, pathParams) 249 ctx = runtime.NewServerMetadataContext(ctx, md) 250 if err != nil { 251 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 252 return 253 } 254 255 forward_Election_Observe_0(ctx, mux, outboundMarshaler, w, req, func() (proto.Message, error) { return resp.Recv() }, mux.GetForwardResponseOptions()...) 256 257 }) 258 259 mux.Handle("POST", pattern_Election_Resign_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) { 260 ctx, cancel := context.WithCancel(req.Context()) 261 defer cancel() 262 if cn, ok := w.(http.CloseNotifier); ok { 263 go func(done <-chan struct{}, closed <-chan bool) { 264 select { 265 case <-done: 266 case <-closed: 267 cancel() 268 } 269 }(ctx.Done(), cn.CloseNotify()) 270 } 271 inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req) 272 rctx, err := runtime.AnnotateContext(ctx, mux, req) 273 if err != nil { 274 runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err) 275 return 276 } 277 resp, md, err := request_Election_Resign_0(rctx, inboundMarshaler, client, 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 291var ( 292 pattern_Election_Campaign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "campaign"}, "")) 293 294 pattern_Election_Proclaim_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "proclaim"}, "")) 295 296 pattern_Election_Leader_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "leader"}, "")) 297 298 pattern_Election_Observe_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "observe"}, "")) 299 300 pattern_Election_Resign_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v3", "election", "resign"}, "")) 301) 302 303var ( 304 forward_Election_Campaign_0 = runtime.ForwardResponseMessage 305 306 forward_Election_Proclaim_0 = runtime.ForwardResponseMessage 307 308 forward_Election_Leader_0 = runtime.ForwardResponseMessage 309 310 forward_Election_Observe_0 = runtime.ForwardResponseStream 311 312 forward_Election_Resign_0 = runtime.ForwardResponseMessage 313) 314