input

Documentation

Index

• type InitTaskJoint
  • func (joint InitTaskJoint) Name() string
  • func (joint InitTaskJoint) Process(context *pipeline.Context) error

Types

type InitTaskJoint

type InitTaskJoint struct {
	pipeline.Parameters
}

InitTaskJoint basically start the pipeline process, construct a model.Task, may loaded from db with CONTEXT_TASK_ID or manually passed in with CONTEXT_CRAWLER_TASK

func (InitTaskJoint) Name

func (joint InitTaskJoint) Name() string

Name return: init_task

func (InitTaskJoint) Process

func (joint InitTaskJoint) Process(context *pipeline.Context) error

Process task load, init a new snapshot instance