LBRYCommunity/lbry.go
1
0
Fork 0
Code Issues 5 Pull requests Projects Releases 46 Packages Wiki Activity

update blobex

Browse source
This commit is contained in:
Alex Grintsvayg 2018-10-25 14:25:10 -04:00
parent dd284f117f
commit df5177dff0
No known key found for this signature in database
GPG key ID: AEB3F089F86A22B5
3 changed files with 40 additions and 40 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

76
blobex/blobex.pb.go
View file

@ -467,7 +467,7 @@ type BlobExchangeClient interface {
PriceCheck(ctx context.Context, in *PriceCheckRequest, opts ...grpc.CallOption) (*PriceCheckResponse, error)
DownloadCheck(ctx context.Context, in *HashesRequest, opts ...grpc.CallOption) (*HashesResponse, error)
Download(ctx context.Context, opts ...grpc.CallOption) (BlobExchange_DownloadClient, error)
UploadOffer(ctx context.Context, in *HashesRequest, opts ...grpc.CallOption) (*HashesResponse, error)
UploadCheck(ctx context.Context, in *HashesRequest, opts ...grpc.CallOption) (*HashesResponse, error)
Upload(ctx context.Context, opts ...grpc.CallOption) (BlobExchange_UploadClient, error)
}
@ -528,9 +528,9 @@ func (x *blobExchangeDownloadClient) Recv() (*DownloadResponse, error) {
return m, nil
}
func (c *blobExchangeClient) UploadOffer(ctx context.Context, in *HashesRequest, opts ...grpc.CallOption) (*HashesResponse, error) {
func (c *blobExchangeClient) UploadCheck(ctx context.Context, in *HashesRequest, opts ...grpc.CallOption) (*HashesResponse, error) {
out := new(HashesResponse)
err := c.cc.Invoke(ctx, "/blobex.BlobExchange/UploadOffer", in, out, opts...)
err := c.cc.Invoke(ctx, "/blobex.BlobExchange/UploadCheck", in, out, opts...)
if err != nil {
return nil, err
}
@ -573,7 +573,7 @@ type BlobExchangeServer interface {
PriceCheck(context.Context, *PriceCheckRequest) (*PriceCheckResponse, error)
DownloadCheck(context.Context, *HashesRequest) (*HashesResponse, error)
Download(BlobExchange_DownloadServer) error
UploadOffer(context.Context, *HashesRequest) (*HashesResponse, error)
UploadCheck(context.Context, *HashesRequest) (*HashesResponse, error)
Upload(BlobExchange_UploadServer) error
}
@ -643,20 +643,20 @@ func (x *blobExchangeDownloadServer) Recv() (*DownloadRequest, error) {
return m, nil
}
func _BlobExchange_UploadOffer_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
func _BlobExchange_UploadCheck_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(HashesRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(BlobExchangeServer).UploadOffer(ctx, in)
return srv.(BlobExchangeServer).UploadCheck(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/blobex.BlobExchange/UploadOffer",
FullMethod: "/blobex.BlobExchange/UploadCheck",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(BlobExchangeServer).UploadOffer(ctx, req.(*HashesRequest))
return srv.(BlobExchangeServer).UploadCheck(ctx, req.(*HashesRequest))
}
return interceptor(ctx, in, info, handler)
}
@ -700,8 +700,8 @@ var _BlobExchange_serviceDesc = grpc.ServiceDesc{
Handler: _BlobExchange_DownloadCheck_Handler,
},
{
MethodName: "UploadOffer",
Handler: _BlobExchange_UploadOffer_Handler,
MethodName: "UploadCheck",
Handler: _BlobExchange_UploadCheck_Handler,
},
},
Streams: []grpc.StreamDesc{
@ -724,33 +724,33 @@ var _BlobExchange_serviceDesc = grpc.ServiceDesc{
func init() { proto.RegisterFile("blobex.proto", fileDescriptor_183aee39e18f30c9) }
var fileDescriptor_183aee39e18f30c9 = []byte{
// 441 bytes of a gzipped FileDescriptorProto
// 436 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x94, 0xcd, 0x6e, 0xd4, 0x30,
0x10, 0xc7, 0xeb, 0xec, 0x07, 0xdd, 0xc9, 0xa6, 0x94, 0x01, 0x4a, 0xd8, 0x53, 0x64, 0x84, 0xc8,
0xa9, 0x42, 0x8b, 0x10, 0x50, 0x09, 0x84, 0x5a, 0x22, 0x81, 0x38, 0x50, 0x59, 0xe2, 0xc4, 0x29,
0x1f, 0xd3, 0x06, 0x35, 0xc4, 0x8b, 0xbd, 0xa5, 0xcd, 0x3b, 0xf1, 0x46, 0xbc, 0x0c, 0x8a, 0x1d,
0x37, 0xbb, 0x6d, 0x25, 0xb4, 0xe2, 0x36, 0x33, 0x9e, 0xf9, 0xfd, 0x27, 0xfe, 0x5b, 0x81, 0x69,
0x56, 0xc9, 0x8c, 0x2e, 0xf7, 0x17, 0x4a, 0x2e, 0x25, 0x8e, 0x6d, 0xc6, 0x5f, 0xc2, 0x28, 0x51,
0x4a, 0x2a, 0x44, 0x18, 0xe6, 0xb2, 0xa0, 0x90, 0x45, 0x2c, 0x0e, 0x84, 0x89, 0x31, 0x84, 0x3b,
0x3f, 0x48, 0xeb, 0xf4, 0x94, 0x42, 0x2f, 0x62, 0xf1, 0x44, 0xb8, 0x94, 0xdf, 0x87, 0x7b, 0xc7,
0xea, 0x7b, 0x4e, 0x47, 0x25, 0xe5, 0x67, 0x82, 0x7e, 0x9e, 0x93, 0x5e, 0xf2, 0x6f, 0x80, 0xab,
0x45, 0xbd, 0x90, 0xb5, 0x26, 0x7c, 0x02, 0x23, 0x6a, 0x15, 0x0c, 0xd9, 0x9f, 0x07, 0xfb, 0xdd,
0x1e, 0x46, 0x56, 0xd8, 0x33, 0x8c, 0xc0, 0x2f, 0xe8, 0x82, 0x1a, 0x7d, 0x4c, 0xea, 0xf3, 0xa1,
0x51, 0x1b, 0x8a, 0xd5, 0x12, 0x7f, 0x06, 0xc1, 0xc7, 0x54, 0x97, 0xa4, 0x3b, 0x35, 0xdc, 0x83,
0x71, 0x69, 0x0a, 0x21, 0x8b, 0x06, 0xf1, 0x44, 0x74, 0x19, 0xff, 0xcd, 0x60, 0xc7, 0x75, 0x6e,
0xb2, 0xc2, 0xc1, 0x15, 0xcf, 0x8b, 0x06, 0xb1, 0x3f, 0xe7, 0xae, 0x6b, 0x1d, 0xd6, 0xa5, 0x49,
0xbd, 0x54, 0x8d, 0xd3, 0x9c, 0xbd, 0x01, 0x7f, 0xa5, 0x8c, 0xbb, 0x30, 0x38, 0xa3, 0xc6, 0xa8,
0x4d, 0x44, 0x1b, 0xe2, 0x03, 0x18, 0xfd, 0x4a, 0xab, 0x73, 0x7b, 0x8f, 0xdb, 0xc2, 0x26, 0x07,
0xde, 0x6b, 0xc6, 0x9f, 0xc2, 0xdd, 0x0f, 0xf2, 0xa2, 0xae, 0x64, 0x5a, 0xb8, 0x2f, 0x43, 0x18,
0xb6, 0xdc, 0x6e, 0xde, 0xc4, 0xbc, 0x81, 0xdd, 0xbe, 0x6d, 0x93, 0xcf, 0x72, 0x30, 0xaf, 0x87,
0xb5, 0xb5, 0xb6, 0x35, 0x1c, 0x44, 0x2c, 0x9e, 0x0a, 0x13, 0xb7, 0x5e, 0xa7, 0x45, 0xa1, 0x48,
0xeb, 0x70, 0x68, 0xbd, 0xee, 0x52, 0xfe, 0x0a, 0x82, 0xaf, 0x8b, 0x7f, 0xec, 0x77, 0x85, 0xf4,
0x7a, 0x24, 0xff, 0x04, 0x3b, 0x6e, 0xf0, 0x3f, 0x37, 0x9e, 0xff, 0xf1, 0x60, 0x7a, 0x58, 0xc9,
0x2c, 0xb9, 0xcc, 0xcb, 0xb4, 0x3e, 0x25, 0x4c, 0x00, 0xfa, 0xb7, 0x86, 0x8f, 0x1d, 0xe8, 0xc6,
0xa3, 0x9c, 0xcd, 0x6e, 0x3b, 0xb2, 0xeb, 0xf0, 0x2d, 0x7c, 0x0f, 0x81, 0xbb, 0x56, 0x4b, 0x7a,
0x78, 0xdd, 0x75, 0x4b, 0xd9, 0xbb, 0xfd, 0x31, 0xf0, 0x2d, 0x3c, 0x82, 0x6d, 0x47, 0xc0, 0x47,
0xae, 0xeb, 0x9a, 0xa3, 0xb3, 0xf0, 0xe6, 0x81, 0x03, 0xc4, 0xec, 0x39, 0xc3, 0x77, 0xe0, 0xdb,
0x9b, 0xfa, 0x72, 0x72, 0x42, 0x6a, 0xf3, 0x25, 0xde, 0xc2, 0xd8, 0xce, 0xf7, 0xa3, 0x6b, 0x96,
0xf5, 0xa3, 0xeb, 0x86, 0x58, 0xf9, 0x6c, 0x6c, 0xfe, 0x09, 0x2f, 0xfe, 0x06, 0x00, 0x00, 0xff,
0xff, 0x7a, 0xcb, 0xab, 0x18, 0x23, 0x04, 0x00, 0x00,
0x10, 0xc7, 0xeb, 0xec, 0x07, 0xdd, 0xc9, 0xa6, 0x94, 0x01, 0x4a, 0xc8, 0x29, 0x32, 0x42, 0xe4,
0x54, 0xa1, 0x45, 0x08, 0xa8, 0x04, 0x42, 0x2d, 0x91, 0x40, 0x5c, 0x2a, 0x4b, 0x9c, 0x38, 0xe5,
0x63, 0xd4, 0xa0, 0x86, 0x78, 0xb1, 0xb7, 0xb4, 0x79, 0x27, 0xde, 0x88, 0x97, 0x41, 0xb1, 0xe3,
0x66, 0xb7, 0xad, 0x84, 0x0a, 0xb7, 0x99, 0xf1, 0xcc, 0xef, 0x3f, 0xf1, 0xdf, 0x0a, 0xcc, 0xf3,
0x5a, 0xe6, 0x74, 0xb1, 0xbf, 0x54, 0x72, 0x25, 0x71, 0x6a, 0x33, 0xfe, 0x12, 0x26, 0xa9, 0x52,
0x52, 0x21, 0xc2, 0xb8, 0x90, 0x25, 0x85, 0x2c, 0x66, 0x49, 0x20, 0x4c, 0x8c, 0x21, 0xdc, 0xf9,
0x4e, 0x5a, 0x67, 0x27, 0x14, 0x7a, 0x31, 0x4b, 0x66, 0xc2, 0xa5, 0xfc, 0x3e, 0xdc, 0x3b, 0x56,
0xdf, 0x0a, 0x3a, 0xaa, 0xa8, 0x38, 0x15, 0xf4, 0xe3, 0x8c, 0xf4, 0x8a, 0x7f, 0x05, 0x5c, 0x2f,
0xea, 0xa5, 0x6c, 0x34, 0xe1, 0x13, 0x98, 0x50, 0xa7, 0x60, 0xc8, 0xfe, 0x22, 0xd8, 0xef, 0xf7,
0x30, 0xb2, 0xc2, 0x9e, 0x61, 0x0c, 0x7e, 0x49, 0xe7, 0xd4, 0xea, 0x63, 0x52, 0x9f, 0x0f, 0x8d,
0xda, 0x58, 0xac, 0x97, 0xf8, 0x33, 0x08, 0x3e, 0x66, 0xba, 0x22, 0xdd, 0xab, 0xe1, 0x1e, 0x4c,
0x2b, 0x53, 0x08, 0x59, 0x3c, 0x4a, 0x66, 0xa2, 0xcf, 0xf8, 0x2f, 0x06, 0x3b, 0xae, 0xf3, 0x36,
0x2b, 0x1c, 0x5c, 0xf2, 0xbc, 0x78, 0x94, 0xf8, 0x0b, 0xee, 0xba, 0x36, 0x61, 0x7d, 0x9a, 0x36,
0x2b, 0xd5, 0x3a, 0xcd, 0xe8, 0x0d, 0xf8, 0x6b, 0x65, 0xdc, 0x85, 0xd1, 0x29, 0xb5, 0x46, 0x6d,
0x26, 0xba, 0x10, 0x1f, 0xc0, 0xe4, 0x67, 0x56, 0x9f, 0xd9, 0x7b, 0xdc, 0x16, 0x36, 0x39, 0xf0,
0x5e, 0x33, 0xfe, 0x14, 0xee, 0x7e, 0x90, 0xe7, 0x4d, 0x2d, 0xb3, 0xd2, 0x7d, 0x19, 0xc2, 0xb8,
0xe3, 0xf6, 0xf3, 0x26, 0xe6, 0x2d, 0xec, 0x0e, 0x6d, 0xb7, 0xf9, 0x2c, 0x07, 0xf3, 0x06, 0x58,
0x57, 0xeb, 0x5a, 0xc3, 0x51, 0xcc, 0x92, 0xb9, 0x30, 0x71, 0xe7, 0x75, 0x56, 0x96, 0x8a, 0xb4,
0x0e, 0xc7, 0xd6, 0xeb, 0x3e, 0xe5, 0xaf, 0x20, 0xf8, 0xb2, 0xfc, 0xcb, 0x7e, 0x97, 0x48, 0x6f,
0x40, 0xf2, 0x4f, 0xb0, 0xe3, 0x06, 0xff, 0x73, 0xe3, 0xc5, 0x6f, 0x0f, 0xe6, 0x87, 0xb5, 0xcc,
0xd3, 0x8b, 0xa2, 0xca, 0x9a, 0x13, 0xc2, 0x14, 0x60, 0x78, 0x6b, 0xf8, 0xd8, 0x81, 0xae, 0x3d,
0xca, 0x28, 0xba, 0xe9, 0xc8, 0xae, 0xc3, 0xb7, 0xf0, 0x3d, 0x04, 0xee, 0x5a, 0x2d, 0xe9, 0xe1,
0x55, 0xd7, 0x2d, 0x65, 0xef, 0xe6, 0xc7, 0xc0, 0xb7, 0xf0, 0x08, 0xb6, 0x1d, 0x01, 0x1f, 0xb9,
0xae, 0x2b, 0x8e, 0x46, 0xe1, 0xf5, 0x03, 0x07, 0x48, 0xd8, 0x73, 0x86, 0xef, 0xc0, 0xb7, 0x37,
0xf5, 0x8f, 0x4b, 0xbc, 0x85, 0xa9, 0x9d, 0x1f, 0x46, 0x37, 0x2c, 0x1b, 0x46, 0x37, 0x0d, 0xb1,
0xf2, 0xf9, 0xd4, 0xfc, 0x13, 0x5e, 0xfc, 0x09, 0x00, 0x00, 0xff, 0xff, 0x20, 0xee, 0x66, 0x62,
0x23, 0x04, 0x00, 0x00,
}

2
blobex/blobex.proto
View file

@ -34,7 +34,7 @@ service BlobExchange {
rpc PriceCheck(PriceCheckRequest) returns (PriceCheckResponse) {}
rpc DownloadCheck(HashesRequest) returns (HashesResponse) {}
rpc Download(stream DownloadRequest) returns (stream DownloadResponse) {}
rpc UploadOffer(HashesRequest) returns (HashesResponse) {}
rpc UploadCheck(HashesRequest) returns (HashesResponse) {}
rpc Upload(stream UploadRequest) returns (stream UploadResponse) {}
}

2
blobex/server.go
View file

@ -40,7 +40,7 @@ func (s *Server) Download(BlobExchange_DownloadServer) error {
return nil
}
func (s *Server) UploadOffer(context.Context, *HashesRequest) (*HashesResponse, error) {
func (s *Server) UploadCheck(context.Context, *HashesRequest) (*HashesResponse, error) {
return nil, nil
}