Versions in this module Expand all Collapse all v1 v1.3.0-alpha.3 Apr 26, 2016 v1.2.3 Apr 22, 2016 Changes in this version + type AllMastersListener struct + func (a *AllMastersListener) OnMasterChanged(mi *mesos.MasterInfo) + func (a *AllMastersListener) UpdatedMasters(mi []*mesos.MasterInfo) + type Client struct + func NewClient(testZkPath string, initialChildren ...string) (mocked *Client, snaps chan []string, errs chan error) + func (m *Client) Data(path string) (a []byte, b error) + func (m *Client) Stop() + func (m *Client) Stopped() (a <-chan struct{}) + func (m *Client) WatchChildren(path string) (a string, b <-chan []string, c <-chan error) + type Connector struct + func NewConnector() *Connector + func (conn *Connector) Children(path string) ([]string, *zk.Stat, error) + func (conn *Connector) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error) + func (conn *Connector) Close() + func (conn *Connector) Get(path string) ([]byte, *zk.Stat, error)