1// Code generated by protoc-gen-gogo. DO NOT EDIT.
2// source: servicedefs.proto
3
4package servicedefs
5
6import (
7	context "context"
8	errors "errors"
9	fmt "fmt"
10	proto "github.com/gogo/protobuf/proto"
11	math "math"
12	drpc "storj.io/drpc"
13	drpcerr "storj.io/drpc/drpcerr"
14)
15
16// Reference imports to suppress errors if they are not otherwise used.
17var _ = proto.Marshal
18var _ = fmt.Errorf
19var _ = math.Inf
20
21// This is a compile-time assertion to ensure that this generated file
22// is compatible with the proto package it is being compiled against.
23// A compilation error at this line likely means your copy of the
24// proto package needs to be updated.
25const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
26
27type In struct {
28	In                   int64    `protobuf:"varint,1,opt,name=in,proto3" json:"in,omitempty"`
29	XXX_NoUnkeyedLiteral struct{} `json:"-"`
30	XXX_unrecognized     []byte   `json:"-"`
31	XXX_sizecache        int32    `json:"-"`
32}
33
34func (m *In) Reset()         { *m = In{} }
35func (m *In) String() string { return proto.CompactTextString(m) }
36func (*In) ProtoMessage()    {}
37func (*In) Descriptor() ([]byte, []int) {
38	return fileDescriptor_37b01b08ac87a50d, []int{0}
39}
40func (m *In) XXX_Unmarshal(b []byte) error {
41	return xxx_messageInfo_In.Unmarshal(m, b)
42}
43func (m *In) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
44	return xxx_messageInfo_In.Marshal(b, m, deterministic)
45}
46func (m *In) XXX_Merge(src proto.Message) {
47	xxx_messageInfo_In.Merge(m, src)
48}
49func (m *In) XXX_Size() int {
50	return xxx_messageInfo_In.Size(m)
51}
52func (m *In) XXX_DiscardUnknown() {
53	xxx_messageInfo_In.DiscardUnknown(m)
54}
55
56var xxx_messageInfo_In proto.InternalMessageInfo
57
58func (m *In) GetIn() int64 {
59	if m != nil {
60		return m.In
61	}
62	return 0
63}
64
65type Out struct {
66	Out                  int64    `protobuf:"varint,1,opt,name=out,proto3" json:"out,omitempty"`
67	XXX_NoUnkeyedLiteral struct{} `json:"-"`
68	XXX_unrecognized     []byte   `json:"-"`
69	XXX_sizecache        int32    `json:"-"`
70}
71
72func (m *Out) Reset()         { *m = Out{} }
73func (m *Out) String() string { return proto.CompactTextString(m) }
74func (*Out) ProtoMessage()    {}
75func (*Out) Descriptor() ([]byte, []int) {
76	return fileDescriptor_37b01b08ac87a50d, []int{1}
77}
78func (m *Out) XXX_Unmarshal(b []byte) error {
79	return xxx_messageInfo_Out.Unmarshal(m, b)
80}
81func (m *Out) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
82	return xxx_messageInfo_Out.Marshal(b, m, deterministic)
83}
84func (m *Out) XXX_Merge(src proto.Message) {
85	xxx_messageInfo_Out.Merge(m, src)
86}
87func (m *Out) XXX_Size() int {
88	return xxx_messageInfo_Out.Size(m)
89}
90func (m *Out) XXX_DiscardUnknown() {
91	xxx_messageInfo_Out.DiscardUnknown(m)
92}
93
94var xxx_messageInfo_Out proto.InternalMessageInfo
95
96func (m *Out) GetOut() int64 {
97	if m != nil {
98		return m.Out
99	}
100	return 0
101}
102
103func init() {
104	proto.RegisterType((*In)(nil), "servicedefs.In")
105	proto.RegisterType((*Out)(nil), "servicedefs.Out")
106}
107
108func init() { proto.RegisterFile("servicedefs.proto", fileDescriptor_37b01b08ac87a50d) }
109
110var fileDescriptor_37b01b08ac87a50d = []byte{
111	// 190 bytes of a gzipped FileDescriptorProto
112	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x2c, 0x4e, 0x2d, 0x2a,
113	0xcb, 0x4c, 0x4e, 0x4d, 0x49, 0x4d, 0x2b, 0xd6, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x46,
114	0x12, 0x52, 0x12, 0xe1, 0x62, 0xf2, 0xcc, 0x13, 0xe2, 0xe3, 0x62, 0xca, 0xcc, 0x93, 0x60, 0x54,
115	0x60, 0xd4, 0x60, 0x0e, 0x62, 0xca, 0xcc, 0x53, 0x12, 0xe7, 0x62, 0xf6, 0x2f, 0x2d, 0x11, 0x12,
116	0xe0, 0x62, 0xce, 0x2f, 0x2d, 0x81, 0x8a, 0x83, 0x98, 0x46, 0x27, 0x19, 0xb9, 0xd8, 0x83, 0x21,
117	0xda, 0x85, 0x74, 0xb8, 0xd8, 0x7d, 0x53, 0x4b, 0x32, 0xf2, 0x53, 0x0c, 0x85, 0xf8, 0xf5, 0x90,
118	0xad, 0xf1, 0xcc, 0x93, 0x12, 0x40, 0x11, 0x00, 0x99, 0xa5, 0x07, 0x53, 0x6d, 0x44, 0x84, 0x6a,
119	0x0d, 0x46, 0x84, 0x7a, 0x63, 0x22, 0xd4, 0x1b, 0x30, 0x0a, 0x19, 0xc0, 0xd4, 0x9b, 0x10, 0x65,
120	0xbe, 0x01, 0xa3, 0x93, 0x7e, 0x94, 0x6e, 0x71, 0x49, 0x7e, 0x51, 0x96, 0x5e, 0x66, 0xbe, 0x7e,
121	0x4a, 0x51, 0x41, 0xb2, 0x7e, 0x66, 0x5e, 0x49, 0x6a, 0x51, 0x5e, 0x62, 0x8e, 0x7e, 0x52, 0x62,
122	0x72, 0x76, 0x72, 0x7e, 0x6e, 0x41, 0x62, 0x89, 0x3e, 0x92, 0xc6, 0x24, 0x36, 0x70, 0xf8, 0x19,
123	0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0xed, 0x52, 0xfd, 0x72, 0x54, 0x01, 0x00, 0x00,
124}
125
126// --- DRPC BEGIN ---
127
128type DRPCServiceClient interface {
129	DRPCConn() drpc.Conn
130
131	Method1(ctx context.Context, in *In) (*Out, error)
132	Method2(ctx context.Context) (DRPCService_Method2Client, error)
133	Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error)
134	Method4(ctx context.Context) (DRPCService_Method4Client, error)
135}
136
137type drpcServiceClient struct {
138	cc drpc.Conn
139}
140
141func NewDRPCServiceClient(cc drpc.Conn) DRPCServiceClient {
142	return &drpcServiceClient{cc}
143}
144
145func (c *drpcServiceClient) DRPCConn() drpc.Conn { return c.cc }
146
147func (c *drpcServiceClient) Method1(ctx context.Context, in *In) (*Out, error) {
148	out := new(Out)
149	err := c.cc.Invoke(ctx, "/servicedefs.Service/Method1", in, out)
150	if err != nil {
151		return nil, err
152	}
153	return out, nil
154}
155
156func (c *drpcServiceClient) Method2(ctx context.Context) (DRPCService_Method2Client, error) {
157	stream, err := c.cc.NewStream(ctx, "/servicedefs.Service/Method2")
158	if err != nil {
159		return nil, err
160	}
161	x := &drpcServiceMethod2Client{stream}
162	return x, nil
163}
164
165type DRPCService_Method2Client interface {
166	drpc.Stream
167	Send(*In) error
168	CloseAndRecv() (*Out, error)
169}
170
171type drpcServiceMethod2Client struct {
172	drpc.Stream
173}
174
175func (x *drpcServiceMethod2Client) Send(m *In) error {
176	return x.MsgSend(m)
177}
178
179func (x *drpcServiceMethod2Client) CloseAndRecv() (*Out, error) {
180	if err := x.CloseSend(); err != nil {
181		return nil, err
182	}
183	m := new(Out)
184	if err := x.MsgRecv(m); err != nil {
185		return nil, err
186	}
187	return m, nil
188}
189
190func (c *drpcServiceClient) Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error) {
191	stream, err := c.cc.NewStream(ctx, "/servicedefs.Service/Method3")
192	if err != nil {
193		return nil, err
194	}
195	x := &drpcServiceMethod3Client{stream}
196	if err := x.MsgSend(in); err != nil {
197		return nil, err
198	}
199	if err := x.CloseSend(); err != nil {
200		return nil, err
201	}
202	return x, nil
203}
204
205type DRPCService_Method3Client interface {
206	drpc.Stream
207	Recv() (*Out, error)
208}
209
210type drpcServiceMethod3Client struct {
211	drpc.Stream
212}
213
214func (x *drpcServiceMethod3Client) Recv() (*Out, error) {
215	m := new(Out)
216	if err := x.MsgRecv(m); err != nil {
217		return nil, err
218	}
219	return m, nil
220}
221
222func (c *drpcServiceClient) Method4(ctx context.Context) (DRPCService_Method4Client, error) {
223	stream, err := c.cc.NewStream(ctx, "/servicedefs.Service/Method4")
224	if err != nil {
225		return nil, err
226	}
227	x := &drpcServiceMethod4Client{stream}
228	return x, nil
229}
230
231type DRPCService_Method4Client interface {
232	drpc.Stream
233	Send(*In) error
234	Recv() (*Out, error)
235}
236
237type drpcServiceMethod4Client struct {
238	drpc.Stream
239}
240
241func (x *drpcServiceMethod4Client) Send(m *In) error {
242	return x.MsgSend(m)
243}
244
245func (x *drpcServiceMethod4Client) Recv() (*Out, error) {
246	m := new(Out)
247	if err := x.MsgRecv(m); err != nil {
248		return nil, err
249	}
250	return m, nil
251}
252
253type DRPCServiceServer interface {
254	Method1(context.Context, *In) (*Out, error)
255	Method2(DRPCService_Method2Stream) error
256	Method3(*In, DRPCService_Method3Stream) error
257	Method4(DRPCService_Method4Stream) error
258}
259
260type DRPCServiceUnimplementedServer struct{}
261
262func (s *DRPCServiceUnimplementedServer) Method1(context.Context, *In) (*Out, error) {
263	return nil, drpcerr.WithCode(errors.New("Unimplemented"), 12)
264}
265
266func (s *DRPCServiceUnimplementedServer) Method2(DRPCService_Method2Stream) error {
267	return drpcerr.WithCode(errors.New("Unimplemented"), 12)
268}
269
270func (s *DRPCServiceUnimplementedServer) Method3(*In, DRPCService_Method3Stream) error {
271	return drpcerr.WithCode(errors.New("Unimplemented"), 12)
272}
273
274func (s *DRPCServiceUnimplementedServer) Method4(DRPCService_Method4Stream) error {
275	return drpcerr.WithCode(errors.New("Unimplemented"), 12)
276}
277
278type DRPCServiceDescription struct{}
279
280func (DRPCServiceDescription) NumMethods() int { return 4 }
281
282func (DRPCServiceDescription) Method(n int) (string, drpc.Receiver, interface{}, bool) {
283	switch n {
284	case 0:
285		return "/servicedefs.Service/Method1",
286			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
287				return srv.(DRPCServiceServer).
288					Method1(
289						ctx,
290						in1.(*In),
291					)
292			}, DRPCServiceServer.Method1, true
293	case 1:
294		return "/servicedefs.Service/Method2",
295			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
296				return nil, srv.(DRPCServiceServer).
297					Method2(
298						&drpcServiceMethod2Stream{in1.(drpc.Stream)},
299					)
300			}, DRPCServiceServer.Method2, true
301	case 2:
302		return "/servicedefs.Service/Method3",
303			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
304				return nil, srv.(DRPCServiceServer).
305					Method3(
306						in1.(*In),
307						&drpcServiceMethod3Stream{in2.(drpc.Stream)},
308					)
309			}, DRPCServiceServer.Method3, true
310	case 3:
311		return "/servicedefs.Service/Method4",
312			func(srv interface{}, ctx context.Context, in1, in2 interface{}) (drpc.Message, error) {
313				return nil, srv.(DRPCServiceServer).
314					Method4(
315						&drpcServiceMethod4Stream{in1.(drpc.Stream)},
316					)
317			}, DRPCServiceServer.Method4, true
318	default:
319		return "", nil, nil, false
320	}
321}
322
323func DRPCRegisterService(mux drpc.Mux, impl DRPCServiceServer) error {
324	return mux.Register(impl, DRPCServiceDescription{})
325}
326
327type DRPCService_Method1Stream interface {
328	drpc.Stream
329	SendAndClose(*Out) error
330}
331
332type drpcServiceMethod1Stream struct {
333	drpc.Stream
334}
335
336func (x *drpcServiceMethod1Stream) SendAndClose(m *Out) error {
337	if err := x.MsgSend(m); err != nil {
338		return err
339	}
340	return x.CloseSend()
341}
342
343type DRPCService_Method2Stream interface {
344	drpc.Stream
345	SendAndClose(*Out) error
346	Recv() (*In, error)
347}
348
349type drpcServiceMethod2Stream struct {
350	drpc.Stream
351}
352
353func (x *drpcServiceMethod2Stream) SendAndClose(m *Out) error {
354	if err := x.MsgSend(m); err != nil {
355		return err
356	}
357	return x.CloseSend()
358}
359
360func (x *drpcServiceMethod2Stream) Recv() (*In, error) {
361	m := new(In)
362	if err := x.MsgRecv(m); err != nil {
363		return nil, err
364	}
365	return m, nil
366}
367
368type DRPCService_Method3Stream interface {
369	drpc.Stream
370	Send(*Out) error
371}
372
373type drpcServiceMethod3Stream struct {
374	drpc.Stream
375}
376
377func (x *drpcServiceMethod3Stream) Send(m *Out) error {
378	return x.MsgSend(m)
379}
380
381type DRPCService_Method4Stream interface {
382	drpc.Stream
383	Send(*Out) error
384	Recv() (*In, error)
385}
386
387type drpcServiceMethod4Stream struct {
388	drpc.Stream
389}
390
391func (x *drpcServiceMethod4Stream) Send(m *Out) error {
392	return x.MsgSend(m)
393}
394
395func (x *drpcServiceMethod4Stream) Recv() (*In, error) {
396	m := new(In)
397	if err := x.MsgRecv(m); err != nil {
398		return nil, err
399	}
400	return m, nil
401}
402
403// --- DRPC END ---
404