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