serfin

Documentation

Overview

Package serfin bundles up serf functions for goiardi.

Index

• Variables
• func CloseAll()
• func CloseSerfClient(serfAddr string)
• func NewRPCClient(serfAddr string) (*serfclient.RPCClient, error)
• func Query(q *serfclient.QueryParam, errch chan<- error)
• func SendEvent(eventName string, payload interface{})
• func SendQuery(queryName string, payload interface{})
• func StartSerfin() error

Variables

var Serfer *serfclient.RPCClient

Serfer is the common serf client for goiardi. NB: moving away from doing it this way.

Functions

func CloseAll

func CloseAll()

CloseAll closes all active serf clients

func CloseSerfClient

func CloseSerfClient(serfAddr string)

CloseSerfClient closes one serf client.

func NewRPCClient

func NewRPCClient(serfAddr string) (*serfclient.RPCClient, error)

func Query

func Query(q *serfclient.QueryParam, errch chan<- error)

Query makes a query to the default serf client, reconnecting if it's been closed.

func SendEvent

func SendEvent(eventName string, payload interface{})

SendEvent sends a serf event out from goiardi.

func SendQuery

func SendQuery(queryName string, payload interface{})

SendQuery sends a basic, no frills query out over serf.

func StartSerfin

func StartSerfin() error

StartSerfin sets up the serf instance and starts listening for events and queries from other serf instances.