syncdrive

Mar 23, 2025

Changes in this version

type SyncTaskManager

+ func (m *SyncTaskManager) DoTaskSyncCompletelyPluginCallback()

Sep 21, 2024

Changes in this version

type SyncTask

+ ScanTimeInterval int64

Apr 21, 2024

Changes in this version

+ const Download

+ const SyncPolicyExclusive

+ const SyncPolicyIncrement

+ const Upload

+ type SyncPolicy string

type SyncTask

+ Policy SyncPolicy

+ func (t *SyncTask) IsTaskCompletely() bool

type SyncTaskManager

+ func (m *SyncTaskManager) IsAllTaskCompletely() bool

Mar 17, 2024

Changes in this version

+ const CycleInfiniteLoop

+ const CycleOneTime

+ func GetLocalFileFullPathFromPanPath(panFilePath, localRootPath, panRootPath string) string

+ func GetPanFileFullPathFromLocalPath(localFilePath, localRootPath, panRootPath string) string

+ func IsSymlinkFile(file fs.FileInfo) bool

+ func PromptPrint(msg string)

+ func PromptPrintln(msg string)

+ type CycleMode string

type FileActionTaskManager

+ func (f *FileActionTaskManager) InitMgr() error

+ func (f *FileActionTaskManager) IsExecuteLoopIsDone() bool

+ func (f *FileActionTaskManager) StartFileActionTaskExecutor() error

type SyncTask

+ CycleModeType CycleMode

+ DriveName string

+ func (t *SyncTask) IsScanLoopDone() bool

+ func (t *SyncTask) SetScanLoopFlag(done bool)

Jan 1, 2023

Changes in this version

type SyncOption

+ FileRecorder *log.FileRecorder

Dec 7, 2022

Changes in this version

type SyncTask

+ UserId string

Sep 29, 2022

Changes in this version

+ const StepDiffFile

+ const StepScanFile

+ const StepSyncFile

type LocalFileItem

+ func (item *LocalFileItem) IsFile() bool

type SyncOption

+ LocalFileModifiedCheckIntervalSec int

type SyncTask

+ func (t *SyncTask) WaitToStop() error

+ type TaskStep string

Aug 13, 2022

Changes in this version

+ const SyncPriorityLocalFirst

+ const SyncPriorityPanFirst

+ const SyncPriorityTimestampFirst

+ var LogPrompt = false

+ type SyncOption struct

+ FileDownloadBlockSize int64

+ FileDownloadParallel int

+ FileUploadBlockSize int64

+ FileUploadParallel int

+ MaxDownloadRate int64

+ MaxUploadRate int64

+ SyncPriority SyncPriorityOption

+ UseInternalUrl bool

+ type SyncPriorityOption string

type SyncTask

+ Priority SyncPriorityOption

Jul 3, 2022

Changes in this version

+ const SyncFileActionCreateLocalFolder

+ const SyncFileActionCreatePanFolder

Jun 26, 2022

Changes in this version

type FileActionTaskManager

+ func (f *FileActionTaskManager) AddLocalFolderModifyCount()

+ func (f *FileActionTaskManager) AddPanFolderModifyCount()

+ func (f *FileActionTaskManager) AddSyncActionModifyCount()

+ func (f *FileActionTaskManager) MinusLocalFolderModifyCount()

+ func (f *FileActionTaskManager) MinusPanFolderModifyCount()

+ func (f *FileActionTaskManager) MinusSyncActionModifyCount()

Jun 18, 2022

Changes in this version

+ const DirBucketPrefix

+ const DownloadingFileSuffix

+ const ScanStatusDiscard

+ const ScanStatusNormal

+ const SyncFileActionDeleteLocal

+ const SyncFileActionDeletePan

+ const SyncFileActionDownload

+ const SyncFileActionUpload

+ const SyncFileStatusCreate

+ const SyncFileStatusDownloading

+ const SyncFileStatusFailed

+ const SyncFileStatusIllegal

+ const SyncFileStatusNotExisted

+ const SyncFileStatusSuccess

+ const SyncFileStatusUploading

+ const TimeSecondsOf10Minute

+ const TimeSecondsOf2Minute

+ const TimeSecondsOf30Minute

+ const TimeSecondsOf30Seconds

+ const TimeSecondsOf5Minute

+ const TimeSecondsOf60Minute

+ const TimeSecondsOfOneMinute

+ var ErrItemNotExisted error = fmt.Errorf("item is not existed")

+ var ErrSyncTaskListEmpty error = fmt.Errorf("no sync task")

