Lines Matching refs:Print
77 printer->Print("//Generated by gRPC Go plugin\n"); in GenerateImports()
78 printer->Print("//If you make any local changes, they will be lost\n"); in GenerateImports()
79 printer->Print(vars, "//source: $filename$\n\n"); in GenerateImports()
80 printer->Print(vars, "package $Package$\n\n"); in GenerateImports()
82 printer->Print(file->additional_headers().c_str()); in GenerateImports()
83 printer->Print("\n\n"); in GenerateImports()
85 printer->Print("import (\n"); in GenerateImports()
87 printer->Print(vars, "$context$ \"context\"\n"); in GenerateImports()
88 printer->Print(vars, "$grpc$ \"google.golang.org/grpc\"\n"); in GenerateImports()
90 printer->Print(")\n\n"); in GenerateImports()
100 printer->Print(vars, "$Method$($context$.Context, *$Request$) (*$Response$, error)"); in GenerateServerMethodSignature()
102 printer->Print(vars, "$Method$(*$Request$, $Service$_$Method$Server) error"); in GenerateServerMethodSignature()
104 printer->Print(vars, "$Method$($Service$_$Method$Server) error"); in GenerateServerMethodSignature()
116 …printer->Print(vars, "func $Handler$(srv interface{}, ctx $context$.Context,\n\tdec func(interface… in GenerateServerMethod()
118 printer->Print(vars, "in := new($Request$)\n"); in GenerateServerMethod()
119 printer->Print("if err := dec(in); err != nil { return nil, err }\n"); in GenerateServerMethod()
120 …printer->Print(vars, "if interceptor == nil { return srv.($Service$Server).$Method$(ctx, in) }\n"); in GenerateServerMethod()
121 printer->Print(vars, "info := &$grpc$.UnaryServerInfo{\n"); in GenerateServerMethod()
123 printer->Print("Server: srv,\n"); in GenerateServerMethod()
124 printer->Print(vars, "FullMethod: \"$FullMethodName$\",\n"); in GenerateServerMethod()
126 printer->Print("}\n\n"); in GenerateServerMethod()
127 …printer->Print(vars, "handler := func(ctx $context$.Context, req interface{}) (interface{}, error)… in GenerateServerMethod()
129 printer->Print(vars, "return srv.($Service$Server).$Method$(ctx, req.(* $Request$))\n"); in GenerateServerMethod()
131 printer->Print("}\n"); in GenerateServerMethod()
132 printer->Print("return interceptor(ctx, in, info, handler)\n"); in GenerateServerMethod()
134 printer->Print("}\n\n"); in GenerateServerMethod()
138 printer->Print(vars, "func $Handler$(srv interface{}, stream $grpc$.ServerStream) error {\n"); in GenerateServerMethod()
141 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
142 printer->Print(vars, "if err := stream.RecvMsg(m); err != nil { return err }\n"); in GenerateServerMethod()
143 printer->Print(vars, "return srv.($Service$Server).$Method$(m, &$StreamType${stream})\n"); in GenerateServerMethod()
145 printer->Print(vars, "return srv.($Service$Server).$Method$(&$StreamType${stream})\n"); in GenerateServerMethod()
148 printer->Print("}\n\n"); in GenerateServerMethod()
154 printer->Print(vars, "type $Service$_$Method$Server interface { \n"); in GenerateServerMethod()
157 printer->Print(vars, "Send(* $Response$) error\n"); in GenerateServerMethod()
160 printer->Print(vars, "Recv() (* $Request$, error)\n"); in GenerateServerMethod()
163 printer->Print(vars, "SendAndClose(* $Response$) error\n"); in GenerateServerMethod()
165 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
167 printer->Print("}\n\n"); in GenerateServerMethod()
169 printer->Print(vars, "type $StreamType$ struct {\n"); in GenerateServerMethod()
171 printer->Print(vars, "$grpc$.ServerStream\n"); in GenerateServerMethod()
173 printer->Print("}\n\n"); in GenerateServerMethod()
176 printer->Print(vars, "func (x *$StreamType$) Send(m *$Response$) error {\n"); in GenerateServerMethod()
178 printer->Print("return x.ServerStream.SendMsg(m)\n"); in GenerateServerMethod()
180 printer->Print("}\n\n"); in GenerateServerMethod()
183 printer->Print(vars, "func (x *$StreamType$) Recv() (*$Request$, error) {\n"); in GenerateServerMethod()
185 printer->Print(vars, "m := new($Request$)\n"); in GenerateServerMethod()
186 printer->Print("if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err }\n"); in GenerateServerMethod()
187 printer->Print("return m, nil\n"); in GenerateServerMethod()
189 printer->Print("}\n\n"); in GenerateServerMethod()
192 printer->Print(vars, "func (x *$StreamType$) SendAndClose(m *$Response$) error {\n"); in GenerateServerMethod()
194 printer->Print("return x.ServerStream.SendMsg(m)\n"); in GenerateServerMethod()
196 printer->Print("}\n\n"); in GenerateServerMethod()
213 …printer->Print(vars, "$Method$(ctx $context$.Context$Request$, \n\topts... $grpc$.CallOption) ($Re… in GenerateClientMethodSignature()
219 printer->Print(vars, "func (c *$ServiceUnexported$Client) "); in GenerateClientMethod()
221 printer->Print(" {\n"); in GenerateClientMethod()
228 printer->Print(vars, "out := new($Response$)\n"); in GenerateClientMethod()
229 printer->Print(vars, "err := $grpc$.Invoke(ctx, \"$FullMethodName$\", in, out, c.cc, opts...)\n"); in GenerateClientMethod()
230 printer->Print("if err != nil { return nil, err }\n"); in GenerateClientMethod()
231 printer->Print("return out, nil\n"); in GenerateClientMethod()
233 printer->Print("}\n\n"); in GenerateClientMethod()
237 …printer->Print(vars, "stream, err := $grpc$.NewClientStream(ctx, &$MethodDesc$, c.cc, \"$FullMetho… in GenerateClientMethod()
238 printer->Print("if err != nil { return nil, err }\n"); in GenerateClientMethod()
240 printer->Print(vars, "x := &$StreamType${stream}\n"); in GenerateClientMethod()
242 printer->Print("if err := x.ClientStream.SendMsg(in); err != nil { return nil, err }\n"); in GenerateClientMethod()
243 printer->Print("if err := x.ClientStream.CloseSend(); err != nil { return nil, err }\n"); in GenerateClientMethod()
245 printer->Print("return x,nil\n"); in GenerateClientMethod()
247 printer->Print("}\n\n"); in GenerateClientMethod()
254 printer->Print(vars, "type $Service$_$Method$Client interface {\n"); in GenerateClientMethod()
257 printer->Print(vars, "Send(*$Request$) error\n"); in GenerateClientMethod()
260 printer->Print(vars, "Recv() (*$Response$, error)\n"); in GenerateClientMethod()
263 printer->Print(vars, "CloseAndRecv() (*$Response$, error)\n"); in GenerateClientMethod()
265 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
267 printer->Print("}\n\n"); in GenerateClientMethod()
270 printer->Print(vars, "type $StreamType$ struct{\n"); in GenerateClientMethod()
272 printer->Print(vars, "$grpc$.ClientStream\n"); in GenerateClientMethod()
274 printer->Print("}\n\n"); in GenerateClientMethod()
277 printer->Print(vars, "func (x *$StreamType$) Send(m *$Request$) error {\n"); in GenerateClientMethod()
279 printer->Print("return x.ClientStream.SendMsg(m)\n"); in GenerateClientMethod()
281 printer->Print("}\n\n"); in GenerateClientMethod()
285 printer->Print(vars, "func (x *$StreamType$) Recv() (*$Response$, error) {\n"); in GenerateClientMethod()
287 printer->Print(vars, "m := new($Response$)\n"); in GenerateClientMethod()
288 printer->Print("if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }\n"); in GenerateClientMethod()
289 printer->Print("return m, nil\n"); in GenerateClientMethod()
291 printer->Print("}\n\n"); in GenerateClientMethod()
295 printer->Print(vars, "func (x *$StreamType$) CloseAndRecv() (*$Response$, error) {\n"); in GenerateClientMethod()
297 printer->Print("if err := x.ClientStream.CloseSend(); err != nil { return nil, err }\n"); in GenerateClientMethod()
298 printer->Print(vars, "m := new ($Response$)\n"); in GenerateClientMethod()
299 printer->Print("if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }\n"); in GenerateClientMethod()
300 printer->Print("return m, nil\n"); in GenerateClientMethod()
302 printer->Print("}\n\n"); in GenerateClientMethod()
311 printer->Print(vars, "// Client API for $Service$ service\n"); in GenerateService()
312 printer->Print(vars, "type $Service$Client interface{\n"); in GenerateService()
316 printer->Print("\n"); in GenerateService()
319 printer->Print("}\n\n"); in GenerateService()
323 printer->Print(vars, "type $ServiceUnexported$Client struct {\n"); in GenerateService()
325 printer->Print(vars, "cc *$grpc$.ClientConn\n"); in GenerateService()
327 printer->Print("}\n\n"); in GenerateService()
330 printer->Print(vars, "func New$Service$Client(cc *$grpc$.ClientConn) $Service$Client {\n"); in GenerateService()
332 printer->Print(vars, "return &$ServiceUnexported$Client{cc}"); in GenerateService()
334 printer->Print("\n}\n\n"); in GenerateService()
351 printer->Print(vars, "// Server API for $Service$ service\n"); in GenerateService()
352 printer->Print(vars, "type $Service$Server interface {\n"); in GenerateService()
356 printer->Print("\n"); in GenerateService()
359 printer->Print("}\n\n"); in GenerateService()
362 printer->Print(vars, "func Register$Service$Server(s *$grpc$.Server, srv $Service$Server) {\n"); in GenerateService()
364 printer->Print(vars, "s.RegisterService(&$ServiceDesc$, srv)\n"); in GenerateService()
366 printer->Print("}\n\n"); in GenerateService()
370 printer->Print("\n"); in GenerateService()
375 printer->Print(vars, "var $ServiceDesc$ = $grpc$.ServiceDesc{\n"); in GenerateService()
377 printer->Print(vars, "ServiceName: \"$ServicePrefix$.$Service$\",\n"); in GenerateService()
378 printer->Print(vars, "HandlerType: (*$Service$Server)(nil),\n"); in GenerateService()
379 printer->Print(vars, "Methods: []$grpc$.MethodDesc{\n"); in GenerateService()
386 printer->Print("{\n"); in GenerateService()
388 printer->Print(vars, "MethodName: \"$Method$\",\n"); in GenerateService()
389 printer->Print(vars, "Handler: $Handler$, \n"); in GenerateService()
391 printer->Print("},\n"); in GenerateService()
395 printer->Print("},\n"); in GenerateService()
396 printer->Print(vars, "Streams: []$grpc$.StreamDesc{\n"); in GenerateService()
403 printer->Print("{\n"); in GenerateService()
405 printer->Print(vars, "StreamName: \"$Method$\",\n"); in GenerateService()
406 printer->Print(vars, "Handler: $Handler$, \n"); in GenerateService()
408 printer->Print("ClientStreams: true,\n"); in GenerateService()
410 printer->Print("ServerStreams: true,\n"); in GenerateService()
412 printer->Print("ServerStreams: true,\n"); in GenerateService()
413 printer->Print("ClientStreams: true,\n"); in GenerateService()
416 printer->Print("},\n"); in GenerateService()
420 printer->Print("},\n"); in GenerateService()
422 printer->Print("}\n\n"); in GenerateService()