Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // JobQueue is channel from with workers consume jobs JobQueue = make(chan Job, 5) )
Functions ¶
func StartWorkers ¶ added in v0.8.1
StartWorkers run predefined number of workers, workers wait on channel JobQueue
Types ¶
type Config ¶ added in v0.9.0
type Config struct { API string `codec:"api"` Project string `codec:"project"` Cluster string `codec:"cluster"` Service string `codec:"service"` Timeout int `codec:"timeout"` Fields []string `codec:"Fields"` Schema []string `codec:"schema"` }
Config contains setting from combainers sender section
type Sender ¶ added in v0.9.0
type Sender struct { Config // contains filtered or unexported fields }
Sender object
Click to show internal directories.
Click to hide internal directories.