+ func FormatFilePath(filePath string) string

+ type BoltDb struct

+ Path string

+ func NewBoltDb(dbFilePath string) *BoltDb

+ func (b *BoltDb) Add(item *BoltItem) (bool, error)

+ func (b *BoltDb) AddItems(items []*BoltItem) (bool, error)

+ func (b *BoltDb) Close() (bool, error)

+ func (b *BoltDb) Delete(filePath string) (bool, error)

+ func (b *BoltDb) Get(filePath string) (string, error)

+ func (b *BoltDb) GetFileList(filePath string) ([]string, error)

+ func (b *BoltDb) Open() (bool, error)

+ func (b *BoltDb) Update(filePath string, data string) (bool, error)

+ type BoltItem struct

+ Data string

+ FilePath string

+ IsFolder bool

+ type FileAction string

+ type FileActionTask struct

+ func (f *FileActionTask) DoAction(ctx context.Context) error

+ func (f *FileActionTask) HashCode() string

+ type FileActionTaskList []*FileActionTask

+ type FileActionTaskManager struct

+ func NewFileActionTaskManager(task *SyncTask, maxDownloadRate, maxUploadRate int64) *FileActionTaskManager

+ func (f *FileActionTaskManager) Start() error

+ func (f *FileActionTaskManager) Stop() error

+ type LocalFileItem struct

+ CreatedAt string

+ FileExtension string

+ FileName string

+ FileSize int64

+ FileType string

+ Path string

+ ScanStatus ScanStatus

+ ScanTimeAt string

+ Sha1Hash string

+ UpdatedAt string

+ func (item *LocalFileItem) FormatFileName() string

+ func (item *LocalFileItem) FormatFilePath() string

+ func (item *LocalFileItem) HashCode() string

+ func (item *LocalFileItem) Id() string

+ func (item *LocalFileItem) IsFolder() bool

+ func (item *LocalFileItem) ScanTime() time.Time

+ func (item *LocalFileItem) ScanTimeUnix() int64

+ func (item *LocalFileItem) UpdateTime() time.Time

+ func (item *LocalFileItem) UpdateTimeUnix() int64

+ type LocalFileList []*LocalFileItem

+ func (l LocalFileList) FindFileByPath(filePath string) *LocalFileItem

+ type LocalSyncDb interface

+ Add func(item *LocalFileItem) (bool, error)

+ AddFileList func(items LocalFileList) (bool, error)

+ Close func() (bool, error)

+ Delete func(filePath string) (bool, error)

+ Get func(filePath string) (*LocalFileItem, error)

+ GetFileList func(filePath string) (LocalFileList, error)

+ Open func() (bool, error)

+ Update func(item *LocalFileItem) (bool, error)

+ func NewLocalSyncDb(dbFilePath string) LocalSyncDb

+ type LocalSyncDbBolt struct

+ Path string

+ func (p *LocalSyncDbBolt) Add(item *LocalFileItem) (bool, error)

+ func (p *LocalSyncDbBolt) AddFileList(items LocalFileList) (bool, error)

+ func (p *LocalSyncDbBolt) Close() (bool, error)

+ func (p *LocalSyncDbBolt) Delete(filePath string) (bool, error)

+ func (p *LocalSyncDbBolt) Get(filePath string) (*LocalFileItem, error)

+ func (p *LocalSyncDbBolt) GetFileList(filePath string) (LocalFileList, error)

+ func (p *LocalSyncDbBolt) Open() (bool, error)

+ func (p *LocalSyncDbBolt) Update(item *LocalFileItem) (bool, error)

+ type PanFileItem struct

+ Category string

+ Crc64Hash string

+ CreatedAt string

+ DomainId string

+ DriveId string

+ FileExtension string

+ FileId string

+ FileName string

+ FileSize int64

+ FileType string

+ ParentFileId string

+ Path string

+ ScanStatus ScanStatus

+ ScanTimeAt string

+ Sha1Hash string

+ UpdatedAt string

+ UploadId string

+ func NewPanFileItem(fe *aliyunpan.FileEntity) *PanFileItem

+ func (item *PanFileItem) FormatFileName() string

+ func (item *PanFileItem) FormatFilePath() string

+ func (item *PanFileItem) HashCode() string

+ func (item *PanFileItem) Id() string

+ func (item *PanFileItem) IsFolder() bool

+ func (item *PanFileItem) ScanTime() time.Time

+ func (item *PanFileItem) ScanTimeUnix() int64

+ func (item *PanFileItem) UpdateTime() time.Time

+ func (item *PanFileItem) UpdateTimeUnix() int64

