service

Documentation

Index

• type File
  • func NewFile() *File
  • func (f *File) Close() error
  • func (f *File) SetFile(fileName, path string) error
  • func (f *File) Write(chunk []byte) error
• type FileServiceServer
  • func New(l *logger.Logger, cfg *config.Config) *FileServiceServer
  • func (g *FileServiceServer) BucketFileHashes(ctx context.Context, req *pb.BucketFileHashesRequest) (*pb.BucketFileHashesResponse, error)
  • func (g *FileServiceServer) Download(req *pb.FileDownloadRequest, server pb.FileService_DownloadServer) error
  • func (g *FileServiceServer) Upload(stream pb.FileService_UploadServer) error

Types

type File

type File struct {
	FilePath string

	OutputFile *os.File
	// contains filtered or unexported fields
}

func NewFile

func NewFile() *File

func (*File) Close

func (f *File) Close() error

func (*File) SetFile

func (f *File) SetFile(fileName, path string) error

func (*File) Write

func (f *File) Write(chunk []byte) error

type FileServiceServer

type FileServiceServer struct {
	pb.UnimplementedFileServiceServer
	// contains filtered or unexported fields
}

Execution context of the service

func New

func New(l *logger.Logger, cfg *config.Config) *FileServiceServer

Init the service execution context

func (*FileServiceServer) BucketFileHashes

func (g *FileServiceServer) BucketFileHashes(ctx context.Context, req *pb.BucketFileHashesRequest) (*pb.BucketFileHashesResponse, error)

Handle the request for retrieving the file hashes of a given storage bucket

func (*FileServiceServer) Download

func (g *FileServiceServer) Download(req *pb.FileDownloadRequest, server pb.FileService_DownloadServer) error

Handle a request for a file download

func (*FileServiceServer) Upload

func (g *FileServiceServer) Upload(stream pb.FileService_UploadServer) error

Handler of file upload requests Manages large files upload by supporting the streaming of data chunks