Documentation ¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*Emitter) OverrideListeners ¶
Notify notifies emitter with webhook
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 (*Loader) Register ¶
func (s *Loader) Register(reconciler common.ListenerLoader)
Register registers new listener reconciler
Click to show internal directories.
Click to hide internal directories.