Versions in this module Expand all Collapse all v0 v0.4.1 Feb 3, 2014 v0.4.0 Jan 31, 2014 Changes in this version + type Member struct + Addr net.IP + DelegateCur uint8 + DelegateMax uint8 + DelegateMin uint8 + Name string + Port uint16 + ProtocolCur uint8 + ProtocolMax uint8 + ProtocolMin uint8 + Status string + Tags map[string]string + type RPCClient struct + func NewRPCClient(addr string) (*RPCClient, error) + func (c *RPCClient) Close() error + func (c *RPCClient) ForceLeave(node string) error + func (c *RPCClient) Join(addrs []string, replay bool) (int, error) + func (c *RPCClient) Leave() error + func (c *RPCClient) Members() ([]Member, error) + func (c *RPCClient) Monitor(level logutils.LogLevel, ch chan<- string) (StreamHandle, error) + func (c *RPCClient) Stop(handle StreamHandle) error + func (c *RPCClient) Stream(filter string, ch chan<- map[string]interface{}) (StreamHandle, error) + func (c *RPCClient) UserEvent(name string, payload []byte, coalesce bool) error + type StreamHandle uint64
Go to main page