1// Code generated by protoc-gen-go-drpc. DO NOT EDIT. 2// protoc-gen-go-drpc version: (devel) 3// source: service.proto 4 5package grpccompat 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_service_proto struct{} 17 18func (drpcEncoding_File_service_proto) Marshal(msg drpc.Message) ([]byte, error) { 19 return proto.Marshal(msg.(proto.Message)) 20} 21 22func (drpcEncoding_File_service_proto) MarshalAppend(buf []byte, msg drpc.Message) ([]byte, error) { 23 return proto.MarshalOptions{}.MarshalAppend(buf, msg.(proto.Message)) 24} 25 26func (drpcEncoding_File_service_proto) Unmarshal(buf []byte, msg drpc.Message) error { 27 return proto.Unmarshal(buf, msg.(proto.Message)) 28} 29 30func (drpcEncoding_File_service_proto) JSONMarshal(msg drpc.Message) ([]byte, error) { 31 return protojson.Marshal(msg.(proto.Message)) 32} 33 34func (drpcEncoding_File_service_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, "/service.Service/Method1", drpcEncoding_File_service_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, "/service.Service/Method2", drpcEncoding_File_service_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_service_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_service_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_service_proto{}) 105} 106 107func (c *drpcServiceClient) Method3(ctx context.Context, in *In) (DRPCService_Method3Client, error) { 108 stream, err := c.cc.NewStream(ctx, "/service.Service/Method3", drpcEncoding_File_service_proto{}) 109 if err != nil { 110 return nil, err 111 } 112 x := &drpcService_Method3Client{stream} 113 if err := x.MsgSend(in, drpcEncoding_File_service_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_service_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_service_proto{}) 141} 142 143func (c *drpcServiceClient) Method4(ctx context.Context) (DRPCService_Method4Client, error) { 144 stream, err := c.cc.NewStream(ctx, "/service.Service/Method4", drpcEncoding_File_service_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_service_proto{}) 164} 165 166func (x *drpcService_Method4Client) Recv() (*Out, error) { 167 m := new(Out) 168 if err := x.MsgRecv(m, drpcEncoding_File_service_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_service_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 "/service.Service/Method1", drpcEncoding_File_service_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 "/service.Service/Method2", drpcEncoding_File_service_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 "/service.Service/Method3", drpcEncoding_File_service_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 "/service.Service/Method4", drpcEncoding_File_service_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_service_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_service_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_service_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_service_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_service_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_service_proto{}) 322} 323 324func (x *drpcService_Method4Stream) Recv() (*In, error) { 325 m := new(In) 326 if err := x.MsgRecv(m, drpcEncoding_File_service_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_service_proto{}) 334} 335