Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Configurer ¶
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) DriverFromConfig ¶
func (p *Plugin) DriverFromConfig(configKey string, pq jobs.Queue, pipeline jobs.Pipeline) (jobs.Driver, error)
DriverFromConfig constructs kafka driver from the .rr.yaml configuration
func (*Plugin) DriverFromPipeline ¶
DriverFromPipeline constructs kafka driver from pipeline
Click to show internal directories.
Click to hide internal directories.