es_sync

Documentation

Index

• type ListenerCopyFailure
• type ListenerCopySuccess
• type ListenerCreateFolderFailure
• type ListenerCreateFolderSuccess
• type ListenerDeleteFailure
• type ListenerDeleteSuccess
• type ListenerSkip
• type Opt
  • func OnCopyFailure(l ListenerCopyFailure) Opt
  • func OnCopySuccess(l ListenerCopySuccess) Opt
  • func OnCreateFolderFailure(l ListenerCreateFolderFailure) Opt
  • func OnCreateFolderSuccess(l ListenerCreateFolderSuccess) Opt
  • func OnDeleteFailure(l ListenerDeleteFailure) Opt
  • func OnDeleteSuccess(l ListenerDeleteSuccess) Opt
  • func OnSkip(l ListenerSkip) Opt
  • func OptimizePreventCreateFolder(enabled bool) Opt
  • func SyncDelete(enabled bool) Opt
  • func SyncDontCompareContent(enabled bool) Opt
  • func SyncDontCompareTime(enabled bool) Opt
  • func SyncOverwrite(enabled bool) Opt
  • func WithNameFilter(filter mo_filter.Filter) Opt
  • func WithProgress(container ea_indicator.Container) Opt
• type Opts
  • func (z Opts) Apply(opt []Opt) Opts
  • func (z Opts) OnCopyFailure(source es_filesystem.Path, err es_filesystem.FileSystemError)
  • func (z Opts) OnCopySuccess(source es_filesystem.Entry, target es_filesystem.Entry)
  • func (z Opts) OnCreateFolderFailure(target es_filesystem.Path, err es_filesystem.FileSystemError)
  • func (z Opts) OnCreateFolderSuccess(target es_filesystem.Path)
  • func (z Opts) OnDeleteFailure(target es_filesystem.Path, err es_filesystem.FileSystemError)
  • func (z Opts) OnDeleteSuccess(target es_filesystem.Path)
  • func (z Opts) OnSkip(reason SkipReason, source es_filesystem.Entry, target es_filesystem.Path)
  • func (z Opts) OptimizeReduceCreateFolder() bool
  • func (z Opts) Progress() ea_indicator.Container
  • func (z Opts) SyncDelete() bool
  • func (z Opts) SyncDontCompareContent() bool
  • func (z Opts) SyncDontCompareTime() bool
  • func (z Opts) SyncOverwrite() bool
• type SkipReason
• type Syncer
  • func New(log esl.Logger, qd eq_queue.Definition, ...) Syncer
• type TaskCopyFile
• type TaskDelete
• type TaskReplaceFileByFolder
• type TaskReplaceFolderByFile
• type TaskSyncFolder

Types

type ListenerCopyFailure

type ListenerCopyFailure func(source es_filesystem.Path, fsErr es_filesystem.FileSystemError)

type ListenerCopySuccess

type ListenerCopySuccess func(source es_filesystem.Entry, target es_filesystem.Entry)

type ListenerCreateFolderFailure

type ListenerCreateFolderFailure func(target es_filesystem.Path, fsErr es_filesystem.FileSystemError)

type ListenerCreateFolderSuccess

type ListenerCreateFolderSuccess func(target es_filesystem.Path)

type ListenerDeleteFailure

type ListenerDeleteFailure func(target es_filesystem.Path, fsErr es_filesystem.FileSystemError)

type ListenerDeleteSuccess

type ListenerDeleteSuccess func(target es_filesystem.Path)

type ListenerSkip

type ListenerSkip func(reason SkipReason, source es_filesystem.Entry, target es_filesystem.Path)

type Opt

type Opt func(o Opts) Opts

func OnCopyFailure

func OnCopyFailure(l ListenerCopyFailure) Opt

func OnCopySuccess

func OnCopySuccess(l ListenerCopySuccess) Opt

func OnCreateFolderFailure

func OnCreateFolderFailure(l ListenerCreateFolderFailure) Opt

func OnCreateFolderSuccess

