http

Documentation

Index

• type Router
  • func NewRouter(node node.Node, cluster cluster.Cluster, reporter, distributer action.Watcher, ...) *Router
  • func (this *Router) Cluster(w http.ResponseWriter, r *http.Request)
  • func (this *Router) Crawl(w http.ResponseWriter, r *http.Request)
  • func (this *Router) CrawlCluster(w http.ResponseWriter, r *http.Request)
  • func (this *Router) CrawlNode(w http.ResponseWriter, r *http.Request)
  • func (this *Router) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (this *Router) Spiders(w http.ResponseWriter, r *http.Request)
  • func (this *Router) Welcome(w http.ResponseWriter, r *http.Request)
• type StartSpiderResult
• type WelcomeInfo

Types

type Router

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

func NewRouter

func NewRouter(node node.Node, cluster cluster.Cluster, reporter, distributer action.Watcher, rpcClient action.RpcClientAnts) *Router

func (*Router) Cluster

func (this *Router) Cluster(w http.ResponseWriter, r *http.Request)

func (*Router) Crawl

func (this *Router) Crawl(w http.ResponseWriter, r *http.Request)

try to start spider if ok * tell other node start spider * start reporter and distribute in this node

func (*Router) CrawlCluster

func (this *Router) CrawlCluster(w http.ResponseWriter, r *http.Request)

func (*Router) CrawlNode

func (this *Router) CrawlNode(w http.ResponseWriter, r *http.Request)

func (*Router) ServeHTTP

func (this *Router) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Router) Spiders

func (this *Router) Spiders(w http.ResponseWriter, r *http.Request)

func (*Router) Welcome

func (this *Router) Welcome(w http.ResponseWriter, r *http.Request)

type StartSpiderResult

type StartSpiderResult struct {
	Success    bool
	Message    string
	Spider     string
	Time       string
	MasterNode *node.NodeInfo
}

result of start spider

type WelcomeInfo

type WelcomeInfo struct {
	Message  string
	Greeting string
	Time     string
}

welcome struct