A simple cluster server package for golang. The library uses ZeroMQ bindings for golang (https://github.com/pebbe/zmq4).

To install the package in your GOPATH just run the following command:

$ go get github.com/pforpallav/cluster-server

To use the library in your go-code import the package by adding this import line

import cluster "github.com/pforpallav/cluster-server"

Now you can access the interfaces, structs and functions by through cluster namespace.

func AddPeer(id int, config string) Server

id - Peer's id
config - .json file with configuration (sample file is config.json)

Starts a new peer in the cluster. The peer listens to address corresponding to the id mentioned in the config file. Returns a Server object.

type Server interface

Pid() int - Return self's Pid in the cluster.
Peers() []int - Return id's to all the peers in the cluster.
Outbox() chan *Envelope - Return the channel for outbox.
Inbox() chan *Envelope - Return the channel for inbox.

An interface to access basic information of the server.

type Envelope struct

Pid int - The Pid of the peer from/to which the message was recieved/sent.
MsgId int64 - Unique message id.
Msg interface{} - Actual message.

<src folder> $ go test

Testing with five servers. Multiple messages sent between themselves. Check for count. Check for message content.