pipeline

Documentation

Overview

Author: Aosen Data: 2016-01-07 QQ: 316052486 Desc: Pipeline file

Index

• type PipelineConsole
  • func NewPipelineConsole() *PipelineConsole
  • func (self *PipelineConsole) Process(items *robot.PageItems, t robot.Task)
• type PipelineFile
  • func NewPipelineFile(path string) *PipelineFile
  • func (self *PipelineFile) Process(items *robot.PageItems, t robot.Task)
• type PipelineMongo
  • func NewPipelineMongo(url, db, collection string) *PipelineMongo
  • func (self *PipelineMongo) Process(pageitems *robot.PageItems, task robot.Task)
• type User

Types

type PipelineConsole

type PipelineConsole struct {
}

func NewPipelineConsole

func NewPipelineConsole() *PipelineConsole

func (*PipelineConsole) Process

func (self *PipelineConsole) Process(items *robot.PageItems, t robot.Task)

type PipelineFile

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

func NewPipelineFile

func NewPipelineFile(path string) *PipelineFile

func (*PipelineFile) Process

func (self *PipelineFile) Process(items *robot.PageItems, t robot.Task)

type PipelineMongo

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

mongo pipline 的例子，仅供参考，需要开发者自己实现

func NewPipelineMongo

func NewPipelineMongo(url, db, collection string) *PipelineMongo

func (*PipelineMongo) Process

func (self *PipelineMongo) Process(pageitems *robot.PageItems, task robot.Task)

type User

type User struct {
	Id_  bson.ObjectId `bson:"_id"`
	Name string        `bson:"name"`
	Age  int           `bson:"age"`
}