reactor

type DocumentController interface {
	jobs.Controller
	// SetDownloadScope sets the scope for resources considered "local"
	// and therefore downloaded and relatively linked
	// SetDownloadScope(scope *localityDomain)
	// GetDownloadController is accessor for the DownloadController
	// working with this DocumentController
	GetDownloadController() DownloadController
}

type DocumentWorkTask struct {
	Node *api.Node
}

type DocumentWorker struct {
	writers.Writer
	Reader
	processors.Processor
	NodeContentProcessor NodeContentProcessor
}

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

type DownloadController interface {
	jobs.Controller
	// Schedule is a typesafe wrapper around Controller#Enqueue
	// for enqueuing download tasks. An error is returned if
	// scheduling fails.
	Schedule(ctx context.Context, link, resourceName string) error
}

type DownloadTask struct {
	Source string
	Target string
}

type GenericReader struct {
	ResourceHandlers resourcehandlers.Registry
}

type NodeContentProcessor interface {
	ReconcileLinks(ctx context.Context, node *api.Node, contentSourcePath string, documentBlob []byte) ([]byte, error)
	GetDownloadController() DownloadController
}

type Options struct {
	MaxWorkersCount              int
	MinWorkersCount              int
	FailFast                     bool
	DestinationPath              string
	ResourcesPath                string
	ResourceDownloadWorkersCount int
	MarkdownFmt                  bool
	RewriteEmbedded              bool
	processors.Processor
	ResourceDownloadWriter writers.Writer
	Writer                 writers.Writer
	ResourceHandlers       []resourcehandlers.ResourceHandler
	DryRunWriter           writers.DryRunWriter
	Resolve                bool
	GlobalLinksConfig      *api.Links
}

type Reactor struct {
	FailFast         bool
	ResourceHandlers resourcehandlers.Registry
	// localityDomain     *localityDomain
	DocController      DocumentController
	DownloadController DownloadController
	DryRunWriter       writers.DryRunWriter
	Resolve            bool
}

type Reader interface {
	Read(ctx context.Context, source string) ([]byte, error)
}