1 files changed, 26 insertions, 0 deletions
diff --git a/util/events.go b/util/events.go
new file mode 100644
index 00000000..9e12c4f7
--- /dev/null
+++ b/util/events.go
@@ -0,0 +1,26 @@
+package util
+
+// Event listener listens for the events produced by worker, worker pool or other servce.
+type EventListener func(event interface{})
+
+// EventHandler helps to broadcast events to multiple listeners.
+type EventHandler struct {
+	listeners []EventListener
+}
+
+// NumListeners returns number of event listeners.
+func (eb *EventHandler) NumListeners() int {
+	return len(eb.listeners)
+}
+
+// AddListener registers new event listener.
+func (eb *EventHandler) AddListener(listener EventListener) {
+	eb.listeners = append(eb.listeners, listener)
+}
+
+// Push broadcast events across all event listeners.
+func (eb *EventHandler) Push(e interface{}) {
+	for _, listener := range eb.listeners {
+		listener(e)
+	}
+}