Lines Matching refs:P
102 func (g *grpc) P(args ...interface{}) { g.gen.P(args...) } func
113 g.P("// Reference imports to suppress errors if they are not otherwise used.")
114 g.P("var _ ", contextPkg, ".Context")
115 g.P("var _ ", grpcPkg, ".ClientConn")
116 g.P()
119 g.P("// This is a compile-time assertion to ensure that this generated file")
120 g.P("// is compatible with the grpc package it is being compiled against.")
121 g.P("const _ = ", grpcPkg, ".SupportPackageIsVersion", generatedCodeVersion)
122 g.P()
156 g.P()
157 g.P(fmt.Sprintf(`// %sClient is the client API for %s service.
163 g.P("//")
164 g.P(deprecationComment)
166 g.P("type ", servName, "Client interface {")
169 g.P(g.generateClientSignature(servName, method))
171 g.P("}")
172 g.P()
175 g.P("type ", unexport(servName), "Client struct {")
176 g.P("cc *", grpcPkg, ".ClientConn")
177 g.P("}")
178 g.P()
182 g.P(deprecationComment)
184 g.P("func New", servName, "Client (cc *", grpcPkg, ".ClientConn) ", servName, "Client {")
185 g.P("return &", unexport(servName), "Client{cc}")
186 g.P("}")
187 g.P()
208 g.P("// ", serverType, " is the server API for ", servName, " service.")
210 g.P("//")
211 g.P(deprecationComment)
213 g.P("type ", serverType, " interface {")
216 g.P(g.generateServerSignature(servName, method))
218 g.P("}")
219 g.P()
223 g.P(deprecationComment)
229 g.P(deprecationComment)
231 g.P("func Register", servName, "Server(s *", grpcPkg, ".Server, srv ", serverType, ") {")
232 g.P("s.RegisterService(&", serviceDescVar, `, srv)`)
233 g.P("}")
234 g.P()
244 g.P("var ", serviceDescVar, " = ", grpcPkg, ".ServiceDesc {")
245 g.P("ServiceName: ", strconv.Quote(fullServName), ",")
246 g.P("HandlerType: (*", serverType, ")(nil),")
247 g.P("Methods: []", grpcPkg, ".MethodDesc{")
252 g.P("{")
253 g.P("MethodName: ", strconv.Quote(method.GetName()), ",")
254 g.P("Handler: ", handlerNames[i], ",")
255 g.P("},")
257 g.P("},")
258 g.P("Streams: []", grpcPkg, ".StreamDesc{")
263 g.P("{")
264 g.P("StreamName: ", strconv.Quote(method.GetName()), ",")
265 g.P("Handler: ", handlerNames[i], ",")
267 g.P("ServerStreams: true,")
270 g.P("ClientStreams: true,")
272 g.P("},")
274 g.P("},")
275 g.P("Metadata: \"", file.GetName(), "\",")
276 g.P("}")
277 g.P()
283 g.P("// Unimplemented", serverType, " can be embedded to have forward compatible implementations.")
284 g.P("type Unimplemented", serverType, " struct {")
285 g.P("}")
286 g.P()
291 g.P()
297 g.P("func (*Unimplemented", servName, "Server) ", header, " {")
305 …g.P("return ", nilArg, statusPkg, `.Errorf(`, codePkg, `.Unimplemented, "method `, methName, ` not…
306 g.P("}")
334 g.P(deprecationComment)
336 g.P("func (c *", unexport(servName), "Client) ", g.generateClientSignature(servName, method), "{")
338 g.P("out := new(", outType, ")")
340 g.P(`err := c.cc.Invoke(ctx, "`, sname, `", in, out, opts...)`)
341 g.P("if err != nil { return nil, err }")
342 g.P("return out, nil")
343 g.P("}")
344 g.P()
348 g.P("stream, err := c.cc.NewStream(ctx, ", descExpr, `, "`, sname, `", opts...)`)
349 g.P("if err != nil { return nil, err }")
350 g.P("x := &", streamType, "{stream}")
352 g.P("if err := x.ClientStream.SendMsg(in); err != nil { return nil, err }")
353 g.P("if err := x.ClientStream.CloseSend(); err != nil { return nil, err }")
355 g.P("return x, nil")
356 g.P("}")
357 g.P()
364 g.P("type ", servName, "_", methName, "Client interface {")
366 g.P("Send(*", inType, ") error")
369 g.P("Recv() (*", outType, ", error)")
372 g.P("CloseAndRecv() (*", outType, ", error)")
374 g.P(grpcPkg, ".ClientStream")
375 g.P("}")
376 g.P()
378 g.P("type ", streamType, " struct {")
379 g.P(grpcPkg, ".ClientStream")
380 g.P("}")
381 g.P()
384 g.P("func (x *", streamType, ") Send(m *", inType, ") error {")
385 g.P("return x.ClientStream.SendMsg(m)")
386 g.P("}")
387 g.P()
390 g.P("func (x *", streamType, ") Recv() (*", outType, ", error) {")
391 g.P("m := new(", outType, ")")
392 g.P("if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }")
393 g.P("return m, nil")
394 g.P("}")
395 g.P()
398 g.P("func (x *", streamType, ") CloseAndRecv() (*", outType, ", error) {")
399 g.P("if err := x.ClientStream.CloseSend(); err != nil { return nil, err }")
400 g.P("m := new(", outType, ")")
401 g.P("if err := x.ClientStream.RecvMsg(m); err != nil { return nil, err }")
402 g.P("return m, nil")
403 g.P("}")
404 g.P()
463 …g.P("func ", hname, "(srv interface{}, ctx ", contextPkg, ".Context, dec func(interface{}) error, …
464 g.P("in := new(", inType, ")")
465 g.P("if err := dec(in); err != nil { return nil, err }")
466 g.P("if interceptor == nil { return srv.(", servName, "Server).", methName, "(ctx, in) }")
467 g.P("info := &", grpcPkg, ".UnaryServerInfo{")
468 g.P("Server: srv,")
469 g.P("FullMethod: ", strconv.Quote(fmt.Sprintf("/%s/%s", fullServName, methName)), ",")
470 g.P("}")
471 g.P("handler := func(ctx ", contextPkg, ".Context, req interface{}) (interface{}, error) {")
472 g.P("return srv.(", servName, "Server).", methName, "(ctx, req.(*", inType, "))")
473 g.P("}")
474 g.P("return interceptor(ctx, in, info, handler)")
475 g.P("}")
476 g.P()
480 g.P("func ", hname, "(srv interface{}, stream ", grpcPkg, ".ServerStream) error {")
482 g.P("m := new(", inType, ")")
483 g.P("if err := stream.RecvMsg(m); err != nil { return err }")
484 g.P("return srv.(", servName, "Server).", methName, "(m, &", streamType, "{stream})")
486 g.P("return srv.(", servName, "Server).", methName, "(&", streamType, "{stream})")
488 g.P("}")
489 g.P()
496 g.P("type ", servName, "_", methName, "Server interface {")
498 g.P("Send(*", outType, ") error")
501 g.P("SendAndClose(*", outType, ") error")
504 g.P("Recv() (*", inType, ", error)")
506 g.P(grpcPkg, ".ServerStream")
507 g.P("}")
508 g.P()
510 g.P("type ", streamType, " struct {")
511 g.P(grpcPkg, ".ServerStream")
512 g.P("}")
513 g.P()
516 g.P("func (x *", streamType, ") Send(m *", outType, ") error {")
517 g.P("return x.ServerStream.SendMsg(m)")
518 g.P("}")
519 g.P()
522 g.P("func (x *", streamType, ") SendAndClose(m *", outType, ") error {")
523 g.P("return x.ServerStream.SendMsg(m)")
524 g.P("}")
525 g.P()
528 g.P("func (x *", streamType, ") Recv() (*", inType, ", error) {")
529 g.P("m := new(", inType, ")")
530 g.P("if err := x.ServerStream.RecvMsg(m); err != nil { return nil, err }")
531 g.P("return m, nil")
532 g.P("}")
533 g.P()