func OnCreateFolderSuccess(l ListenerCreateFolderSuccess) Opt

func OnDeleteFailure

func OnDeleteFailure(l ListenerDeleteFailure) Opt

func OnDeleteSuccess

func OnDeleteSuccess(l ListenerDeleteSuccess) Opt

func OnSkip

func OnSkip(l ListenerSkip) Opt

func OptimizePreventCreateFolder

func OptimizePreventCreateFolder(enabled bool) Opt

Performance optimize option: try avoid call create folder operation

func SyncDelete

func SyncDelete(enabled bool) Opt

func SyncDontCompareContent

func SyncDontCompareContent(enabled bool) Opt

func SyncDontCompareTime

func SyncDontCompareTime(enabled bool) Opt

func SyncOverwrite

func SyncOverwrite(enabled bool) Opt

func WithNameFilter

func WithNameFilter(filter mo_filter.Filter) Opt

func WithProgress

func WithProgress(container ea_indicator.Container) Opt

type Opts

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

func (Opts) Apply

func (z Opts) Apply(opt []Opt) Opts

func (Opts) OnCopyFailure

func (z Opts) OnCopyFailure(source es_filesystem.Path, err es_filesystem.FileSystemError)

func (Opts) OnCopySuccess

func (z Opts) OnCopySuccess(source es_filesystem.Entry, target es_filesystem.Entry)

func (Opts) OnCreateFolderFailure

func (z Opts) OnCreateFolderFailure(target es_filesystem.Path, err es_filesystem.FileSystemError)

func (Opts) OnCreateFolderSuccess

func (z Opts) OnCreateFolderSuccess(target es_filesystem.Path)

func (Opts) OnDeleteFailure

func (z Opts) OnDeleteFailure(target es_filesystem.Path, err es_filesystem.FileSystemError)

func (Opts) OnDeleteSuccess

func (z Opts) OnDeleteSuccess(target es_filesystem.Path)

func (Opts) OnSkip

func (z Opts) OnSkip(reason SkipReason, source es_filesystem.Entry, target es_filesystem.Path)

func (Opts) OptimizeReduceCreateFolder

func (z Opts) OptimizeReduceCreateFolder() bool

func (Opts) Progress

func (z Opts) Progress() ea_indicator.Container

func (Opts) SyncDelete

func (z Opts) SyncDelete() bool

func (Opts) SyncDontCompareContent

func (z Opts) SyncDontCompareContent() bool

func (Opts) SyncDontCompareTime

func (z Opts) SyncDontCompareTime() bool

func (Opts) SyncOverwrite

func (z Opts) SyncOverwrite() bool

type SkipReason

type SkipReason string

const (
	SkipSame   SkipReason = "same"
	SkipOld    SkipReason = "old"
	SkipExists SkipReason = "exists"
	SkipFilter SkipReason = "filter"
)

type Syncer

type Syncer interface {
	// Sync source to target.
	// This function is not thread safe. Please create an instance per thread.
	Sync(source es_filesystem.Path, target es_filesystem.Path) error
}

func New

func New(log esl.Logger, qd eq_queue.Definition, source, target es_filesystem.FileSystem, conn es_filesystem.Connector, opt ...Opt) Syncer

type TaskCopyFile

type TaskCopyFile struct {
	Source es_filesystem.EntryData `json:"source"`
	Target es_filesystem.PathData  `json:"target"`
}

type TaskDelete

type TaskDelete struct {
	Target es_filesystem.PathData `json:"target"`
}

type TaskReplaceFileByFolder

type TaskReplaceFileByFolder struct {
	Source es_filesystem.EntryData `json:"source"`
	Target es_filesystem.PathData  `json:"target"`
}

type TaskReplaceFolderByFile

type TaskReplaceFolderByFile struct {
	Source es_filesystem.EntryData `json:"source"`
	Target es_filesystem.PathData  `json:"target"`
}

type TaskSyncFolder

type TaskSyncFolder struct {
	Source es_filesystem.PathData `json:"source"`
	Target es_filesystem.PathData `json:"target"`
}