Lines Matching full:vars
39 std::map<grpc::string, grpc::string> vars, in GenerateError() argument
41 printer->Print(vars, "if $Error_Check$ {\n"); in GenerateError()
43 vars["Return"] = multiple_return ? "nil, err" : "err"; in GenerateError()
44 printer->Print(vars, "return $Return$\n"); in GenerateError()
52 std::map<grpc::string, grpc::string> vars) { in GenerateImports() argument
53 vars["filename"] = file->filename(); in GenerateImports()
56 printer->Print(vars, "//source: $filename$\n\n"); in GenerateImports()
57 printer->Print(vars, "package $Package$\n\n"); in GenerateImports()
60 printer->Print(vars, "$context$ \"context\"\n"); in GenerateImports()
62 printer->Print(vars, "$grpc$ \"google.golang.org/grpc\"\n"); in GenerateImports()
72 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethodSignature() argument
73 vars["Method"] = exportName(method->name()); in GenerateServerMethodSignature()
74 vars["Request"] = method->get_input_type_name(); in GenerateServerMethodSignature()
75 vars["Response"] = (vars["CustomMethodIO"] == "") in GenerateServerMethodSignature()
77 : vars["CustomMethodIO"]; in GenerateServerMethodSignature()
80 vars, in GenerateServerMethodSignature()
84 vars, "$Method$(*$Request$, $Service$_$Method$Server) error$Ending$"); in GenerateServerMethodSignature()
86 printer->Print(vars, "$Method$($Service$_$Method$Server) error$Ending$"); in GenerateServerMethodSignature()
92 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethod() argument
93 vars["Method"] = exportName(method->name()); in GenerateServerMethod()
94 vars["Request"] = method->get_input_type_name(); in GenerateServerMethod()
95 vars["Response"] = (vars["CustomMethodIO"] == "") in GenerateServerMethod()
97 : vars["CustomMethodIO"]; in GenerateServerMethod()
98 vars["FullMethodName"] = in GenerateServerMethod()
99 "/" + vars["ServicePrefix"] + vars["Service"] + "/" + vars["Method"]; in GenerateServerMethod()
100 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateServerMethod()
103 vars, in GenerateServerMethod()
108 printer->Print(vars, "in := new($Request$)\n"); in GenerateServerMethod()
109 vars["Error_Check"] = "err := dec(in); err != nil"; in GenerateServerMethod()
110 GenerateError(printer, vars); in GenerateServerMethod()
113 printer->Print(vars, "return srv.($Service$Server).$Method$(ctx, in)\n"); in GenerateServerMethod()
116 printer->Print(vars, "info := &$grpc$.UnaryServerInfo{\n"); in GenerateServerMethod()
119 printer->Print(vars, "FullMethod: \"$FullMethodName$\",\n"); in GenerateServerMethod()
125 printer->Print(vars, in GenerateServerMethod()
130 vars, "return srv.($Service$Server).$Method$(ctx, req.(*$Request$))\n"); in GenerateServerMethod()
138 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Server"; in GenerateServerMethod()
140 vars, in GenerateServerMethod()
144 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
145 vars["Error_Check"] = "err := stream.RecvMsg(m); err != nil"; in GenerateServerMethod()
146 GenerateError(printer, vars, false); in GenerateServerMethod()
148 vars, in GenerateServerMethod()
152 vars, "return srv.($Service$Server).$Method$(&$StreamType${stream})\n"); in GenerateServerMethod()
161 printer->Print(vars, "type $Service$_$Method$Server interface {\n"); in GenerateServerMethod()
163 if (genSend) { printer->Print(vars, "Send(*$Response$) error\n"); } in GenerateServerMethod()
164 if (genRecv) { printer->Print(vars, "Recv() (*$Request$, error)\n"); } in GenerateServerMethod()
166 printer->Print(vars, "SendAndClose(*$Response$) error\n"); in GenerateServerMethod()
168 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
172 printer->Print(vars, "type $StreamType$ struct {\n"); in GenerateServerMethod()
174 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
179 printer->Print(vars, in GenerateServerMethod()
187 printer->Print(vars, in GenerateServerMethod()
190 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
191 vars["Error_Check"] = "err := x.ServerStream.RecvMsg(m); err != nil"; in GenerateServerMethod()
192 GenerateError(printer, vars); in GenerateServerMethod()
199 vars, "func (x *$StreamType$) SendAndClose(m *$Response$) error {\n"); in GenerateServerMethod()
210 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethodSignature() argument
211 vars["Method"] = exportName(method->name()); in GenerateClientMethodSignature()
212 vars["Request"] = in GenerateClientMethodSignature()
213 ", in *" + ((vars["CustomMethodIO"] == "") ? method->get_input_type_name() in GenerateClientMethodSignature()
214 : vars["CustomMethodIO"]); in GenerateClientMethodSignature()
216 vars["Request"] = ""; in GenerateClientMethodSignature()
218 vars["Response"] = "*" + method->get_output_type_name(); in GenerateClientMethodSignature()
221 vars["Response"] = vars["Service"] + "_" + vars["Method"] + "Client"; in GenerateClientMethodSignature()
223 printer->Print(vars, in GenerateClientMethodSignature()
231 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethod() argument
232 printer->Print(vars, "func (c *$ServiceUnexported$Client) "); in GenerateClientMethod()
233 vars["Ending"] = " {\n"; in GenerateClientMethod()
234 GenerateClientMethodSignature(method, printer, vars); in GenerateClientMethod()
236 vars["Method"] = exportName(method->name()); in GenerateClientMethod()
237 vars["Request"] = (vars["CustomMethodIO"] == "") in GenerateClientMethod()
239 : vars["CustomMethodIO"]; in GenerateClientMethod()
240 vars["Response"] = method->get_output_type_name(); in GenerateClientMethod()
241 vars["FullMethodName"] = in GenerateClientMethod()
242 "/" + vars["ServicePrefix"] + vars["Service"] + "/" + vars["Method"]; in GenerateClientMethod()
244 printer->Print(vars, "out := new($Response$)\n"); in GenerateClientMethod()
246 vars, in GenerateClientMethod()
248 vars["Error_Check"] = "err != nil"; in GenerateClientMethod()
249 GenerateError(printer, vars); in GenerateClientMethod()
255 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Client"; in GenerateClientMethod()
256 printer->Print(vars, in GenerateClientMethod()
259 vars["Error_Check"] = "err != nil"; in GenerateClientMethod()
260 GenerateError(printer, vars); in GenerateClientMethod()
262 printer->Print(vars, "x := &$StreamType${stream}\n"); in GenerateClientMethod()
264 vars["Error_Check"] = "err := x.ClientStream.SendMsg(in); err != nil"; in GenerateClientMethod()
265 GenerateError(printer, vars); in GenerateClientMethod()
266 vars["Error_Check"] = "err := x.ClientStream.CloseSend(); err != nil"; in GenerateClientMethod()
267 GenerateError(printer, vars); in GenerateClientMethod()
278 printer->Print(vars, "type $Service$_$Method$Client interface {\n"); in GenerateClientMethod()
280 if (genSend) { printer->Print(vars, "Send(*$Request$) error\n"); } in GenerateClientMethod()
281 if (genRecv) { printer->Print(vars, "Recv() (*$Response$, error)\n"); } in GenerateClientMethod()
283 printer->Print(vars, "CloseAndRecv() (*$Response$, error)\n"); in GenerateClientMethod()
285 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
290 printer->Print(vars, "type $StreamType$ struct {\n"); in GenerateClientMethod()
292 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
297 printer->Print(vars, "func (x *$StreamType$) Send(m *$Request$) error {\n"); in GenerateClientMethod()
305 printer->Print(vars, in GenerateClientMethod()
308 printer->Print(vars, "m := new($Response$)\n"); in GenerateClientMethod()
309 vars["Error_Check"] = "err := x.ClientStream.RecvMsg(m); err != nil"; in GenerateClientMethod()
310 GenerateError(printer, vars); in GenerateClientMethod()
318 vars, "func (x *$StreamType$) CloseAndRecv() (*$Response$, error) {\n"); in GenerateClientMethod()
320 vars["Error_Check"] = "err := x.ClientStream.CloseSend(); err != nil"; in GenerateClientMethod()
321 GenerateError(printer, vars); in GenerateClientMethod()
322 printer->Print(vars, "m := new($Response$)\n"); in GenerateClientMethod()
323 vars["Error_Check"] = "err := x.ClientStream.RecvMsg(m); err != nil"; in GenerateClientMethod()
324 GenerateError(printer, vars); in GenerateClientMethod()
334 std::map<grpc::string, grpc::string> vars) { in GenerateService() argument
335 vars["Service"] = exportName(service->name()); in GenerateService()
337 printer->Print(vars, "// Client API for $Service$ service\n"); in GenerateService()
338 printer->Print(vars, "type $Service$Client interface {\n"); in GenerateService()
340 vars["Ending"] = "\n"; in GenerateService()
342 GenerateClientMethodSignature(service->method(i).get(), printer, vars); in GenerateService()
348 vars["ServiceUnexported"] = unexportName(vars["Service"]); in GenerateService()
349 printer->Print(vars, "type $ServiceUnexported$Client struct {\n"); in GenerateService()
351 printer->Print(vars, "cc $grpc$.ClientConnInterface\n"); in GenerateService()
356 printer->Print(vars, in GenerateService()
360 printer->Print(vars, "return &$ServiceUnexported$Client{cc}"); in GenerateService()
365 vars["ServiceDesc"] = "_" + vars["Service"] + "_serviceDesc"; in GenerateService()
369 vars["MethodDesc"] = in GenerateService()
370 vars["ServiceDesc"] + ".Method[" + as_string(unary_methods) + "]"; in GenerateService()
373 vars["MethodDesc"] = vars["ServiceDesc"] + ".Streams[" + in GenerateService()
377 GenerateClientMethod(method.get(), printer, vars); in GenerateService()
381 printer->Print(vars, "// Server API for $Service$ service\n"); in GenerateService()
382 printer->Print(vars, "type $Service$Server interface {\n"); in GenerateService()
384 vars["Ending"] = "\n"; in GenerateService()
386 GenerateServerMethodSignature(service->method(i).get(), printer, vars); in GenerateService()
388 printer->Print(vars, "mustEmbedUnimplemented$Service$Server()\n"); in GenerateService()
392 printer->Print(vars, "type Unimplemented$Service$Server struct {\n"); in GenerateService()
395 vars["Ending"] = " {\n"; in GenerateService()
398 vars["Method"] = exportName(method->name()); in GenerateService()
399 vars["Nil"] = method->NoStreaming() ? "nil, " : ""; in GenerateService()
400 printer->Print(vars, "func (Unimplemented$Service$Server) "); in GenerateService()
401 GenerateServerMethodSignature(method.get(), printer, vars); in GenerateService()
403 printer->Print(vars, in GenerateService()
411 printer->Print(vars, in GenerateService()
416 printer->Print(vars, "type Unsafe$Service$Server interface {\n"); in GenerateService()
418 printer->Print(vars, "mustEmbedUnimplemented$Service$Server()\n"); in GenerateService()
422 printer->Print(vars, in GenerateService()
426 printer->Print(vars, "s.RegisterService(&$ServiceDesc$, srv)\n"); in GenerateService()
431 GenerateServerMethod(service->method(i).get(), printer, vars); in GenerateService()
435 printer->Print(vars, "var $ServiceDesc$ = $grpc$.ServiceDesc{\n"); in GenerateService()
437 printer->Print(vars, "ServiceName: \"$ServicePrefix$$Service$\",\n"); in GenerateService()
438 printer->Print(vars, "HandlerType: (*$Service$Server)(nil),\n"); in GenerateService()
439 printer->Print(vars, "Methods: []$grpc$.MethodDesc{\n"); in GenerateService()
443 vars["Method"] = exportName(method->name()); in GenerateService()
444 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateService()
448 printer->Print(vars, "MethodName: \"$Method$\",\n"); in GenerateService()
449 printer->Print(vars, "Handler: $Handler$,\n"); in GenerateService()
456 printer->Print(vars, "Streams: []$grpc$.StreamDesc{\n"); in GenerateService()
460 vars["Method"] = exportName(method->name()); in GenerateService()
461 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateService()
465 printer->Print(vars, "StreamName: \"$Method$\",\n"); in GenerateService()
466 printer->Print(vars, "Handler: $Handler$,\n"); in GenerateService()
494 std::map<grpc::string, grpc::string> vars; in GenerateServiceSource() local
495 vars["Package"] = parameters->package_name; in GenerateServiceSource()
496 vars["ServicePrefix"] = parameters->service_prefix; in GenerateServiceSource()
497 if (!parameters->service_prefix.empty()) vars["ServicePrefix"].append("."); in GenerateServiceSource()
498 vars["grpc"] = "grpc"; in GenerateServiceSource()
499 vars["context"] = "context"; in GenerateServiceSource()
500 GenerateImports(file, printer, vars); in GenerateServiceSource()
502 vars["CustomMethodIO"] = parameters->custom_method_io_type; in GenerateServiceSource()
504 GenerateService(service, printer, vars); in GenerateServiceSource()