Versions in this module Expand all Collapse all v0 v0.4.0 Jan 27, 2017 Changes in this version + func Close() + func DequeueEvent() + func Initialize(k KafkaConfig) error + func Publish(payload interface{}) + func PublishActionBuild(pb *sdk.PipelineBuild, ab *sdk.ActionBuild) + func PublishPipelineBuild(db database.QueryExecuter, pb *sdk.PipelineBuild, previous *sdk.PipelineBuild) + func Status() string + type Broker interface + type KafkaClient struct + type KafkaConfig struct + BrokerAddresses string + Enabled bool + Password string + Topic string + User string
Go to main page