multi

type AcquireImage struct {
	DownloadTimeout time.Duration
	MaxHeight       int
	MaxWidth        int
	Uploader        Uploader
	Log             logging.Logger
}

type AcquiredImage struct {
	SourceSize        int
	SourceUrl         string
	SourceContentType string

	DestUrl    string
	DestSize   int64
	DestHeight int
	DestWidth  int
	PHash      uint64
}

type AsyncOutcome struct {
	Error    error
	Duration time.Duration
	Id       string
}

type Coordinator struct {
	Success chan *Flow
	Fail    chan *Flow
	// contains filtered or unexported fields
}

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

type DataFlow interface {
	Set(name string, value interface{})
	Get(name string) interface{}
}

type FileDownloadInput struct {
	Url      string
	Filename string
}

type FileDownloadOutput struct {
	Path        string
	Size        int64
	ContentType string
}

type FileDownloadTask struct {
	Folder  string
	Timeout time.Duration
}

type FileUploadOutput struct {
	Url      string
	FileSize int64
}

type FileUploadTask struct {
	Uploader Uploader
}

type Flow struct {
	Steps map[string]*StepState
	Data  DataFlow
}

type ImageProcessor struct {

	// Uploader - required
	Uploader Uploader

	// LocalPath - defaults to os.TempDir()/downloads
	LocalPath string

	Log logging.Logger

	MaxHeight int
	MaxWidth  int
	// contains filtered or unexported fields
}

type ImageProcessorOutput struct {
	DownloadSize        int64
	DownloadContentType string
	DownloadUrl         string
	PHash               uint64

	FileSize    int64
	Height      int
	Width       int
	ContentType string

	DestinationUrl string
	Error          error
	Context        *DataContext
}

type ImageResizeOutput struct {
	FileSize    int64
	Height      int
	Width       int
	ContentType string
	FilePath    string
}

type NoOpUploader struct {
}

type NoOpWriteCloser struct {
}

type PHashTask struct {
	Log logging.Logger
}

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

type ResizeImageTask struct {
	MaxWidth  int
	MaxHeight int
}

type S3Writer struct {
	BucketName string
	Root       string
}

type StepAction interface {
	Action(tuple DataFlow, done func())
	Error() error
}

type StepState struct {
	Name     string
	Attempts int
	Action   StepAction
	State    interface{}
}

type TaskAction interface {
	Run(input interface{}) (interface{}, error)
	Name() string
}

type TaskRun struct {
	Action        TaskAction
	DiscardOutput bool

	Track        stats.BasicMeter
	Log          logging.Logger
	Concurrency  int
	MaxQueuedIn  int
	MaxQueuedOut int
	// contains filtered or unexported fields
}

type TaskRunInput struct {
	Input   interface{}
	Context *DataContext
}

type TaskRunOutput struct {
	Context *DataContext
	// contains filtered or unexported fields
}

type TaskRunResult struct {
	Error  error
	Input  interface{}
	Output interface{}
}

type Uploader interface {
	Writer(string) (io.WriteCloser, error)
	DestinationUrl(string) string
}