worker

Documentation

Index

• func CacheCleanUp(ctx context.Context)
• func GetSyncUploadStatus() (string, error)
• func SetupWorkers(ctx context.Context)
• func StartSyncUpload(...) error
• func StopSyncUpload()
• type StatusCallback
  • func NewStatusCallback() *StatusCallback
  • func (s *StatusCallback) CommitMetaCompleted(request, response string, err error)
  • func (s *StatusCallback) Completed(allocationId, filePath string, filename string, mimetype string, size int, ...)
  • func (s *StatusCallback) Error(allocationID string, filePath string, op int, err error)
  • func (s *StatusCallback) InProgress(allocationId, filePath string, op int, completedBytes int, data []byte)
  • func (s *StatusCallback) RepairCompleted(filesRepaired int)
  • func (s *StatusCallback) Started(allocationId, filePath string, op int, totalBytes int)

Functions

func CacheCleanUp

func CacheCleanUp(ctx context.Context)

func GetSyncUploadStatus

func GetSyncUploadStatus() (string, error)

GetSyncUploadStatus get logs from sync upload worker if it is running

func SetupWorkers

func SetupWorkers(ctx context.Context)

func StartSyncUpload

func StartSyncUpload(clientJSON, allocation, fileName, remotePath, feed, fileAttrs, downloaderArgs, ffmpegArgs string, delay int, encrypt bool) error

StartSyncUpload start sync upload worker

func StopSyncUpload

func StopSyncUpload()

StopSyncUpload stop sync upload worker if it is running

Types

type StatusCallback

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

func NewStatusCallback

func NewStatusCallback() *StatusCallback

func (*StatusCallback) CommitMetaCompleted

func (s *StatusCallback) CommitMetaCompleted(request, response string, err error)

func (*StatusCallback) Completed

func (s *StatusCallback) Completed(allocationId, filePath string, filename string, mimetype string, size int, op int)

func (*StatusCallback) Error

func (s *StatusCallback) Error(allocationID string, filePath string, op int, err error)

func (*StatusCallback) InProgress

func (s *StatusCallback) InProgress(allocationId, filePath string, op int, completedBytes int, data []byte)

0 / 70538713 [-------------------------------------------------------------------------------------------------------------] 0.00%

func (*StatusCallback) RepairCompleted

func (s *StatusCallback) RepairCompleted(filesRepaired int)

func (*StatusCallback) Started

func (s *StatusCallback) Started(allocationId, filePath string, op int, totalBytes int)