grapevine
Brokerless (p2p) cluster with service auto-discover and failure resilient implemented in gomsg
It is very easy to use, with very little configuration.
The provider
var peer = grapevine.NewPeer(grapevine.Config{})
peer.Handle("GREETING", func(name string) string {
return "Hello " + name
})
if err := <-peer.Bind(":7000"); err != nil {
panic(err)
}The consumer
var peer = grapevine.NewPeer(grapevine.Config{})
go func() {
if err := <-peer.Bind(":8000"); err != nil {
panic(err)
}
}()
// give time for the Peer to connect
time.Sleep(time.Second)
<-peer.Request("GREETING", "Paulo", func(reply string) {
fmt.Println("Reply:", reply)
})Details
Auto discovery is implemented by a UDP heartbeat that every node emits. When a node receives a heartbeat from a new node, it connects to it.
A node is implemented with a gomsg.Server (to make calls) and a list of gomsg.Client (to listen), one for each cluster node.
