Hub

📨 A fast(?) Event Hub for go applications using publish/subscribe pattern with support for topics like rabbitMQ exchanges.

---

Table of Contents

• Install
• Usage
• Examples & Demos
• Contribute
• Code of conduct

Install

To install this library you can go get it but I encourage you to always vendor your dependencies or use one of the version tags of this project.

go get -u github.com/leandro-lugaresi/hub

dep ensure --add github.com/leandro-lugaresi/hub

Usage

Subscribers

Hub provides two types of subscribers:

• BlockingSubscriber this subscriber use channels inside. If the channel is full the operation of publishing will block. you can use a buffered (cap > 0) or unbuffered channel (cap = 0).
• NonBlockingSubscriber this subscriber use a ring buffer. If the cap of the buffer is reached the publish operation will override the oldest data and never block. This should be used only if loose data is acceptable. ie: metrics, logs

Topics

This library uses the same concept of topic exchanges on rabbiMQ, so the message name is used to find all the subscribers that match, like a route. The topic must be a list of words delimited by dots (.) however, there is one important special case for binding keys: * (star) can substitute for exactly one word.

Examples & Demos

TODO: Add real examples

import github.com/leandro-lugaresi/hub

h := hub.New()

// Unbuffered subscribe
subs1 := h.Subscribe("account.login.*", 0)
go func(s *Subscription) {
	for {
		msg, ok := s.Next()
		if !ok {
			return
		}
		//process msg
	}
}(subs1)

subs2 := h.NonBlockingSubscribe("account.login.*", 10)
go func(s *Subscription) {
	for {
		msg, ok := s.Next()
		if !ok {
			return
		}
		//process msg
	}
}(subs2)

h.Publish(hub.Message{
	Name: "account.login.failed",
	Fields: hub.Fields{
		"account": 123,
		"ip": '127.0.0.1',
	},
})

---

This project adheres to the Contributor Covenant code of conduct. By participating, you are expected to uphold this code. We appreciate your contribution. Please refer to our contributing guidelines for further information