| 297 | } |
| 298 | |
| 299 | func serverSignature(g *protogen.GeneratedFile, method *protogen.Method) string { |
| 300 | var reqArgs []string |
| 301 | ret := "error" |
| 302 | if !method.Desc.IsStreamingClient() && !method.Desc.IsStreamingServer() { |
| 303 | reqArgs = append(reqArgs, g.QualifiedGoIdent(contextPackage.Ident("Context"))) |
| 304 | ret = "(*" + g.QualifiedGoIdent(method.Output.GoIdent) + ", error)" |
| 305 | } |
| 306 | if !method.Desc.IsStreamingClient() { |
| 307 | reqArgs = append(reqArgs, "*"+g.QualifiedGoIdent(method.Input.GoIdent)) |
| 308 | } |
| 309 | if method.Desc.IsStreamingClient() || method.Desc.IsStreamingServer() { |
| 310 | reqArgs = append(reqArgs, method.Parent.GoName+"_"+method.GoName+"Server") |
| 311 | } |
| 312 | return method.GoName + "(" + strings.Join(reqArgs, ", ") + ") " + ret |
| 313 | } |
| 314 | |
| 315 | func genServerMethod(gen *protogen.Plugin, file *protogen.File, g *protogen.GeneratedFile, method *protogen.Method) string { |
| 316 | service := method.Parent |