watch

type Uploader ¶

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

Uploader uploads local files to the target storage via a worker pool. If a file changes while being uploaded, it is re-uploaded once after the current upload finishes, instead of being queued multiple times.

func NewUploader(ctx context.Context, opts UploaderOptions) *Uploader

func (u *Uploader) Close()

func (u *Uploader) Submit(ctx context.Context, job uploadJob) bool

type UploaderOptions ¶

type UploaderOptions struct {
	Storage    storage.Storage
	DestDir    string
	Overwrite  bool
	Workers    int
	Retry      int
	RetryDelay time.Duration
	QueueSize  int
}

type Watcher ¶

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

Watcher watches a local directory and submits stable files to the Uploader.

Write-completion detection: fsnotify emits Write events throughout a write. Watcher debounces per file and only uploads once the file size stays unchanged across a debounce window, avoiding uploads of partial files.

func NewWatcher(ctx context.Context, opts WatcherOptions) (*Watcher, error)

func (w *Watcher) Run(ctx context.Context) error

func (w *Watcher) ScanExisting(ctx context.Context)

type WatcherOptions ¶

type WatcherOptions struct {
	Root      string
	Recursive bool
	Debounce  time.Duration
	Uploader  *Uploader
}