event

Documentation

Index

• type Emitter
  • func NewEmitter(eventBus bus.Bus, clusterName string, envs map[string]string) *Emitter
  • func (e *Emitter) GetListeners() common.Listeners
  • func (e *Emitter) Listen(ctx context.Context)
  • func (e *Emitter) Logs() []any
  • func (e *Emitter) Notify(event testkube.Event)
  • func (e *Emitter) Reconcile(ctx context.Context)
  • func (e *Emitter) Register(listener common.Listener)
  • func (e *Emitter) UpdateListeners(listeners common.Listeners)
• type Loader
  • func NewLoader() *Loader
  • func (s *Loader) Reconcile() (listeners common.Listeners)
  • func (s *Loader) Register(loader common.ListenerLoader)

Types

type Emitter

type Emitter struct {
	Results   chan testkube.EventResult
	Listeners common.Listeners
	Loader    *Loader
	Log       *zap.SugaredLogger

	Bus         bus.Bus
	ClusterName string
	Envs        map[string]string
	// contains filtered or unexported fields
}

Emitter handles events emitting for webhooks

func NewEmitter

func NewEmitter(eventBus bus.Bus, clusterName string, envs map[string]string) *Emitter

NewEmitter returns new emitter instance

func (*Emitter) GetListeners

func (e *Emitter) GetListeners() common.Listeners

func (*Emitter) Listen

func (e *Emitter) Listen(ctx context.Context)

Listen runs emitter workers responsible for sending HTTP requests

func (*Emitter) Logs

func (e *Emitter) Logs() []any

func (*Emitter) Notify

func (e *Emitter) Notify(event testkube.Event)

Notify notifies emitter with webhook

func (*Emitter) Reconcile

func (e *Emitter) Reconcile(ctx context.Context)

Reconcile reloads listeners from all registered reconcilers

func (*Emitter) Register

func (e *Emitter) Register(listener common.Listener)

Register adds new listener

func (*Emitter) UpdateListeners

func (e *Emitter) UpdateListeners(listeners common.Listeners)

UpdateListeners updates listeners list

type Loader

type Loader struct {
	Log     *zap.SugaredLogger
	Loaders []common.ListenerLoader
}

Loader updates list of available listeners in the background as we don't want to load them on each event

func NewLoader

func NewLoader() *Loader

func (*Loader) Reconcile

func (s *Loader) Reconcile() (listeners common.Listeners)

Reconcile loop for reconciling listeners from different sources

func (*Loader) Register

func (s *Loader) Register(loader common.ListenerLoader)

Register registers new listener reconciler