app

type App interface {
	SetLog(io.Writer) App                                         // Set global log output to terminal
	LogGoOn() App                                                 // Resume log output
	LogRest() App                                                 // Pause log output
	Init(mode int, port int, master string, w ...io.Writer) App   // Must call Init before using App (except SetLog)
	ReInit(mode int, port int, master string, w ...io.Writer) App // Switch run mode and reset log output target
	GetAppConf(k ...string) interface{}                           // Get global config
	SetAppConf(k string, v interface{}) App                       // Set global config (not called in client mode)
	SpiderPrepare(original []*spider.Spider) App                  // Must call after setting global params and before Run() (not called in client mode)
	Run()                                                         // Block until task completes (call after all config is done)
	Stop()                                                        // Terminate task mid-run in Offline mode (blocks until current task stops)
	IsRunning() bool                                              // Check if task is running
	IsPaused() bool                                               // Check if task is paused
	IsStopped() bool                                              // Check if task has stopped
	PauseRecover()                                                // Pause or resume task in Offline mode
	Status() int                                                  // Return current status
	GetSpiderLib() []*spider.Spider                               // Get all spider species
	GetSpiderByName(string) option.Option[*spider.Spider]         // Get spider by name
	GetSpiderQueue() crawler.SpiderQueue                          // Get spider queue interface
	GetOutputLib() []string                                       // Get all output methods
	GetTaskJar() *distribute.TaskJar                              // Return task jar
	distribute.Distributor                                        // Implements distributed interface
}

type Logic struct {
	*cache.AppConf        // Global config
	*spider.SpiderSpecies // All spider species
	crawler.SpiderQueue   // Spider queue for current task
	*distribute.TaskJar   // Task storage passed between server and client
	crawler.CrawlerPool   // Crawler pool
	teleport.Teleport     // Socket duplex communication, JSON transport

	sync.RWMutex
	// contains filtered or unexported fields
}