Lines Matching refs:vars
74 std::map<grpc::string, grpc::string> vars, in GenerateError() argument
76 printer->Print(vars, "if $Error_Check$ {\n"); in GenerateError()
78 vars["Return"] = multiple_return ? "nil, err" : "err"; in GenerateError()
79 printer->Print(vars, "return $Return$\n"); in GenerateError()
86 std::map<grpc::string, grpc::string> vars) { in GenerateImports() argument
87 vars["filename"] = file->filename(); in GenerateImports()
90 printer->Print(vars, "//source: $filename$\n\n"); in GenerateImports()
91 printer->Print(vars, "package $Package$\n\n"); in GenerateImports()
94 printer->Print(vars, "$context$ \"context\"\n"); in GenerateImports()
96 printer->Print(vars, "$grpc$ \"google.golang.org/grpc\"\n"); in GenerateImports()
105 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethodSignature() argument
106 vars["Method"] = exportName(method->name()); in GenerateServerMethodSignature()
107 vars["Request"] = method->get_input_type_name(); in GenerateServerMethodSignature()
108 …vars["Response"] = (vars["CustomMethodIO"] == "") ? method->get_output_type_name() : vars["CustomM… in GenerateServerMethodSignature()
110 printer->Print(vars, "$Method$($context$.Context, *$Request$) (*$Response$, error)$Ending$"); in GenerateServerMethodSignature()
112 printer->Print(vars, "$Method$(*$Request$, $Service$_$Method$Server) error$Ending$"); in GenerateServerMethodSignature()
114 printer->Print(vars, "$Method$($Service$_$Method$Server) error$Ending$"); in GenerateServerMethodSignature()
119 std::map<grpc::string, grpc::string> vars) { in GenerateServerMethod() argument
120 vars["Method"] = exportName(method->name()); in GenerateServerMethod()
121 vars["Request"] = method->get_input_type_name(); in GenerateServerMethod()
122 …vars["Response"] = (vars["CustomMethodIO"] == "") ? method->get_output_type_name() : vars["CustomM… in GenerateServerMethod()
123 vars["FullMethodName"] = "/" + vars["ServicePrefix"] + vars["Service"] + "/" + vars["Method"]; in GenerateServerMethod()
124 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateServerMethod()
126 …printer->Print(vars, "func $Handler$(srv interface{}, ctx $context$.Context,\n\tdec func(interface… in GenerateServerMethod()
128 printer->Print(vars, "in := new($Request$)\n"); in GenerateServerMethod()
129 vars["Error_Check"] = "err := dec(in); err != nil"; in GenerateServerMethod()
130 GenerateError(printer, vars); in GenerateServerMethod()
133 printer->Print(vars, "return srv.($Service$Server).$Method$(ctx, in)\n"); in GenerateServerMethod()
136 printer->Print(vars, "info := &$grpc$.UnaryServerInfo{\n"); in GenerateServerMethod()
139 printer->Print(vars, "FullMethod: \"$FullMethodName$\",\n"); in GenerateServerMethod()
145 …printer->Print(vars, "handler := func(ctx $context$.Context, req interface{}) (interface{}, error)… in GenerateServerMethod()
147 printer->Print(vars, "return srv.($Service$Server).$Method$(ctx, req.(*$Request$))\n"); in GenerateServerMethod()
155 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Server"; in GenerateServerMethod()
156 printer->Print(vars, "func $Handler$(srv interface{}, stream $grpc$.ServerStream) error {\n"); in GenerateServerMethod()
159 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
160 vars["Error_Check"] = "err := stream.RecvMsg(m); err != nil"; in GenerateServerMethod()
161 GenerateError(printer, vars, false); in GenerateServerMethod()
162 printer->Print(vars, "return srv.($Service$Server).$Method$(m, &$StreamType${stream})\n"); in GenerateServerMethod()
164 printer->Print(vars, "return srv.($Service$Server).$Method$(&$StreamType${stream})\n"); in GenerateServerMethod()
173 printer->Print(vars, "type $Service$_$Method$Server interface {\n"); in GenerateServerMethod()
176 printer->Print(vars, "Send(*$Response$) error\n"); in GenerateServerMethod()
179 printer->Print(vars, "Recv() (*$Request$, error)\n"); in GenerateServerMethod()
182 printer->Print(vars, "SendAndClose(*$Response$) error\n"); in GenerateServerMethod()
184 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
188 printer->Print(vars, "type $StreamType$ struct {\n"); in GenerateServerMethod()
190 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
195 printer->Print(vars, "func (x *$StreamType$) Send(m *$Response$) error {\n"); in GenerateServerMethod()
202 printer->Print(vars, "func (x *$StreamType$) Recv() (*$Request$, error) {\n"); in GenerateServerMethod()
204 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
205 vars["Error_Check"] = "err := x.ServerStream.RecvMsg(m); err != nil"; in GenerateServerMethod()
206 GenerateError(printer, vars); in GenerateServerMethod()
212 printer->Print(vars, "func (x *$StreamType$) SendAndClose(m *$Response$) error {\n"); in GenerateServerMethod()
223 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethodSignature() argument
224 vars["Method"] = exportName(method->name()); in GenerateClientMethodSignature()
225 …vars["Request"] = ", in *" + ((vars["CustomMethodIO"] == "") ? method->get_input_type_name() : var… in GenerateClientMethodSignature()
227 vars["Request"] = ""; in GenerateClientMethodSignature()
229 vars["Response"] = "*" + method->get_output_type_name(); in GenerateClientMethodSignature()
231 vars["Response"] = vars["Service"] + "_" + vars["Method"] + "Client" ; in GenerateClientMethodSignature()
233 …printer->Print(vars, "$Method$(ctx $context$.Context$Request$,\n\topts ...$grpc$.CallOption) ($Res… in GenerateClientMethodSignature()
238 std::map<grpc::string, grpc::string> vars) { in GenerateClientMethod() argument
239 printer->Print(vars, "func (c *$ServiceUnexported$Client) "); in GenerateClientMethod()
240 vars["Ending"] = " {\n"; in GenerateClientMethod()
241 GenerateClientMethodSignature(method, printer, vars); in GenerateClientMethod()
243 vars["Method"] = exportName(method->name()); in GenerateClientMethod()
244 …vars["Request"] = (vars["CustomMethodIO"] == "") ? method->get_input_type_name() : vars["CustomMet… in GenerateClientMethod()
245 vars["Response"] = method->get_output_type_name(); in GenerateClientMethod()
246 vars["FullMethodName"] = "/" + vars["ServicePrefix"] + vars["Service"] + "/" + vars["Method"]; in GenerateClientMethod()
248 printer->Print(vars, "out := new($Response$)\n"); in GenerateClientMethod()
249 printer->Print(vars, "err := c.cc.Invoke(ctx, \"$FullMethodName$\", in, out, opts...)\n"); in GenerateClientMethod()
250 vars["Error_Check"] = "err != nil"; in GenerateClientMethod()
251 GenerateError(printer, vars); in GenerateClientMethod()
257 vars["StreamType"] = vars["ServiceUnexported"] + vars["Method"] + "Client"; in GenerateClientMethod()
258 …printer->Print(vars, "stream, err := c.cc.NewStream(ctx, &$MethodDesc$, \"$FullMethodName$\", opts… 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()
281 printer->Print(vars, "Send(*$Request$) error\n"); in GenerateClientMethod()
284 printer->Print(vars, "Recv() (*$Response$, error)\n"); in GenerateClientMethod()
287 printer->Print(vars, "CloseAndRecv() (*$Response$, error)\n"); in GenerateClientMethod()
289 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
294 printer->Print(vars, "type $StreamType$ struct {\n"); in GenerateClientMethod()
296 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
301 printer->Print(vars, "func (x *$StreamType$) Send(m *$Request$) error {\n"); in GenerateClientMethod()
309 printer->Print(vars, "func (x *$StreamType$) Recv() (*$Response$, error) {\n"); in GenerateClientMethod()
311 printer->Print(vars, "m := new($Response$)\n"); in GenerateClientMethod()
312 vars["Error_Check"] = "err := x.ClientStream.RecvMsg(m); err != nil"; in GenerateClientMethod()
313 GenerateError(printer, vars); in GenerateClientMethod()
320 printer->Print(vars, "func (x *$StreamType$) CloseAndRecv() (*$Response$, error) {\n"); in GenerateClientMethod()
322 vars["Error_Check"] = "err := x.ClientStream.CloseSend(); err != nil"; in GenerateClientMethod()
323 GenerateError(printer, vars); in GenerateClientMethod()
324 printer->Print(vars, "m := new($Response$)\n"); in GenerateClientMethod()
325 vars["Error_Check"] = "err := x.ClientStream.RecvMsg(m); err != nil"; in GenerateClientMethod()
326 GenerateError(printer, vars); in GenerateClientMethod()
335 std::map<grpc::string, grpc::string> vars) { in GenerateService() argument
336 vars["Service"] = exportName(service->name()); in GenerateService()
338 printer->Print(vars, "// Client API for $Service$ service\n"); in GenerateService()
339 printer->Print(vars, "type $Service$Client interface {\n"); in GenerateService()
341 vars["Ending"] = "\n"; in GenerateService()
343 GenerateClientMethodSignature(service->method(i).get(), printer, vars); in GenerateService()
349 vars["ServiceUnexported"] = unexportName(vars["Service"]); in GenerateService()
350 printer->Print(vars, "type $ServiceUnexported$Client struct {\n"); in GenerateService()
352 printer->Print(vars, "cc $grpc$.ClientConnInterface\n"); in GenerateService()
357 printer->Print(vars, "func New$Service$Client(cc $grpc$.ClientConnInterface) $Service$Client {\n"); in GenerateService()
359 printer->Print(vars, "return &$ServiceUnexported$Client{cc}"); in GenerateService()
364 vars["ServiceDesc"] = "_" + vars["Service"] + "_serviceDesc"; in GenerateService()
368 vars["MethodDesc"] = vars["ServiceDesc"] + ".Method[" + as_string(unary_methods) + "]"; in GenerateService()
371 vars["MethodDesc"] = vars["ServiceDesc"] + ".Streams[" + as_string(streaming_methods) + "]"; in GenerateService()
374 GenerateClientMethod(method.get(), printer, vars); in GenerateService()
378 printer->Print(vars, "// Server API for $Service$ service\n"); in GenerateService()
379 printer->Print(vars, "type $Service$Server interface {\n"); in GenerateService()
381 vars["Ending"] = "\n"; in GenerateService()
383 GenerateServerMethodSignature(service->method(i).get(), printer, vars); in GenerateService()
385 printer->Print(vars, "mustEmbedUnimplemented$Service$Server()\n"); in GenerateService()
389 printer->Print(vars, "type Unimplemented$Service$Server struct {\n"); in GenerateService()
392 vars["Ending"] = " {\n"; in GenerateService()
395 vars["Method"] = exportName(method->name()); in GenerateService()
396 vars["Nil"] = method->NoStreaming() ? "nil, " : ""; in GenerateService()
397 printer->Print(vars, "func (Unimplemented$Service$Server) "); in GenerateService()
398 GenerateServerMethodSignature(method.get(), printer, vars); in GenerateService()
400 …printer->Print(vars, "return $Nil$status.Errorf(codes.Unimplemented, \"method $Method$ not impleme… in GenerateService()
406 …printer->Print(vars, "func (Unimplemented$Service$Server) mustEmbedUnimplemented$Service$Server() … in GenerateService()
409 printer->Print(vars, "type Unsafe$Service$Server interface {\n"); in GenerateService()
411 printer->Print(vars, "mustEmbedUnimplemented$Service$Server()\n"); in GenerateService()
415 …printer->Print(vars, "func Register$Service$Server(s $grpc$.ServiceRegistrar, srv $Service$Server)… in GenerateService()
417 printer->Print(vars, "s.RegisterService(&$ServiceDesc$, srv)\n"); in GenerateService()
422 GenerateServerMethod(service->method(i).get(), printer, vars); in GenerateService()
427 printer->Print(vars, "var $ServiceDesc$ = $grpc$.ServiceDesc{\n"); in GenerateService()
429 printer->Print(vars, "ServiceName: \"$ServicePrefix$$Service$\",\n"); in GenerateService()
430 printer->Print(vars, "HandlerType: (*$Service$Server)(nil),\n"); in GenerateService()
431 printer->Print(vars, "Methods: []$grpc$.MethodDesc{\n"); in GenerateService()
435 vars["Method"] = exportName(method->name()); in GenerateService()
436 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateService()
440 printer->Print(vars, "MethodName: \"$Method$\",\n"); in GenerateService()
441 printer->Print(vars, "Handler: $Handler$,\n"); in GenerateService()
448 printer->Print(vars, "Streams: []$grpc$.StreamDesc{\n"); in GenerateService()
452 vars["Method"] = exportName(method->name()); in GenerateService()
453 vars["Handler"] = "_" + vars["Service"] + "_" + vars["Method"] + "_Handler"; in GenerateService()
457 printer->Print(vars, "StreamName: \"$Method$\",\n"); in GenerateService()
458 printer->Print(vars, "Handler: $Handler$,\n"); in GenerateService()
487 std::map<grpc::string, grpc::string> vars; in GenerateServiceSource() local
488 vars["Package"] = parameters->package_name; in GenerateServiceSource()
489 vars["ServicePrefix"] = parameters->service_prefix; in GenerateServiceSource()
491 vars["ServicePrefix"].append("."); in GenerateServiceSource()
492 vars["grpc"] = "grpc"; in GenerateServiceSource()
493 vars["context"] = "context"; in GenerateServiceSource()
494 GenerateImports(file, printer, vars); in GenerateServiceSource()
496 vars["CustomMethodIO"] = parameters->custom_method_io_type; in GenerateServiceSource()
498 GenerateService(service, printer, vars); in GenerateServiceSource()