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
Constants ¶
This section is empty.
Variables ¶
View Source
var Serfer *serfclient.RPCClient
Serfer is the common serf client for goiardi. NB: moving away from doing it this way.
Functions ¶
func CloseSerfClient ¶ added in v0.11.7
func CloseSerfClient(serfAddr string)
CloseSerfClient closes one serf client.
func NewRPCClient ¶ added in v0.11.7
func NewRPCClient(serfAddr string) (*serfclient.RPCClient, error)
func Query ¶ added in v0.11.7
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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.