event

Documentation

Index

• 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
• type KafkaClient
• type KafkaConfig

Functions

func Close

func Close()

Close closes event system

func DequeueEvent

func DequeueEvent()

DequeueEvent runs in a goroutine and dequeue event from cache

func Initialize

func Initialize(k KafkaConfig) error

Initialize initializes event system

func Publish

func Publish(payload interface{})

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

func PublishActionBuild

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

PublishActionBuild sends a actionBuild event

func PublishPipelineBuild

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

PublishPipelineBuild sends a pipelineBuild event

func Status

func Status() string

Status returns Event status

Types

type Broker

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

Broker event typed

type KafkaClient

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

KafkaClient enbeddes the Kafka connecion

type KafkaConfig

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

KafkaConfig handles all config to connect to Kafka