v1

package
v0.5.352 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 7, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FileServicesService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.fileservices.v1.FileServicesService",
	HandlerType: (*FileServicesServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "UploadChunk",
			Handler:       _FileServicesService_UploadChunk_Handler,
			ClientStreams: true,
		},
	},
	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)

View Source 
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 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) Descriptor() ([]byte, []int)

Deprecated: Use DataBlock.ProtoReflect.Descriptor instead.

func (*DataBlock) GetBucket added in v0.4.497 

func (x *DataBlock) GetBucket() string

func (*DataBlock) GetData 

func (x *DataBlock) GetData() []byte

func (*DataBlock) GetDataProductName added in v0.4.497 

func (x *DataBlock) GetDataProductName() string

func (*DataBlock) GetDataProductVersion added in v0.4.497 

func (x *DataBlock) GetDataProductVersion() string

func (*DataBlock) GetMd5Hash 

func (x *DataBlock) GetMd5Hash() string

func (*DataBlock) GetName 

func (x *DataBlock) GetName() string

func (*DataBlock) GetResourceName added in v0.4.497 

func (x *DataBlock) GetResourceName() string

func (*DataBlock) GetResourceType added in v0.4.497 

func (x *DataBlock) GetResourceType() string

func (*DataBlock) GetTenant added in v0.4.497 

func (x *DataBlock) GetTenant() string

func (*DataBlock) ProtoMessage 

func (*DataBlock) ProtoMessage()

func (*DataBlock) ProtoReflect 

func (x *DataBlock) ProtoReflect() protoreflect.Message

func (*DataBlock) Reset 

func (x *DataBlock) Reset()

func (*DataBlock) String 

func (x *DataBlock) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFileServicesServiceClient 

func NewFileServicesServiceClient(cc grpc.ClientConnInterface) FileServicesServiceClient

type FileServicesServiceServer 

type FileServicesServiceServer interface {
	UploadChunk(FileServicesService_UploadChunkServer) error
	// contains filtered or unexported methods
}

FileServicesServiceServer is the server API for FileServicesService service. All implementations must embed UnimplementedFileServicesServiceServer for forward compatibility

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 must be embedded to have forward compatible implementations.

func (UnimplementedFileServicesServiceServer) UploadChunk 

func (UnimplementedFileServicesServiceServer) UploadChunk(FileServicesService_UploadChunkServer) 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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.