slurpfiles

type BackendFunc ¶

type BackendFunc func(ctx context.Context, sink chan<- File) error

BackendFunc fetches files from its backend and sends them on the sink.

Implementations must close the channel when they are done and return.

func SFTPBackend(client *sftp.Client, directory string) BackendFunc

type File ¶

type File interface {
	io.Reader
	Name() string
}

File is the thing being processed.

type Handler ¶

type Handler struct {
	// OnFile is invoked on any file encountered.
	OnFile OnFileFunc
	// OnSuccess is invoked once and only if no error occured.
	OnSuccess Thunk
	// OnCompletion is invoked once after all operations are complete and before OnSuccess.
	OnCompletion Thunk
}

Handler stores callbacks for use in Digest.

type OnFileFunc ¶

type OnFileFunc func(ctx context.Context, file File) error

OnFileFunc processes file.

type Thunk ¶

type Thunk func(ctx context.Context) error

Thunk is a callback for various, though purely side-effect reasons.