Example Serf client in go

gistfile1.go

package main

import (
	"fmt"
	"strconv"
	"time"

	"github.com/hashicorp/serf/client"
)

// handler for user events
func handler(c chan map[string]interface{}) {

	for {
		data := <-c

		fmt.Printf("%v\n", data)
	}
}

func main() {
	conf := client.Config{Addr:"localhost:7373"}

	// connect our client
	client, err := client.ClientFromConfig(&conf)
	if err != nil {
		panic(nil)
	}


	// consume user events in another goroutine
	ch := make(chan map[string]interface{})
	client.Stream("user", ch)
	go handler(ch)

	// continually send user events
	i := 0
	for {
		err := client.UserEvent("test", []byte(strconv.Itoa(i)), false)
		if err != nil {
			panic(err)
		}

		time.Sleep(100 * time.Millisecond)
		i++
	}
}