Documentation ¶
Index ¶
- func NewGoQuartzSchedulerSourceConnectorGenerator() pluginapi.SourceConnectorGenerator
- type GoQuartzSchedulerSourceConnector
- type GoQuartzSchedulerSourceConnectorGenerator
- func (g *GoQuartzSchedulerSourceConnectorGenerator) GenerateSourceConnectorInstance(req pluginapi.SourceConnectorGenerateRequest) (pluginapi.SourceConnector, error)
- func (g *GoQuartzSchedulerSourceConnectorGenerator) InitializeSubGeneratorInstance(req pluginapi.CommonSourceConnectorGenerateRequest) (pluginapi.SourceConnectorGenerator, error)
- func (g *GoQuartzSchedulerSourceConnectorGenerator) OriginalGeneratorNames() []string
- func (g *GoQuartzSchedulerSourceConnectorGenerator) Startup() error
- func (g *GoQuartzSchedulerSourceConnectorGenerator) Stop() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewGoQuartzSchedulerSourceConnectorGenerator ¶
func NewGoQuartzSchedulerSourceConnectorGenerator() pluginapi.SourceConnectorGenerator
Types ¶
type GoQuartzSchedulerSourceConnector ¶
type GoQuartzSchedulerSourceConnector struct {
// contains filtered or unexported fields
}
func (*GoQuartzSchedulerSourceConnector) BindPipeline ¶
func (g *GoQuartzSchedulerSourceConnector) BindPipeline(process pluginapi.PipelineProcess) error
func (*GoQuartzSchedulerSourceConnector) Reload ¶
func (g *GoQuartzSchedulerSourceConnector) Reload() error
func (*GoQuartzSchedulerSourceConnector) Start ¶
func (g *GoQuartzSchedulerSourceConnector) Start() error
func (*GoQuartzSchedulerSourceConnector) Stop ¶
func (g *GoQuartzSchedulerSourceConnector) Stop() error
type GoQuartzSchedulerSourceConnectorGenerator ¶
type GoQuartzSchedulerSourceConnectorGenerator struct {
// contains filtered or unexported fields
}
func (*GoQuartzSchedulerSourceConnectorGenerator) GenerateSourceConnectorInstance ¶
func (g *GoQuartzSchedulerSourceConnectorGenerator) GenerateSourceConnectorInstance(req pluginapi.SourceConnectorGenerateRequest) (pluginapi.SourceConnector, error)
func (*GoQuartzSchedulerSourceConnectorGenerator) InitializeSubGeneratorInstance ¶
func (g *GoQuartzSchedulerSourceConnectorGenerator) InitializeSubGeneratorInstance(req pluginapi.CommonSourceConnectorGenerateRequest) (pluginapi.SourceConnectorGenerator, error)
func (*GoQuartzSchedulerSourceConnectorGenerator) OriginalGeneratorNames ¶
func (g *GoQuartzSchedulerSourceConnectorGenerator) OriginalGeneratorNames() []string
func (*GoQuartzSchedulerSourceConnectorGenerator) Startup ¶
func (g *GoQuartzSchedulerSourceConnectorGenerator) Startup() error
func (*GoQuartzSchedulerSourceConnectorGenerator) Stop ¶
func (g *GoQuartzSchedulerSourceConnectorGenerator) Stop() error
Click to show internal directories.
Click to hide internal directories.