event

package

v0.4.0 Latest Latest Go to latest Published: Jan 27, 2017 License: BSD-3-Clause Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func Close()

Close closes event system

func DequeueEvent()

DequeueEvent runs in a goroutine and dequeue event from cache

func Initialize(k KafkaConfig) error

Initialize initializes event system

func Publish(payload interface{})

Publish sends a event to a queue func Publish(event sdk.Event, eventType string) {

func PublishActionBuild(pb *sdk.PipelineBuild, ab *sdk.ActionBuild)

PublishActionBuild sends a actionBuild event

func PublishPipelineBuild(db database.QueryExecuter, pb *sdk.PipelineBuild, previous *sdk.PipelineBuild)

PublishPipelineBuild sends a pipelineBuild event

func Status() string

Status returns Event status

type Broker interface {
	// contains filtered or unexported methods
}

Broker event typed

type KafkaClient struct {
	// contains filtered or unexported fields
}

KafkaClient enbeddes the Kafka connecion

type KafkaConfig struct {
	Enabled         bool
	BrokerAddresses string
	User            string
	Password        string
	Topic           string
}

KafkaConfig handles all config to connect to Kafka