fs

Documentation

Index

• func CopyFile(src, dest string) error
• func MoveFile(src, dest string) error
• type FileEvent
• type StableFileWatcher
  • func NewStableFileWatcher(watchDir string, stableThreshold time.Duration) (*StableFileWatcher, error)
  • func (w *StableFileWatcher) Close()

Functions

func CopyFile

func CopyFile(src, dest string) error

CopyFile copies the source path to the destination path.

func MoveFile

func MoveFile(src, dest string) error

MoveFile copies the source path to the destination path, and then removes it.

Types

type FileEvent

type FileEvent struct {
	// Path to the file
	Path string
}

FileEvent signals that a file is in the watch directory is ready to be processed.

type StableFileWatcher

type StableFileWatcher struct {

	// StableThreshold is the duration that a file must not change
	// before a signaling an event for the file.
	StableThreshold time.Duration

	// Events signal when a file has stabilized.
	Events chan FileEvent
	// contains filtered or unexported fields
}

StableFile watches for new files, waiting for the file to be completely written before signaling an event.

func NewStableFileWatcher

func NewStableFileWatcher(watchDir string, stableThreshold time.Duration) (*StableFileWatcher, error)

NewStableFileWatcher watcher for a directory.

func (*StableFileWatcher) Close

func (w *StableFileWatcher) Close()

Close all channels.