+ type PanFileList []*PanFileItem

+ func (p PanFileList) FindFileByPath(filePath string) *PanFileItem

+ type PanSyncDb interface

+ Add func(item *PanFileItem) (bool, error)

+ AddFileList func(items PanFileList) (bool, error)

+ Close func() (bool, error)

+ Delete func(filePath string) (bool, error)

+ Get func(filePath string) (*PanFileItem, error)

+ GetFileList func(filePath string) (PanFileList, error)

+ Open func() (bool, error)

+ Update func(item *PanFileItem) (bool, error)

+ func NewPanSyncDb(dbFilePath string) PanSyncDb

+ type PanSyncDbBolt struct

+ Path string

+ func (p *PanSyncDbBolt) Add(item *PanFileItem) (bool, error)

+ func (p *PanSyncDbBolt) AddFileList(items PanFileList) (bool, error)

+ func (p *PanSyncDbBolt) Close() (bool, error)

+ func (p *PanSyncDbBolt) Delete(filePath string) (bool, error)

+ func (p *PanSyncDbBolt) Get(filePath string) (*PanFileItem, error)

+ func (p *PanSyncDbBolt) GetFileList(filePath string) (PanFileList, error)

+ func (p *PanSyncDbBolt) Open() (bool, error)

+ func (p *PanSyncDbBolt) Update(item *PanFileItem) (bool, error)

+ type ScanStatus string

+ type SyncDriveConfig struct

+ ConfigVer string

+ SyncTaskList []*SyncTask

+ type SyncFileAction string

+ type SyncFileDb interface

+ Add func(item *SyncFileItem) (bool, error)

+ Close func() (bool, error)

+ Delete func(id string) (bool, error)

+ Get func(id string) (*SyncFileItem, error)

+ GetFileList func(Status SyncFileStatus) (SyncFileList, error)

+ Open func() (bool, error)

+ Update func(item *SyncFileItem) (bool, error)

+ func NewSyncFileDb(dbFilePath string) SyncFileDb

+ type SyncFileDbBolt struct

+ Path string

+ func (s *SyncFileDbBolt) Add(item *SyncFileItem) (bool, error)

+ func (s *SyncFileDbBolt) Close() (bool, error)

+ func (s *SyncFileDbBolt) Delete(id string) (bool, error)

+ func (s *SyncFileDbBolt) Get(id string) (*SyncFileItem, error)

+ func (s *SyncFileDbBolt) GetFileList(Status SyncFileStatus) (SyncFileList, error)

+ func (s *SyncFileDbBolt) Open() (bool, error)

+ func (s *SyncFileDbBolt) Update(item *SyncFileItem) (bool, error)

+ type SyncFileItem struct

+ Action SyncFileAction

+ DownloadBlockSize int64

+ DownloadRange *transfer.Range

+ DriveId string

+ LocalFile *LocalFileItem

+ LocalFolderPath string

+ PanFile *PanFileItem

+ PanFolderPath string

+ Status SyncFileStatus

+ StatusUpdateTime string

+ UploadBlockSize int64

+ UploadEntity *aliyunpan.CreateFileUploadResult

+ UploadPartSeq int

+ UploadRange *transfer.Range

+ UseInternalUrl bool

+ func (item *SyncFileItem) HashCode() string

+ func (item *SyncFileItem) Id() string

+ func (item *SyncFileItem) StatusUpdateTimeUnix() int64

+ func (item *SyncFileItem) String() string

+ type SyncFileList []*SyncFileItem

+ type SyncFileStatus string

+ type SyncMode string

+ const DownloadOnly

+ const SyncTwoWay

+ const UploadOnly

+ type SyncTask struct

+ DriveId string

+ Id string

+ LastSyncTime string

+ LocalFolderPath string

+ Mode SyncMode

+ Name string

+ PanFolderPath string

+ func (t *SyncTask) NameLabel() string

+ func (t *SyncTask) Start() error

+ func (t *SyncTask) Stop() error

+ func (t *SyncTask) String() string

+ type SyncTaskManager struct

+ DriveId string

+ PanClient *aliyunpan.PanClient

+ PanUser *config.PanUser

+ SyncConfigFolderPath string

+ func NewSyncTaskManager(user *config.PanUser, driveId string, panClient *aliyunpan.PanClient, ...) *SyncTaskManager

+ func (m *SyncTaskManager) ConfigFilePath() string

+ func (m *SyncTaskManager) Start(tasks []*SyncTask) (bool, error)

+ func (m *SyncTaskManager) Stop() (bool, error)