collector

Documentation

Index

• Variables
• func CollectPageJob(id string) cron.Runner
• func Exit(k interface{}) (bool, error)
• func Export(c echo.Context) error
• func ExportAdd(ctx echo.Context) error
• func ExportDelete(ctx echo.Context) error
• func ExportEdit(ctx echo.Context) error
• func ExportEditStatus(ctx echo.Context) error
• func ExportLog(ctx echo.Context) error
• func ExportLogDelete(ctx echo.Context) error
• func ExportLogView(ctx echo.Context) error
• func Go(k interface{}, r *exec.Rules, f func(), ctx context.Context) (err error)
• func Group(ctx echo.Context) error
• func GroupAdd(ctx echo.Context) error
• func GroupDelete(ctx echo.Context) error
• func GroupEdit(ctx echo.Context) error
• func History(c echo.Context) error
• func HistoryDelete(c echo.Context) error
• func HistoryView(c echo.Context) error
• func RegexpTest(c echo.Context) error
• func Rule(c echo.Context) error
• func RuleAdd(c echo.Context) error
• func RuleCollect(c echo.Context) error
• func RuleDelete(c echo.Context) error
• func RuleEdit(c echo.Context) error
• type GoProcess
  • func NewProc(r *exec.Rules) *GoProcess
  • func (g *GoProcess) Close(k interface{})
  • func (g *GoProcess) IsExited() bool
• type RegexpForm

Variables

var GoProcs = sync.Map{}

var LeftNavigate = &navigate.Item{
	Display: true,
	Name:    `数据采集`,
	Action:  `collector`,
	Icon:    `truck`,
	Children: &navigate.List{
		{
			Display: true,
			Name:    `规则管理`,
			Action:  `rule`,
		},
		{
			Display: true,
			Name:    `新建规则`,
			Action:  `rule_add`,
			Icon:    `plus`,
		},
		{
			Display: true,
			Name:    `历史记录`,
			Action:  `history`,
		},
		{
			Display: false,
			Name:    `查看历史内容`,
			Action:  `history_view`,
		},
		{
			Display: false,
			Name:    `删除历史记录`,
			Action:  `history_delete`,
		},
		{
			Display: true,
			Name:    `数据导出`,
			Action:  `export`,
		},
		{
			Display: false,
			Name:    `添加导出规则`,
			Action:  `export_add`,
		},
		{
			Display: false,
			Name:    `修改导出规则`,
			Action:  `export_edit`,
		},
		{
			Display: false,
			Name:    `删除导出规则`,
			Action:  `export_delete`,
		},
		{
			Display: false,
			Name:    `导出日志管理`,
			Action:  `export_log`,
		},
		{
			Display: false,
			Name:    `查看导出日志`,
			Action:  `export_log_view/:id`,
		},
		{
			Display: false,
			Name:    `删除导出日志`,
			Action:  `export_log_delete`,
		},
		{
			Display: false,
			Name:    `更改导出日志状态`,
			Action:  `export_edit_status`,
		},
		{
			Display: true,
			Name:    `分组管理`,
			Action:  `group`,
		},
		{
			Display: true,
			Name:    `添加分组`,
			Action:  `group_add`,
			Icon:    `plus`,
		},
		{
			Display: false,
			Name:    `修改规则`,
			Action:  `rule_edit`,
			Icon:    ``,
		},
		{
			Display: false,
			Name:    `删除规则`,
			Action:  `rule_delete`,
			Icon:    ``,
		},
		{
			Display: false,
			Name:    `规则测试`,
			Action:  `rule_collect`,
			Icon:    ``,
		},
		{
			Display: false,
			Name:    `修改分组`,
			Action:  `group_edit`,
			Icon:    ``,
		},
		{
			Display: false,
			Name:    `删除分组`,
			Action:  `group_delete`,
			Icon:    ``,
		},
		{
			Display: false,
			Name:    `测试正则表达式`,
			Action:  `regexp_test`,
			Icon:    ``,
		},
	},
}

Functions

func CollectPageJob

func CollectPageJob(id string) cron.Runner

CollectPageJob 计划任务调用方式

func Exit

func Exit(k interface{}) (bool, error)

func Export

func Export(c echo.Context) error

func ExportAdd

func ExportAdd(ctx echo.Context) error

func ExportDelete

func ExportDelete(ctx echo.Context) error

func ExportEdit

func ExportEdit(ctx echo.Context) error

func ExportEditStatus

func ExportEditStatus(ctx echo.Context) error

func ExportLog

func ExportLog(ctx echo.Context) error

func ExportLogDelete

func ExportLogDelete(ctx echo.Context) error

func ExportLogView

func ExportLogView(ctx echo.Context) error

func Go

func Go(k interface{}, r *exec.Rules, f func(), ctx context.Context) (err error)

func Group

func Group(ctx echo.Context) error

func GroupAdd

func GroupAdd(ctx echo.Context) error

func GroupDelete

func GroupDelete(ctx echo.Context) error

func GroupEdit

func GroupEdit(ctx echo.Context) error

func History

func History(c echo.Context) error

func HistoryDelete

func HistoryDelete(c echo.Context) error

func HistoryView

func HistoryView(c echo.Context) error

func RegexpTest

func RegexpTest(c echo.Context) error

func Rule

func Rule(c echo.Context) error

func RuleAdd

func RuleAdd(c echo.Context) error

func RuleCollect

func RuleCollect(c echo.Context) error

func RuleDelete

func RuleDelete(c echo.Context) error

func RuleEdit

func RuleEdit(c echo.Context) error

Types

type GoProcess

type GoProcess struct {
	Rules *exec.Rules
	Done  bool
}

func NewProc

func NewProc(r *exec.Rules) *GoProcess

func (*GoProcess) Close

func (g *GoProcess) Close(k interface{})

func (*GoProcess) IsExited

func (g *GoProcess) IsExited() bool

type RegexpForm

type RegexpForm struct {
	Src    string
	Regexp string
	Type   string
	Error  string
	Result interface{}
}