file

package

Go to main page

Versions in this module

v0

v0.12.4

Oct 22, 2024

v0.12.3

Sep 12, 2024

Changes in this version

+ func SetFileDeleteResult(key string, result *rpc.Result)

+ func SubscribeFileDeleteResult(fileHash string) chan *rpc.Result

+ func UnsubscribeFileDeleteResult(key string)

v0.12.2

Aug 2, 2024

v0.12.1

Jun 25, 2024

v0.12.0

May 24, 2024

Changes in this version

+ func CheckRemoteFileDownloadComplete(fileHash, reqid string, fileSize uint64) bool

+ func NextRemoteDownloadPacket(fileHash, reqid string) ([]byte, uint64, uint64, bool)

+ func SetDownloadFileInfo(fileHash string, fileInfo DownloadFile)

+ func SetDownloadSliceResult(fileHash string, result bool)

+ func SetRemoteFileResultWithRetries(key string, result rpc.Result, interval time.Duration, retryTimes int)

+ func SubscribeDownloadSlice(key string) chan bool

+ func SubscribeFileShareResult(shareLink string) chan *rpc.FileShareResult

+ func UnsubscribeDownloadSlice(key string)

+ func UnsubscribeFileShareResult(key string)

+ func UpdateDownloadSlices(fileInfo DownloadFile, reqId string) (updated bool)

+ func WaitDownloadSlice(fileHash, reqId string) bool

+ type DataWithOffset struct

+ Data []byte

+ Offset uint64

+ type DownloadFile struct

+ FileHash string

+ FileName string

+ FileSize uint64

+ Slices []DownloadSlice

+ type DownloadFileSlice struct

+ CurrentSlice *DownloadSlice

+ CurrentSliceOffset uint64

+ SlicesToDownload []*DownloadSlice

+ type DownloadSlice struct

+ Handled bool

+ SliceFileOffset uint64

+ SliceHash string

+ SliceSize uint64

v0.11.9

Jan 4, 2024

v0.11.8

Dec 6, 2023

v0.11.7

Nov 22, 2023

v0.11.6

Nov 9, 2023

v0.11.5

Nov 3, 2023

v0.11.4

Oct 23, 2023

v0.11.3

Oct 5, 2023

v0.11.2

Sep 29, 2023

v0.11.1

Sep 29, 2023

v0.11.0

Sep 27, 2023

Changes in this version

+ const LOCAL_TAG

+ func CheckDownloadCache(fileHash string) error

+ func CopyDownloadFile(fileHash, fileName, savePath string) error

+ func CreateFolderAndReopenFile(folderPath, fileName string) (*os.File, error)

+ func FinishLocalDownload(fileHash string)

+ func GetDownloadFileNameFromTmp(fileHash string) (string, error)

+ func GetDownloadFilePath(fileName, savePath string) string

+ func GetDownloadTmpCsvPath(fileHash, fileName string) string

+ func GetDownloadTmpFilePath(fileHash, fileName string) string

+ func GetFileName(fileHash string) string

+ func GetTmpDownloadPath() string

+ func IsLocalDownload(fileHash string) bool

+ func ReadDownloadCachedData(fileHash, reqid string) ([]byte, uint64, uint64, bool)

+ func SaveDownloadedFileData(data []byte, offset int64, ...) error

+ func StartLocalDownload(fileHash string)

v0.10.1

Aug 30, 2023

Changes in this version

+ const DEFAULT_EXP_THRESHOLD

+ const TMP_FOLDER_VIDEO

+ var DataBuffer sync.Mutex

+ func ReadFileDataToPackets(path string) (size int64, buffer [][]byte, err error)

+ func ReadSliceData(sliceHash string) (int64, [][]byte, error)

+ func ReadSliceDataFromTmp(fileHash, sliceHash string) (int64, [][]byte, error)

+ func RequestBuffersForSlice(size int64) [][]byte

+ func StartClearTmpFileJob(ctx context.Context)

+ func StopClearTmpFileJob()

v0.10.0

Aug 4, 2023

Changes in this version

+ const NUMBER_OF_UPLOAD_CHAN_BUFFER

+ func CacheRemoteFileData(fileHash string, offset *protos.SliceOffset, folderName, fileName string, ...) error

+ func CreateTarWithZstd(source string, target string) error

+ func ExtractTarWithZstd(source string, target string) error

+ func GetClearExpiredShareLinksResult(key string) (*rpc.ClearExpiredShareLinksResult, bool)

+ func GetFileHashForVideoStream(filePath, encryptionTag string) string

+ func GetTmpFileFolderPath(fileHash string) string

+ func GetTmpSlicePath(fileHash, sliceHash string) string

+ func OpenTmpFile(fileHash, fileName string) (*os.File, error)

+ func RenameTmpFile(fileHash, srcFile, dstFile string) error

+ func SaveRemoteFileSliceData(sliceKey, fileKey, fileName string, data []byte, offset uint64) error

+ func SaveRemoteSliceData(key, fileName string, data []byte, offset uint64) error

+ func SetClearExpiredShareLinksResult(key string, result *rpc.ClearExpiredShareLinksResult)

+ func SetGetFileStatusDone(key string, result *rpc.FileStatusResult)

+ func SetRemoteSliceResult(key string, result rpc.Result)

+ func SubscribeGetFileStatusDone(key string) chan *rpc.FileStatusResult

+ func SubscribeRemoteSliceEvent(key string) chan *rpc.Result

