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