Documentation
¶
Index ¶
- Variables
- func RegisterFileServicesServiceServer(s *grpc.Server, srv FileServicesServiceServer)
- type DataBlock
- func (*DataBlock) Descriptor() ([]byte, []int)deprecated
- func (x *DataBlock) GetBucket() string
- func (x *DataBlock) GetData() []byte
- func (x *DataBlock) GetDataProductName() string
- func (x *DataBlock) GetDataProductVersion() string
- func (x *DataBlock) GetMd5Hash() string
- func (x *DataBlock) GetName() string
- func (x *DataBlock) GetResourceName() string
- func (x *DataBlock) GetResourceType() string
- func (x *DataBlock) GetTenant() string
- func (*DataBlock) ProtoMessage()
- func (x *DataBlock) ProtoReflect() protoreflect.Message
- func (x *DataBlock) Reset()
- func (x *DataBlock) String() string
- type FileServicesServiceClient
- type FileServicesServiceServer
- type FileServicesService_UploadChunkClient
- type FileServicesService_UploadChunkServer
- type UnimplementedFileServicesServiceServer
- type UploadResult
- func (*UploadResult) Descriptor() ([]byte, []int)deprecated
- func (x *UploadResult) GetDuration() int32
- func (x *UploadResult) GetKey() string
- func (x *UploadResult) GetSize() int32
- func (*UploadResult) ProtoMessage()
- func (x *UploadResult) ProtoReflect() protoreflect.Message
- func (x *UploadResult) Reset()
- func (x *UploadResult) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_github_com_metaprov_modelaapi_services_fileservices_v1_fileservices_proto protoreflect.FileDescriptor
Functions ¶
func RegisterFileServicesServiceServer ¶
func RegisterFileServicesServiceServer(s *grpc.Server, srv FileServicesServiceServer)
Types ¶
type DataBlock ¶
type DataBlock struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` Md5Hash string `protobuf:"bytes,3,opt,name=md5_hash,json=md5Hash,proto3" json:"md5_hash,omitempty"` Tenant string `protobuf:"bytes,4,opt,name=tenant,proto3" json:"tenant,omitempty"` DataProductName string `protobuf:"bytes,5,opt,name=dataProductName,proto3" json:"dataProductName,omitempty"` DataProductVersion string `protobuf:"bytes,6,opt,name=dataProductVersion,proto3" json:"dataProductVersion,omitempty"` Bucket string `protobuf:"bytes,7,opt,name=bucket,proto3" json:"bucket,omitempty"` ResourceType string `protobuf:"bytes,8,opt,name=resourceType,proto3" json:"resourceType,omitempty"` ResourceName string `protobuf:"bytes,9,opt,name=resourceName,proto3" json:"resourceName,omitempty"` // contains filtered or unexported fields }
func (*DataBlock) Descriptor
deprecated
func (*DataBlock) GetDataProductName ¶ added in v0.4.497
func (*DataBlock) GetDataProductVersion ¶ added in v0.4.497
func (*DataBlock) GetMd5Hash ¶
func (*DataBlock) GetResourceName ¶ added in v0.4.497
func (*DataBlock) GetResourceType ¶ added in v0.4.497
func (*DataBlock) ProtoMessage ¶
func (*DataBlock) ProtoMessage()
func (*DataBlock) ProtoReflect ¶
func (x *DataBlock) ProtoReflect() protoreflect.Message
type FileServicesServiceClient ¶
type FileServicesServiceClient interface {
UploadChunk(ctx context.Context, opts ...grpc.CallOption) (FileServicesService_UploadChunkClient, error)
}
FileServicesServiceClient is the client API for FileServicesService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewFileServicesServiceClient ¶
func NewFileServicesServiceClient(cc grpc.ClientConnInterface) FileServicesServiceClient
type FileServicesServiceServer ¶
type FileServicesServiceServer interface {
UploadChunk(FileServicesService_UploadChunkServer) error
}
FileServicesServiceServer is the server API for FileServicesService service.
type FileServicesService_UploadChunkClient ¶
type FileServicesService_UploadChunkClient interface { Send(*DataBlock) error CloseAndRecv() (*UploadResult, error) grpc.ClientStream }
type FileServicesService_UploadChunkServer ¶
type FileServicesService_UploadChunkServer interface { SendAndClose(*UploadResult) error Recv() (*DataBlock, error) grpc.ServerStream }
type UnimplementedFileServicesServiceServer ¶
type UnimplementedFileServicesServiceServer struct { }
UnimplementedFileServicesServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedFileServicesServiceServer) UploadChunk ¶
func (*UnimplementedFileServicesServiceServer) UploadChunk(FileServicesService_UploadChunkServer) error
type UploadResult ¶ added in v0.4.519
type UploadResult struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // the key at the destination. Size int32 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` // the total file size uploaded Duration int32 `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"` // the time it took to upload. // contains filtered or unexported fields }
func (*UploadResult) Descriptor
deprecated
added in
v0.4.519
func (*UploadResult) Descriptor() ([]byte, []int)
Deprecated: Use UploadResult.ProtoReflect.Descriptor instead.
func (*UploadResult) GetDuration ¶ added in v0.4.519
func (x *UploadResult) GetDuration() int32
func (*UploadResult) GetKey ¶ added in v0.4.519
func (x *UploadResult) GetKey() string
func (*UploadResult) GetSize ¶ added in v0.4.519
func (x *UploadResult) GetSize() int32
func (*UploadResult) ProtoMessage ¶ added in v0.4.519
func (*UploadResult) ProtoMessage()
func (*UploadResult) ProtoReflect ¶ added in v0.4.519
func (x *UploadResult) ProtoReflect() protoreflect.Message
func (*UploadResult) Reset ¶ added in v0.4.519
func (x *UploadResult) Reset()
func (*UploadResult) String ¶ added in v0.4.519
func (x *UploadResult) String() string
Click to show internal directories.
Click to hide internal directories.