cache

Documentation

Index

• Variables
• func ExecInit(order int)
• func GetPageCount(i int) uint64
• func PageFailCount()
• func PageSuccCount()
• func ResetPageCount()
• func WaitInit(order int)
• type AppConf
  • func (a *AppConf) Clone() *AppConf
• type Report

Variables

var (
	// 点击开始按钮的时间点
	StartTime time.Time
	// 文本数据小结报告
	ReportChan chan *Report
)

var Task = new(AppConf)

该初始值即默认值

Functions

func ExecInit

func ExecInit(order int)

标记当前init()已执行完毕

func GetPageCount

func GetPageCount(i int) uint64

0 返回总下载页数，负数 返回失败数，正数 返回成功数

func PageFailCount

func PageFailCount()

func PageSuccCount

func PageSuccCount()

func ResetPageCount

func ResetPageCount()

重置页面计数

func WaitInit

func WaitInit(order int)

等待指定init()执行完毕 需并发协程中调用

Types

type AppConf

type AppConf struct {
	Mode           int    // 节点角色
	Port           int    // 主节点端口
	Master         string // 服务器(主节点)地址，不含端口
	ThreadNum      int    // 全局最大并发量
	Pausetime      int64  // 暂停时长参考/ms(随机: Pausetime/2 ~ Pausetime*2)。随机暂停区间(50%~200%)，若规则中直接定义，则不被界面传参覆盖
	OutType        string // 输出方式
	FileOutType    string // 文件输出方式
	FileOutPath    string // 文件输出路径
	DockerCap      int    // 分段转储容器容量
	Limit          int64  // 默认限制请求数，0为不限；<0时，限制总请求数；>0则采用规则的自定义限制方案
	ProxyMinute    int64  // 代理IP更换的间隔分钟数
	SuccessInherit bool   // 继承历史成功记录
	FailureInherit bool   // 继承历史失败记录
	// 选填项
	Keyins string // 自定义输入，后期切分为多个任务的Keyin自定义配置
}

任务运行时公共配置

func (*AppConf) Clone

func (a *AppConf) Clone() *AppConf

type Report

type Report struct {
	SpiderName string
	Keyin      string
	DataNum    uint64
	FileNum    uint64
	// DataSize   uint64
	// FileSize uint64
	Time time.Duration
}