Documentation
¶
Overview ¶
Package task defines a synchronization task
Index ¶
- type Sync
- func (s *Sync) InitialSnapshots(ctx context.Context, dryRun bool, statusChan chan filters.BatchProcessStatus) (diff *proc.SourceDiff, e error)
- func (s *Sync) Resync(ctx context.Context, dryRun bool, statusChan chan filters.BatchProcessStatus) (*proc.SourceDiff, error)
- func (s *Sync) SetupWatcher(ctx context.Context, source PathSyncSource, target PathSyncTarget) error
- func (s *Sync) Shutdown()
- func (s *Sync) Start(ctx context.Context)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sync ¶
type Sync struct {
Source Endpoint
Target Endpoint
EchoFilter *filters.EchoFilter
Merger *proc.Merger
Direction string
// contains filtered or unexported fields
}
func (*Sync) InitialSnapshots ¶
func (s *Sync) InitialSnapshots(ctx context.Context, dryRun bool, statusChan chan filters.BatchProcessStatus) (diff *proc.SourceDiff, e error)
func (*Sync) Resync ¶
func (s *Sync) Resync(ctx context.Context, dryRun bool, statusChan chan filters.BatchProcessStatus) (*proc.SourceDiff, error)
func (*Sync) SetupWatcher ¶
Source Files
¶
- sync.go
Click to show internal directories.
Click to hide internal directories.