fileservice

Documentation

Index

• type FileService
  • func New(fileRepo repoiface.FileRepository, minio repoiface.MinioRepository, ...) *FileService
  • func (s *FileService) CheckFileExistedAndGetFile(ctx context.Context, fileCtx *api.FileContext) (int64, bool, error)
  • func (s *FileService) GetInfoById(ctx context.Context, domainName, bizName string, fileId int64) (*file.File, error)
  • func (s *FileService) GetProgressRate4SlicingPut(ctx context.Context, uploadId string, fileCtx *api.FileContext) (map[string]bool, error)
  • func (s *FileService) MergeFileParts(ctx context.Context, uploadId string, fileCtx *api.FileContext) error
  • func (s *FileService) PreSignGet(ctx context.Context, fileCtx *api.FileContext) (string, error)
  • func (s *FileService) PreSignPut(ctx context.Context, fileCtx *api.FileContext) (string, int64, error)
  • func (s *FileService) PreSignSlicingPut(ctx context.Context, fileCtx *api.FileContext) (*slicingfile.SlicingFile, error)
  • func (s *FileService) RemoveFile(ctx context.Context, fileCtx *api.FileContext) error
  • func (s *FileService) ReportUploaded(ctx context.Context, fileCtx *api.FileContext) error

Types

type FileService

type FileService struct {
	// contains filtered or unexported fields
}

func New

func New(fileRepo repoiface.FileRepository, minio repoiface.MinioRepository, config filerepohelper.FileTableShardingConfig) *FileService

func (*FileService) CheckFileExistedAndGetFile

func (s *FileService) CheckFileExistedAndGetFile(ctx context.Context, fileCtx *api.FileContext) (int64, bool, error)

func (*FileService) GetInfoById

func (s *FileService) GetInfoById(ctx context.Context, domainName, bizName string, fileId int64) (*file.File, error)

func (*FileService) GetProgressRate4SlicingPut

func (s *FileService) GetProgressRate4SlicingPut(ctx context.Context, uploadId string, fileCtx *api.FileContext) (map[string]bool, error)

func (*FileService) MergeFileParts

func (s *FileService) MergeFileParts(ctx context.Context, uploadId string, fileCtx *api.FileContext) error

func (*FileService) PreSignGet

func (s *FileService) PreSignGet(ctx context.Context, fileCtx *api.FileContext) (string, error)

func (*FileService) PreSignPut

func (s *FileService) PreSignPut(ctx context.Context, fileCtx *api.FileContext) (string, int64, error)

func (*FileService) PreSignSlicingPut

func (s *FileService) PreSignSlicingPut(ctx context.Context, fileCtx *api.FileContext) (*slicingfile.SlicingFile, error)

func (*FileService) RemoveFile

func (s *FileService) RemoveFile(ctx context.Context, fileCtx *api.FileContext) error

func (*FileService) ReportUploaded

func (s *FileService) ReportUploaded(ctx context.Context, fileCtx *api.FileContext) error