Method Notify

pkg/events/handler.go:45–51

Notify implements the Handler interface.

(evt Event)

// Notify implements the Handler interface.
func (ch Channel) Notify(evt Event) {
	select {
	case ch <- evt:
	default:
		channelDropped.WithLabelValues(evt.Name()).Inc()
	}
}

// ReceiveTimeout returns the next event from the channel or returns nil after a timeout.
func (ch Channel) ReceiveTimeout(timeout time.Duration) Event {