Documentation: GoDoc
Build Status:
Test Coverage: TBD

go-exchange is an in-process message (or event) exchange for Go (Golang), featuring:

• Publish-Subscribe with topic-based prefix subscriptions.

This is a very young project and the API can and probably will change.

Any ideas on how to make the API or anything else better are welcome.

import "github.com/tchap/go-exchange/exchange"

This section describes the messaging patterns that go-exchange implements.

Publish-subscribe is based on topics and event handlers can be registered for particular topic prefixes. What that means is that an event handler registered for git topic will be as well activated when an events of kind git.push is received.

ex := exchange.New()

ex.Subscribe(ex.Topic("git"), func(topic exchange.Topic, event exchange.Event) {
	fmt.Printf("Event received:\n  topic: %q\n  body:  %v\n", topic, event)
})  

ex.Publish(exchange.Topic("git.push"), "b839dc656e3e78647c09453b33652b389e37c07a")

ex.Terminate()
// Output:
// Event received:
//   topic: "git.push"
//   body:  b839dc656e3e78647c09453b33652b389e37c07a

• Limit how many handlers can be running at the same time.

• go-patricia - trie that is being used in this project for managing subscriptions

MIT, see the LICENSE file.