1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package helloworld_go_proto
22
23 import (
24 context "context"
25 grpc "google.golang.org/grpc"
26 codes "google.golang.org/grpc/codes"
27 status "google.golang.org/grpc/status"
28 )
29
30
31
32
33 const _ = grpc.SupportPackageIsVersion7
34
35 const (
36 Greeter_SayHello_FullMethodName = "/s2a.examples.Greeter/SayHello"
37 Greeter_SayHelloManyRequests_FullMethodName = "/s2a.examples.Greeter/SayHelloManyRequests"
38 Greeter_SayHelloManyReplies_FullMethodName = "/s2a.examples.Greeter/SayHelloManyReplies"
39 Greeter_SayHelloConversation_FullMethodName = "/s2a.examples.Greeter/SayHelloConversation"
40 )
41
42
43
44
45 type GreeterClient interface {
46
47 SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error)
48
49 SayHelloManyRequests(ctx context.Context, opts ...grpc.CallOption) (Greeter_SayHelloManyRequestsClient, error)
50
51 SayHelloManyReplies(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (Greeter_SayHelloManyRepliesClient, error)
52
53 SayHelloConversation(ctx context.Context, opts ...grpc.CallOption) (Greeter_SayHelloConversationClient, error)
54 }
55
56 type greeterClient struct {
57 cc grpc.ClientConnInterface
58 }
59
60 func NewGreeterClient(cc grpc.ClientConnInterface) GreeterClient {
61 return &greeterClient{cc}
62 }
63
64 func (c *greeterClient) SayHello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloReply, error) {
65 out := new(HelloReply)
66 err := c.cc.Invoke(ctx, Greeter_SayHello_FullMethodName, in, out, opts...)
67 if err != nil {
68 return nil, err
69 }
70 return out, nil
71 }
72
73 func (c *greeterClient) SayHelloManyRequests(ctx context.Context, opts ...grpc.CallOption) (Greeter_SayHelloManyRequestsClient, error) {
74 stream, err := c.cc.NewStream(ctx, &Greeter_ServiceDesc.Streams[0], Greeter_SayHelloManyRequests_FullMethodName, opts...)
75 if err != nil {
76 return nil, err
77 }
78 x := &greeterSayHelloManyRequestsClient{stream}
79 return x, nil
80 }
81
82 type Greeter_SayHelloManyRequestsClient interface {
83 Send(*HelloRequest) error
84 CloseAndRecv() (*HelloReply, error)
85 grpc.ClientStream
86 }
87
88 type greeterSayHelloManyRequestsClient struct {
89 grpc.ClientStream
90 }
91
92 func (x *greeterSayHelloManyRequestsClient) Send(m *HelloRequest) error {
93 return x.ClientStream.SendMsg(m)
94 }
95
96 func (x *greeterSayHelloManyRequestsClient) CloseAndRecv() (*HelloReply, error) {
97 if err := x.ClientStream.CloseSend(); err != nil {
98 return nil, err
99 }
100 m := new(HelloReply)
101 if err := x.ClientStream.RecvMsg(m); err != nil {
102 return nil, err
103 }
104 return m, nil
105 }
106
107 func (c *greeterClient) SayHelloManyReplies(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (Greeter_SayHelloManyRepliesClient, error) {
108 stream, err := c.cc.NewStream(ctx, &Greeter_ServiceDesc.Streams[1], Greeter_SayHelloManyReplies_FullMethodName, opts...)
109 if err != nil {
110 return nil, err
111 }
112 x := &greeterSayHelloManyRepliesClient{stream}
113 if err := x.ClientStream.SendMsg(in); err != nil {
114 return nil, err
115 }
116 if err := x.ClientStream.CloseSend(); err != nil {
117 return nil, err
118 }
119 return x, nil
120 }
121
122 type Greeter_SayHelloManyRepliesClient interface {
123 Recv() (*HelloReply, error)
124 grpc.ClientStream
125 }
126
127 type greeterSayHelloManyRepliesClient struct {
128 grpc.ClientStream
129 }
130
131 func (x *greeterSayHelloManyRepliesClient) Recv() (*HelloReply, error) {
132 m := new(HelloReply)
133 if err := x.ClientStream.RecvMsg(m); err != nil {
134 return nil, err
135 }
136 return m, nil
137 }
138
139 func (c *greeterClient) SayHelloConversation(ctx context.Context, opts ...grpc.CallOption) (Greeter_SayHelloConversationClient, error) {
140 stream, err := c.cc.NewStream(ctx, &Greeter_ServiceDesc.Streams[2], Greeter_SayHelloConversation_FullMethodName, opts...)
141 if err != nil {
142 return nil, err
143 }
144 x := &greeterSayHelloConversationClient{stream}
145 return x, nil
146 }
147
148 type Greeter_SayHelloConversationClient interface {
149 Send(*HelloRequest) error
150 Recv() (*HelloReply, error)
151 grpc.ClientStream
152 }
153
154 type greeterSayHelloConversationClient struct {
155 grpc.ClientStream
156 }
157
158 func (x *greeterSayHelloConversationClient) Send(m *HelloRequest) error {
159 return x.ClientStream.SendMsg(m)
160 }
161
162 func (x *greeterSayHelloConversationClient) Recv() (*HelloReply, error) {
163 m := new(HelloReply)
164 if err := x.ClientStream.RecvMsg(m); err != nil {
165 return nil, err
166 }
167 return m, nil
168 }
169
170
171
172
173 type GreeterServer interface {
174
175 SayHello(context.Context, *HelloRequest) (*HelloReply, error)
176
177 SayHelloManyRequests(Greeter_SayHelloManyRequestsServer) error
178
179 SayHelloManyReplies(*HelloRequest, Greeter_SayHelloManyRepliesServer) error
180
181 SayHelloConversation(Greeter_SayHelloConversationServer) error
182 mustEmbedUnimplementedGreeterServer()
183 }
184
185
186 type UnimplementedGreeterServer struct {
187 }
188
189 func (UnimplementedGreeterServer) SayHello(context.Context, *HelloRequest) (*HelloReply, error) {
190 return nil, status.Errorf(codes.Unimplemented, "method SayHello not implemented")
191 }
192 func (UnimplementedGreeterServer) SayHelloManyRequests(Greeter_SayHelloManyRequestsServer) error {
193 return status.Errorf(codes.Unimplemented, "method SayHelloManyRequests not implemented")
194 }
195 func (UnimplementedGreeterServer) SayHelloManyReplies(*HelloRequest, Greeter_SayHelloManyRepliesServer) error {
196 return status.Errorf(codes.Unimplemented, "method SayHelloManyReplies not implemented")
197 }
198 func (UnimplementedGreeterServer) SayHelloConversation(Greeter_SayHelloConversationServer) error {
199 return status.Errorf(codes.Unimplemented, "method SayHelloConversation not implemented")
200 }
201 func (UnimplementedGreeterServer) mustEmbedUnimplementedGreeterServer() {}
202
203
204
205
206 type UnsafeGreeterServer interface {
207 mustEmbedUnimplementedGreeterServer()
208 }
209
210 func RegisterGreeterServer(s grpc.ServiceRegistrar, srv GreeterServer) {
211 s.RegisterService(&Greeter_ServiceDesc, srv)
212 }
213
214 func _Greeter_SayHello_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
215 in := new(HelloRequest)
216 if err := dec(in); err != nil {
217 return nil, err
218 }
219 if interceptor == nil {
220 return srv.(GreeterServer).SayHello(ctx, in)
221 }
222 info := &grpc.UnaryServerInfo{
223 Server: srv,
224 FullMethod: Greeter_SayHello_FullMethodName,
225 }
226 handler := func(ctx context.Context, req interface{}) (interface{}, error) {
227 return srv.(GreeterServer).SayHello(ctx, req.(*HelloRequest))
228 }
229 return interceptor(ctx, in, info, handler)
230 }
231
232 func _Greeter_SayHelloManyRequests_Handler(srv interface{}, stream grpc.ServerStream) error {
233 return srv.(GreeterServer).SayHelloManyRequests(&greeterSayHelloManyRequestsServer{stream})
234 }
235
236 type Greeter_SayHelloManyRequestsServer interface {
237 SendAndClose(*HelloReply) error
238 Recv() (*HelloRequest, error)
239 grpc.ServerStream
240 }
241
242 type greeterSayHelloManyRequestsServer struct {
243 grpc.ServerStream
244 }
245
246 func (x *greeterSayHelloManyRequestsServer) SendAndClose(m *HelloReply) error {
247 return x.ServerStream.SendMsg(m)
248 }
249
250 func (x *greeterSayHelloManyRequestsServer) Recv() (*HelloRequest, error) {
251 m := new(HelloRequest)
252 if err := x.ServerStream.RecvMsg(m); err != nil {
253 return nil, err
254 }
255 return m, nil
256 }
257
258 func _Greeter_SayHelloManyReplies_Handler(srv interface{}, stream grpc.ServerStream) error {
259 m := new(HelloRequest)
260 if err := stream.RecvMsg(m); err != nil {
261 return err
262 }
263 return srv.(GreeterServer).SayHelloManyReplies(m, &greeterSayHelloManyRepliesServer{stream})
264 }
265
266 type Greeter_SayHelloManyRepliesServer interface {
267 Send(*HelloReply) error
268 grpc.ServerStream
269 }
270
271 type greeterSayHelloManyRepliesServer struct {
272 grpc.ServerStream
273 }
274
275 func (x *greeterSayHelloManyRepliesServer) Send(m *HelloReply) error {
276 return x.ServerStream.SendMsg(m)
277 }
278
279 func _Greeter_SayHelloConversation_Handler(srv interface{}, stream grpc.ServerStream) error {
280 return srv.(GreeterServer).SayHelloConversation(&greeterSayHelloConversationServer{stream})
281 }
282
283 type Greeter_SayHelloConversationServer interface {
284 Send(*HelloReply) error
285 Recv() (*HelloRequest, error)
286 grpc.ServerStream
287 }
288
289 type greeterSayHelloConversationServer struct {
290 grpc.ServerStream
291 }
292
293 func (x *greeterSayHelloConversationServer) Send(m *HelloReply) error {
294 return x.ServerStream.SendMsg(m)
295 }
296
297 func (x *greeterSayHelloConversationServer) Recv() (*HelloRequest, error) {
298 m := new(HelloRequest)
299 if err := x.ServerStream.RecvMsg(m); err != nil {
300 return nil, err
301 }
302 return m, nil
303 }
304
305
306
307
308 var Greeter_ServiceDesc = grpc.ServiceDesc{
309 ServiceName: "s2a.examples.Greeter",
310 HandlerType: (*GreeterServer)(nil),
311 Methods: []grpc.MethodDesc{
312 {
313 MethodName: "SayHello",
314 Handler: _Greeter_SayHello_Handler,
315 },
316 },
317 Streams: []grpc.StreamDesc{
318 {
319 StreamName: "SayHelloManyRequests",
320 Handler: _Greeter_SayHelloManyRequests_Handler,
321 ClientStreams: true,
322 },
323 {
324 StreamName: "SayHelloManyReplies",
325 Handler: _Greeter_SayHelloManyReplies_Handler,
326 ServerStreams: true,
327 },
328 {
329 StreamName: "SayHelloConversation",
330 Handler: _Greeter_SayHelloConversation_Handler,
331 ServerStreams: true,
332 ClientStreams: true,
333 },
334 },
335 Metadata: "internal/proto/examples/helloworld.proto",
336 }
337
View as plain text