1// Code generated by protoc-gen-go-drpc. DO NOT EDIT.
2// protoc-gen-go-drpc version: (devel)
3// source: service.proto
4
5package service
6
7import (
8	bytes "bytes"
9	context "context"
10	errors "errors"
11	jsonpb "github.com/gogo/protobuf/jsonpb"
12	proto "github.com/gogo/protobuf/proto"
13	drpc "storj.io/drpc"
14	drpcerr "storj.io/drpc/drpcerr"
15)
16
17type drpcEncoding_File_service_proto struct{}
18
19func (drpcEncoding_File_service_proto) Marshal(msg drpc.Message) ([]byte, error) {
20	return proto.Marshal(msg.(proto.Message))
21}
22
23func (drpcEncoding_File_service_proto) Unmarshal(buf []byte, msg drpc.Message) error {
24	return proto.Unmarshal(buf, msg.(proto.Message))
25}
26
27func (drpcEncoding_File_service_proto) JSONMarshal(msg drpc.Message) ([]byte, error) {
28	var buf bytes.Buffer
29	err := new(jsonpb.Marshaler).Marshal(&buf, msg.(proto.Message))
30	if err != nil {
31		return nil, err
32	}
33	return buf.Bytes(), nil
34}
35
36func (drpcEncoding_File_service_proto) JSONUnmarshal(buf []byte, msg drpc.Message) error {
37	return jsonpb.Unmarshal(bytes.NewReader(buf), msg.(proto.Message))
38}
39
40type DRPCServiceClient interface {
41	DRPCConn() drpc.Conn
42
43	Method1(ctx context.Context, in *In) (*Out, error)
44	Method2(ctx context.Context) (DRPCService_Method2Client, error)
45	Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error)
46	Method4(ctx context.Context) (DRPCService_Method4Client, error)
47}
48
49type drpcServiceClient struct {
50	cc drpc.Conn
51}
52
53func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient {
54	return &drpcServiceClient{cc}
55}
56
57func (c *drpcServiceClient) DRPCConn() drpc.Conn { return c.cc }
58
59func (c *drpcServiceClient) Method1(ctx context.Context, in *In) (*Out, error) {
60	out := new(Out)
61	err := c.cc.Invoke(ctx, "/service.Service/Method1", drpcEncoding_File_service_proto{}, in, out)
62	if err != nil {
63		return nil, err
64	}
65	return out, nil
66}
67
68func (c *drpcServiceClient) Method2(ctx context.Context) (DRPCService_Method2Client, error) {
69	stream, err := c.cc.NewStream(ctx, "/service.Service/Method2", drpcEncoding_File_service_proto{})
70	if err != nil {
71		return nil, err
72	}
73	x := &drpcService_Method2Client{stream}
74	return x, nil
75}
76
77type DRPCService_Method2Client interface {
78	drpc.Stream
79	Send(*In) error
80	CloseAndRecv() (*Out, error)
81}
82
83type drpcService_Method2Client struct {
84	drpc.Stream
85}
86
87func (x *drpcService_Method2Client) Send(m *In) error {
88	return x.MsgSend(m, drpcEncoding_File_service_proto{})
89}
90
91func (x *drpcService_Method2Client) CloseAndRecv() (*Out, error) {
92	if err := x.CloseSend(); err != nil {
93		return nil, err
94	}
95	m := new(Out)
96	if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil {
97		return nil, err
98	}
99	return m, nil
100}
101
102func (x *drpcService_Method2Client) CloseAndRecvMsg(m *Out) error {
103	if err := x.CloseSend(); err != nil {
104		return err
105	}
106	return x.MsgRecv(m, drpcEncoding_File_service_proto{})
107}
108
109func (c *drpcServiceClient) Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error) {
110	stream, err := c.cc.NewStream(ctx, "/service.Service/Method3", drpcEncoding_File_service_proto{})
111	if err != nil {
112		return nil, err
113	}
114	x := &drpcService_Method3Client{stream}
115	if err := x.MsgSend(in, drpcEncoding_File_service_proto{}); err != nil {
116		return nil, err
117	}
118	if err := x.CloseSend(); err != nil {
119		return nil, err
120	}
121	return x, nil
122}
123
124type DRPCService_Method3Client interface {
125	drpc.Stream
126	Recv() (*Out, error)
127}
128
129type drpcService_Method3Client struct {
130	drpc.Stream
131}
132
133func (x *drpcService_Method3Client) Recv() (*Out, error) {
134	m := new(Out)
135	if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil {
136		return nil, err
137	}
138	return m, nil
139}
140
141func (x *drpcService_Method3Client) RecvMsg(m *Out) error {
142	return x.MsgRecv(m, drpcEncoding_File_service_proto{})
143}
144
145func (c *drpcServiceClient) Method4(ctx context.Context) (DRPCService_Method4Client, error) {
146	stream, err := c.cc.NewStream(ctx, "/service.Service/Method4", drpcEncoding_File_service_proto{})
147	if err != nil {
148		return nil, err
149	}
150	x := &drpcService_Method4Client{stream}
151	return x, nil
152}
153
154type DRPCService_Method4Client interface {
155	drpc.Stream
156	Send(*In) error
157	Recv() (*Out, error)
158}
159
160type drpcService_Method4Client struct {
161	drpc.Stream
162}
163
164func (x *drpcService_Method4Client) Send(m *In) error {
165	return x.MsgSend(m, drpcEncoding_File_service_proto{})
166}
167
168func (x *drpcService_Method4Client) Recv() (*Out, error) {
169	m := new(Out)
170	if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil {
171		return nil, err
172	}
173	return m, nil
174}
175
176func (x *drpcService_Method4Client) RecvMsg(m *Out) error {
177	return x.MsgRecv(m, drpcEncoding_File_service_proto{})
178}
179
180type DRPCServiceServer interface {
181	Method1(context.Context, *In) (*Out, error)
182	Method2(DRPCService_Method2Stream) error
183	Method3(*In, DRPCService_Method3Stream) error
184	Method4(DRPCService_Method4Stream) error
185}
186
187type DRPCServiceUnimplementedServer struct{}
188
189func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error) {
190	return nil, drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
191}
192
193func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error {
194	return drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
195}
196
197func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error {
198	return drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
199}
200
201func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error {
202	return drpcerr.WithCode(errors.New("Unimplemented"), drpcerr.Unimplemented)
203}
204
205type DRPCServiceDescription struct{}
206
207func (DRPCServiceDescription) NumMethods() int { return 4 }
208
209func (DRPCServiceDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) {
210	switch n {
211	case 0:
212		return "/service.Service/Method1", drpcEncoding_File_service_proto{},
213			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
214				return srv.(DRPCServiceServer).
215					Method1(
216						ctx,
217						in1.(*In),
218					)
219			}, DRPCServiceServer.Method1, true
220	case 1:
221		return "/service.Service/Method2", drpcEncoding_File_service_proto{},
222			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
223				return nil, srv.(DRPCServiceServer).
224					Method2(
225						&drpcService_Method2Stream{in1.(drpc.Stream)},
226					)
227			}, DRPCServiceServer.Method2, true
228	case 2:
229		return "/service.Service/Method3", drpcEncoding_File_service_proto{},
230			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
231				return nil, srv.(DRPCServiceServer).
232					Method3(
233						in1.(*In),
234						&drpcService_Method3Stream{in2.(drpc.Stream)},
235					)
236			}, DRPCServiceServer.Method3, true
237	case 3:
238		return "/service.Service/Method4", drpcEncoding_File_service_proto{},
239			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
240				return nil, srv.(DRPCServiceServer).
241					Method4(
242						&drpcService_Method4Stream{in1.(drpc.Stream)},
243					)
244			}, DRPCServiceServer.Method4, true
245	default:
246		return "", nil, nil, nil, false
247	}
248}
249
250func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error {
251	return mux.Register(impl, DRPCServiceDescription{})
252}
253
254type DRPCService_Method1Stream interface {
255	drpc.Stream
256	SendAndClose(*Out) error
257}
258
259type drpcService_Method1Stream struct {
260	drpc.Stream
261}
262
263func (x *drpcService_Method1Stream) SendAndClose(m *Out) error {
264	if err := x.MsgSend(m, drpcEncoding_File_service_proto{}); err != nil {
265		return err
266	}
267	return x.CloseSend()
268}
269
270type DRPCService_Method2Stream interface {
271	drpc.Stream
272	SendAndClose(*Out) error
273	Recv() (*In, error)
274}
275
276type drpcService_Method2Stream struct {
277	drpc.Stream
278}
279
280func (x *drpcService_Method2Stream) SendAndClose(m *Out) error {
281	if err := x.MsgSend(m, drpcEncoding_File_service_proto{}); err != nil {
282		return err
283	}
284	return x.CloseSend()
285}
286
287func (x *drpcService_Method2Stream) Recv() (*In, error) {
288	m := new(In)
289	if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil {
290		return nil, err
291	}
292	return m, nil
293}
294
295func (x *drpcService_Method2Stream) RecvMsg(m *In) error {
296	return x.MsgRecv(m, drpcEncoding_File_service_proto{})
297}
298
299type DRPCService_Method3Stream interface {
300	drpc.Stream
301	Send(*Out) error
302}
303
304type drpcService_Method3Stream struct {
305	drpc.Stream
306}
307
308func (x *drpcService_Method3Stream) Send(m *Out) error {
309	return x.MsgSend(m, drpcEncoding_File_service_proto{})
310}
311
312type DRPCService_Method4Stream interface {
313	drpc.Stream
314	Send(*Out) error
315	Recv() (*In, error)
316}
317
318type drpcService_Method4Stream struct {
319	drpc.Stream
320}
321
322func (x *drpcService_Method4Stream) Send(m *Out) error {
323	return x.MsgSend(m, drpcEncoding_File_service_proto{})
324}
325
326func (x *drpcService_Method4Stream) Recv() (*In, error) {
327	m := new(In)
328	if err := x.MsgRecv(m, drpcEncoding_File_service_proto{}); err != nil {
329		return nil, err
330	}
331	return m, nil
332}
333
334func (x *drpcService_Method4Stream) RecvMsg(m *In) error {
335	return x.MsgRecv(m, drpcEncoding_File_service_proto{})
336}
337