Documentation
¶
Index ¶
- Variables
- func RegisterFileServicesServiceServer(s grpc.ServiceRegistrar, srv FileServicesServiceServer)
- type FileServicesServiceClient
- type FileServicesServiceServer
- type InitiateUploadRequest
- func (*InitiateUploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitiateUploadRequest) GetLocation() *Location
- func (x *InitiateUploadRequest) GetSize() int32
- func (*InitiateUploadRequest) ProtoMessage()
- func (x *InitiateUploadRequest) ProtoReflect() protoreflect.Message
- func (x *InitiateUploadRequest) Reset()
- func (x *InitiateUploadRequest) String() string
- type InitiateUploadResponse
- func (*InitiateUploadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InitiateUploadResponse) GetChunkSize() int32
- func (x *InitiateUploadResponse) GetToken() string
- func (*InitiateUploadResponse) ProtoMessage()
- func (x *InitiateUploadResponse) ProtoReflect() protoreflect.Message
- func (x *InitiateUploadResponse) Reset()
- func (x *InitiateUploadResponse) String() string
- type Location
- func (*Location) Descriptor() ([]byte, []int)deprecated
- func (x *Location) GetBucket() string
- func (x *Location) GetDataProduct() string
- func (x *Location) GetFileName() string
- func (x *Location) GetResourceKind() string
- func (x *Location) GetResourceName() string
- func (x *Location) GetTenant() string
- func (*Location) ProtoMessage()
- func (x *Location) ProtoReflect() protoreflect.Message
- func (x *Location) Reset()
- func (x *Location) String() string
- type UnimplementedFileServicesServiceServer
- type UnsafeFileServicesServiceServer
- type UploadRequest
- func (*UploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadRequest) GetData() []byte
- func (x *UploadRequest) GetToken() string
- func (*UploadRequest) ProtoMessage()
- func (x *UploadRequest) ProtoReflect() protoreflect.Message
- func (x *UploadRequest) Reset()
- func (x *UploadRequest) String() string
- type UploadResponse
Constants ¶
This section is empty.
Variables ¶
var FileServicesService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "github.com.metaprov.modelaapi.services.fileservices.v1.FileServicesService", HandlerType: (*FileServicesServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InitiateUpload", Handler: _FileServicesService_InitiateUpload_Handler, }, { MethodName: "Upload", Handler: _FileServicesService_Upload_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/metaprov/modelaapi/services/fileservices/v1/fileservices.proto", }
FileServicesService_ServiceDesc is the grpc.ServiceDesc for FileServicesService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_github_com_metaprov_modelaapi_services_fileservices_v1_fileservices_proto protoreflect.FileDescriptor
Functions ¶
func RegisterFileServicesServiceServer ¶
func RegisterFileServicesServiceServer(s grpc.ServiceRegistrar, srv FileServicesServiceServer)
Types ¶
type FileServicesServiceClient ¶
type FileServicesServiceClient interface { InitiateUpload(ctx context.Context, in *InitiateUploadRequest, opts ...grpc.CallOption) (*InitiateUploadResponse, error) Upload(ctx context.Context, in *UploadRequest, opts ...grpc.CallOption) (*UploadResponse, error) }
FileServicesServiceClient is the client API for FileServicesService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewFileServicesServiceClient ¶
func NewFileServicesServiceClient(cc grpc.ClientConnInterface) FileServicesServiceClient
type FileServicesServiceServer ¶
type FileServicesServiceServer interface { InitiateUpload(context.Context, *InitiateUploadRequest) (*InitiateUploadResponse, error) Upload(context.Context, *UploadRequest) (*UploadResponse, error) // contains filtered or unexported methods }
FileServicesServiceServer is the server API for FileServicesService service. All implementations must embed UnimplementedFileServicesServiceServer for forward compatibility
type InitiateUploadRequest ¶ added in v0.6.310
type InitiateUploadRequest struct { Size int32 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"` Location *Location `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"` // contains filtered or unexported fields }
func (*InitiateUploadRequest) Descriptor
deprecated
added in
v0.6.310
func (*InitiateUploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitiateUploadRequest.ProtoReflect.Descriptor instead.
func (*InitiateUploadRequest) GetLocation ¶ added in v0.6.310
func (x *InitiateUploadRequest) GetLocation() *Location
func (*InitiateUploadRequest) GetSize ¶ added in v0.6.310
func (x *InitiateUploadRequest) GetSize() int32
func (*InitiateUploadRequest) ProtoMessage ¶ added in v0.6.310
func (*InitiateUploadRequest) ProtoMessage()
func (*InitiateUploadRequest) ProtoReflect ¶ added in v0.6.310
func (x *InitiateUploadRequest) ProtoReflect() protoreflect.Message
func (*InitiateUploadRequest) Reset ¶ added in v0.6.310
func (x *InitiateUploadRequest) Reset()
func (*InitiateUploadRequest) String ¶ added in v0.6.310
func (x *InitiateUploadRequest) String() string
type InitiateUploadResponse ¶ added in v0.6.310
type InitiateUploadResponse struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` ChunkSize int32 `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"` // contains filtered or unexported fields }
func (*InitiateUploadResponse) Descriptor
deprecated
added in
v0.6.310
func (*InitiateUploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitiateUploadResponse.ProtoReflect.Descriptor instead.
func (*InitiateUploadResponse) GetChunkSize ¶ added in v0.6.310
func (x *InitiateUploadResponse) GetChunkSize() int32
func (*InitiateUploadResponse) GetToken ¶ added in v0.6.310
func (x *InitiateUploadResponse) GetToken() string
func (*InitiateUploadResponse) ProtoMessage ¶ added in v0.6.310
func (*InitiateUploadResponse) ProtoMessage()
func (*InitiateUploadResponse) ProtoReflect ¶ added in v0.6.310
func (x *InitiateUploadResponse) ProtoReflect() protoreflect.Message
func (*InitiateUploadResponse) Reset ¶ added in v0.6.310
func (x *InitiateUploadResponse) Reset()
func (*InitiateUploadResponse) String ¶ added in v0.6.310
func (x *InitiateUploadResponse) String() string
type Location ¶ added in v0.6.310
type Location struct { Tenant string `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"` DataProduct string `protobuf:"bytes,2,opt,name=dataProduct,proto3" json:"dataProduct,omitempty"` ResourceKind string `protobuf:"bytes,3,opt,name=resourceKind,proto3" json:"resourceKind,omitempty"` ResourceName string `protobuf:"bytes,4,opt,name=resourceName,proto3" json:"resourceName,omitempty"` FileName string `protobuf:"bytes,5,opt,name=fileName,proto3" json:"fileName,omitempty"` Bucket string `protobuf:"bytes,6,opt,name=bucket,proto3" json:"bucket,omitempty"` // contains filtered or unexported fields }
func (*Location) Descriptor
deprecated
added in
v0.6.310
func (*Location) GetDataProduct ¶ added in v0.6.310
func (*Location) GetFileName ¶ added in v0.6.310
func (*Location) GetResourceKind ¶ added in v0.6.310
func (*Location) GetResourceName ¶ added in v0.6.310
func (*Location) ProtoMessage ¶ added in v0.6.310
func (*Location) ProtoMessage()
func (*Location) ProtoReflect ¶ added in v0.6.310
func (x *Location) ProtoReflect() protoreflect.Message
type UnimplementedFileServicesServiceServer ¶
type UnimplementedFileServicesServiceServer struct { }
UnimplementedFileServicesServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedFileServicesServiceServer) InitiateUpload ¶ added in v0.6.310
func (UnimplementedFileServicesServiceServer) InitiateUpload(context.Context, *InitiateUploadRequest) (*InitiateUploadResponse, error)
func (UnimplementedFileServicesServiceServer) Upload ¶ added in v0.6.310
func (UnimplementedFileServicesServiceServer) Upload(context.Context, *UploadRequest) (*UploadResponse, error)
type UnsafeFileServicesServiceServer ¶ added in v0.4.687
type UnsafeFileServicesServiceServer interface {
// contains filtered or unexported methods
}
UnsafeFileServicesServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FileServicesServiceServer will result in compilation errors.
type UploadRequest ¶ added in v0.6.310
type UploadRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*UploadRequest) Descriptor
deprecated
added in
v0.6.310
func (*UploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.
func (*UploadRequest) GetData ¶ added in v0.6.310
func (x *UploadRequest) GetData() []byte
func (*UploadRequest) GetToken ¶ added in v0.6.310
func (x *UploadRequest) GetToken() string
func (*UploadRequest) ProtoMessage ¶ added in v0.6.310
func (*UploadRequest) ProtoMessage()
func (*UploadRequest) ProtoReflect ¶ added in v0.6.310
func (x *UploadRequest) ProtoReflect() protoreflect.Message
func (*UploadRequest) Reset ¶ added in v0.6.310
func (x *UploadRequest) Reset()
func (*UploadRequest) String ¶ added in v0.6.310
func (x *UploadRequest) String() string
type UploadResponse ¶ added in v0.6.310
type UploadResponse struct { Complete bool `protobuf:"varint,1,opt,name=complete,proto3" json:"complete,omitempty"` // contains filtered or unexported fields }
func (*UploadResponse) Descriptor
deprecated
added in
v0.6.310
func (*UploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.
func (*UploadResponse) GetComplete ¶ added in v0.6.310
func (x *UploadResponse) GetComplete() bool
func (*UploadResponse) ProtoMessage ¶ added in v0.6.310
func (*UploadResponse) ProtoMessage()
func (*UploadResponse) ProtoReflect ¶ added in v0.6.310
func (x *UploadResponse) ProtoReflect() protoreflect.Message
func (*UploadResponse) Reset ¶ added in v0.6.310
func (x *UploadResponse) Reset()
func (*UploadResponse) String ¶ added in v0.6.310
func (x *UploadResponse) String() string