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