event

Documentation

Index

• type Emitter
  • func NewEmitter() *Emitter
  • func (e *Emitter) Notify(event testkube.Event)
  • func (e *Emitter) OverrideListeners(listeners common.Listeners)
  • func (s *Emitter) Reconcile(ctx context.Context)
  • func (e *Emitter) Register(listener common.Listener)
  • func (e *Emitter) RunWorker(events chan testkube.Event, results chan testkube.EventResult)
  • func (e *Emitter) RunWorkers()
• type Loader
  • func NewLoader() *Loader
  • func (s *Loader) Reconcile() (listeners common.Listeners)
  • func (s *Loader) Register(reconciler common.ListenerLoader)

Types

type Emitter

type Emitter struct {
	Events    chan testkube.Event
	Results   chan testkube.EventResult
	Listeners common.Listeners
	Loader    Loader
	Log       *zap.SugaredLogger
	// contains filtered or unexported fields
}

Emitter handles events emitting for webhooks

func NewEmitter

func NewEmitter() *Emitter

NewEmitter returns new emitter instance

func (*Emitter) Notify

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

Notify notifies emitter with webhook

func (*Emitter) OverrideListeners

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

Notify notifies emitter with webhook

func (*Emitter) Reconcile

func (s *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) RunWorker

func (e *Emitter) RunWorker(events chan testkube.Event, results chan testkube.EventResult)

RunWorker runs single emitter worker loop responsible for sending events

func (*Emitter) RunWorkers

func (e *Emitter) RunWorkers()

RunWorkers runs emitter workers responsible for sending HTTP requests

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(reconciler common.ListenerLoader)

Register registers new listener reconciler