muta

type ContextHandler func(Ctx *interface{}) error

type DestOpts struct {
	// Remove the entire destination directory before writing anything.
	//
	// Note: This is entirely handled by the DestWithOpts() func, not
	// the Stream itself.
	//
	// TODO: Move this option to the DestWithOpts() func, or possibly
	// move the Clean functionality into the Streamer object itself,
	// so that it makes sense to keep this Option here.
	Clean bool

	// Overwrite the contents of any encountered files. If false, an error
	// is returned if any Streamed files exist in the output directory.
	Overwrite bool
}

type DestStreamer struct {
	Destination string
	Opts        DestOpts
}

type ErrorHandler func() error

type ErrorStreamer struct {
	Message string
}

type FileInfo interface {
	// A getter and setter for the Name of the file object.
	Name() string
	SetName(string)

	// A getter and setter for the path of the file.
	Path() string
	SetPath(string)

	// A getter for the unmodified name and path of the file, as it was
	// at creation time.
	OriginalName() string
	OriginalPath() string

	// Ctx is a map[string]interface{} available for simple data storage
	// and/or passing. Generally it is recommended not to use it, and
	// instead return a new Struct with the FileInfo embedded in it.
	//
	// This will provide additional functionality to the FileInfo of
	// subsequent methods, as well as allow
	Ctx(string) interface{}
	SetCtx(string, interface{})
}

type FuncStreamer func(FileInfo, io.ReadCloser) (FileInfo,
	io.ReadCloser, error)

type Handler func()

type MockStreamer struct {
	// A slice of the file names to generate. If no Content is provided,
	// for an individual file (eg, if there are 5 files, but 4 contents)
	// the content will be automatically created as `<filename> content`
	Files []string

	// An optional slice of the contents to use for each file. These are
	// Shifted off one by one in the same order as files. If, after the slice
	// is empty, there are still more files, the contents are automatically
	// created as `<filename> content`.
	Contents []string

	// An optional slice of errors, to be matched up in the same way Contents
	// are matched to Files.
	Errors []error
}

type SrcStreamer struct {
	// The base directory that will be trimmed from the output path.
	// For example, `SrcStreamer("foo/bar/baz")` would set a Base of
	// `"foo/bar"`, so that the FileInfo has a Path of `.`. Trimming
	// `"foo/bar"` from the Path. You can override this, by setting
	// this value manually.
	Base string

	// The filepaths that this Streamer will load, and Stream
	Sources []string
}

type Stream []Streamer

type StreamHandler func() Stream

type Streamer interface {
	Next(FileInfo, io.ReadCloser) (FileInfo, io.ReadCloser, error)
}

type Tasker struct {
	Tasks  map[string]*TaskerTask
	Logger *logging.Logger
}

type TaskerTask struct {
	Name           string
	Dependencies   []string
	Handler        Handler
	ErrorHandler   ErrorHandler
	StreamHandler  StreamHandler
	ContextHandler ContextHandler
}