action

type CloseSpiderRequest struct {
	RpcBase
	SpiderName string
}

type CloseSpiderResponse struct {
	RpcBase
	SpiderName string
}

type DistributeReqponse struct {
	RpcBase
}

type DistributeRequest struct {
	RpcBase
	Request *http.Request
}

type HttpServer interface {
	ServeHTTP(w http.ResponseWriter, r *http.Request)
	Welcome(w http.ResponseWriter, r *http.Request)
}

type HttpServerAnts interface {
	HttpServer
	HttpServerCluster
	HttpServerCrawler
}

type HttpServerCluster interface {
	Cluster(w http.ResponseWriter, r *http.Request)
}

type HttpServerCrawler interface {
	Spiders(w http.ResponseWriter, r *http.Request)
	Crawl(w http.ResponseWriter, r *http.Request)
	CrawlCluster(w http.ResponseWriter, r *http.Request)
	CrawlNode(w http.ResponseWriter, r *http.Request)
}

type LeftMeInRequest struct {
	RpcBase
}

type LeftMeInResponse struct {
	RpcBase
}

type MulticastClient interface {
	// contains filtered or unexported methods
}

type MulticastServer interface {
	// contains filtered or unexported methods
}

type ReportRequest struct {
	RpcBase
	ScrapeResult *crawler.ScrapeResult
}

type ReportResponse struct {
	RpcBase
}

type RpcBase struct {
	NodeInfo *node.NodeInfo
	Result   bool
}

type RpcClient interface {
	Dial(ip string, port int) (*rpc.Client, error)
	Detect() // if client connection is down
	Start()  // start dead loop for detect
}

type RpcClientAnts interface {
	RpcClient
	RpcClientCrawl
	RpcClientCluster
}

type RpcClientCluster interface {
	LetMeIn(ip string, port int) error
	Connect(ip string, port int) error
	StartSpider(nodeName, spiderName string) error
}

type RpcClientCrawl interface {
	StopNode(nodeName string) error
	Distribute(nodeName string, request *http.Request) error
	ReportResult(nodeName string, result *crawler.ScrapeResult) error
	CloseSpider(nodeName, spiderName string) error
}

type RpcServer interface {
	IsAlive(request *RpcBase, response *RpcBase) error
}

type RpcServerAnts interface {
	RpcServer
	RpcServerCrawl
	RpcServerCluster
}

type RpcServerCluster interface {
	LetMeIn(request *LeftMeInRequest, response *LeftMeInResponse) error
	Connect(request *RpcBase, response *RpcBase) error
	StopNode(request *StopRequest, response *StopResponse) error
	StartSpider(request *DistributeRequest, response *DistributeReqponse) error
}

type RpcServerCrawl interface {
	AcceptRequest(request *DistributeRequest, response *DistributeReqponse) error
	AcceptResult(request *ReportRequest, response *ReportResponse) error
	CloseSpider(request *CloseSpiderRequest, response *CloseSpiderResponse) error
}

type StopRequest struct {
	RpcBase
}

type StopResponse struct {
	RpcBase
}

type Watcher interface {
	Stop()
	IsStop() bool
	IsPause() bool
	Pause()
	Unpause()
	Start()
	Run()
}