Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitJoints ¶
func InitJoints()
InitJoints register crawler joint types in order to create pipeline with these joints on the fly
Types ¶
type PipeRunner ¶
type PipeRunner struct {
// contains filtered or unexported fields
}
func (*PipeRunner) Start ¶
func (pipe *PipeRunner) Start(config PipeConfig)
func (*PipeRunner) Stop ¶
func (pipe *PipeRunner) Stop()
func (*PipeRunner) Update ¶
func (pipe *PipeRunner) Update(config PipeConfig)
type PipelineFrameworkModule ¶
type PipelineFrameworkModule struct {
}
func (PipelineFrameworkModule) Name ¶
func (module PipelineFrameworkModule) Name() string
func (PipelineFrameworkModule) Start ¶
func (module PipelineFrameworkModule) Start(cfg *Config)
func (PipelineFrameworkModule) Stop ¶
func (module PipelineFrameworkModule) Stop() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.