+ func UnsubscribeGetFileStatusDone(key string)

+ func UnsubscribeRemoteSliceEvent(key string)

+ func WriteFile(data []byte, offset int64, fileMg *os.File) error

type HlsInfo

+ func LoadHlsInfoFromData(data []byte) (*HlsInfo, error)

v0.9.0

Jan 17, 2023

Changes in this version

+ var RpcWaitTimeout time.Duration

+ func CleanFileHash(key string)

+ func CloseDownloadSession(key string)

+ func GetFileListResult(key string) (*rpc.FileListResult, bool)

+ func GetFileShareResult(key string) (*rpc.FileShareResult, bool)

+ func GetQueryOzoneResult(key string) (*rpc.GetOzoneResult, bool)

+ func GetRemoteFileData(hash string, offset *protos.SliceOffset) []byte

+ func GetRemoteFileInfo(key, reqId string) uint64

+ func GetRemoteFileSize(hash string) uint64

+ func GetSignatureFromRemote(key string) []byte

+ func IsFileRpcRemote(key string) bool

+ func SaveRemoteFileData(key string, data []byte, offset uint64) bool

+ func SaveRemoteFileHash(hash, fileName string, fileSize uint64)

+ func SendFileDataBack(hash string, content []byte)

+ func SetDownloadSliceDone(key string)

+ func SetFileListResult(key string, result *rpc.FileListResult)

+ func SetFileShareResult(key string, result *rpc.FileShareResult)

+ func SetQueryOzoneResult(key string, result *rpc.GetOzoneResult)

+ func SetRemoteFileInfo(key string, size uint64)

+ func SetRemoteFileResult(key string, result rpc.Result)

+ func SetSignature(key string, sig []byte)

+ func SubscribeDownloadFileInfo(key string) chan uint64

+ func SubscribeDownloadSliceDone(key string) chan bool

+ func SubscribeGetRemoteFileData(key string) chan []byte

+ func SubscribeGetSignature(key string) chan []byte

+ func SubscribeRemoteFileEvent(key string) chan *rpc.Result

+ func UnsubscribeDownloadFileInfo(key string)

+ func UnsubscribeDownloadSliceDone(key string)

+ func UnsubscribeGetRemoteFileData(key string)

+ func UnsubscribeGetSignature(key string)

+ func UnsubscribeRemoteFileEvent(key string)

+ func WaitDownloadSliceDone(key string) bool

v0.8.1

Jul 26, 2022

v0.8.0

Jul 22, 2022

Changes in this version

+ func DeleteTmpFileSlices(fileHash string)

+ func DeleteTmpHlsFolder(fileHash string)

+ func GetSliceDataFromTmp(fileHash, sliceHash string) []byte

+ func SaveTmpSliceData(fileHash, sliceHash string, data []byte) bool

v0.7.0

Apr 19, 2022

v0.6.0

Mar 21, 2022

v0.5.1

Mar 4, 2022

v0.5.0

Feb 22, 2022

v0.3.0

Oct 17, 2021

Changes in this version

+ const HLS_HEADER_FILENAME

+ const HLS_SEGMENT_FILENAME

+ const TEMP_FOLDER

+ var HlsInfoMap = make(map[string]*HlsInfo)

+ func CheckFileExisting(fileHash, fileName, savePath string) bool

+ func CheckFilePathEx(fileHash, fileName, savePath string) bool

+ func CheckSliceExisting(fileHash, fileName, sliceHash, savePath string) bool

+ func ClearFileMap(hash string)

+ func DeleteDirectory(fileHash string)

+ func DeleteSlice(sliceHash string) error

+ func EscapePath(param []string) string

+ func GetAllFiles(pathname string)

+ func GetDownloadCsvPath(fileHash, fileName, savePath string) string

+ func GetDownloadPath(fileName string) string

+ func GetDownloadTmpPath(fileHash, fileName, savePath string) string

+ func GetDumpySliceData(fileHash string, sliceNumber uint64) []byte

+ func GetFileData(filePath string, offset *protos.SliceOffset) []byte

+ func GetFileHash(filePath string) string

+ func GetFileInfo(filePath string) os.FileInfo

+ func GetFilePath(hash string) string

+ func GetFileSuffix(fileName string) string

+ func GetSliceData(sliceHash string) []byte

+ func GetSliceSize(sliceHash string) int64

+ func GetVideoDuration(path string) (uint64, error)

+ func GetVideoTmpFolder(fileHash string) string

+ func GetWholeFileData(filePath string) []byte

+ func IsFile(f string) (bool, error)

+ func PathExists(path string) (bool, error)

+ func RecordDownloadCSV(target *protos.RspFileStorageInfo)

+ func SaveDownloadProgress(sliceHash, fileName, fileHash, savePath string)

+ func SaveFileData(data []byte, offset int64, sliceHash, fileName, fileHash, savePath string) bool

+ func SaveSliceData(data []byte, sliceHash string, offset uint64) bool

+ func VideoToHls(fileHash string) bool

+ type HlsInfo struct

+ FileHash string

+ HeaderFile string

+ SegmentToSlice map[string]uint64

+ SliceToSegment map[uint64]string

+ StartSliceNumber uint64

+ TotalSize int64

+ func GetHlsInfo(fileHash string, maxSliceCount uint64) (*HlsInfo, error)

+ func LoadHlsInfo(fileHash, sliceHash, savePath string) *HlsInfo

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL