pipeline

package
v0.0.0-...-926784e Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2016 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL