Versions in this module Expand all Collapse all v0 v0.1.2 Apr 17, 2015 v0.1.1 Apr 9, 2015 Changes in this version + type ChildWatcher func(*Client, string) + type Client struct + type Connector interface + Children func(string) ([]string, *zk.Stat, error) + ChildrenW func(string) ([]string, *zk.Stat, <-chan zk.Event, error) + Close func() + Get func(string) ([]byte, *zk.Stat, error) + type ErrorHandler func(*Client, error) + type Factory interface + type MasterDetector struct + func NewMasterDetector(zkurls string) (*MasterDetector, error) + func (md *MasterDetector) Cancel() + func (md *MasterDetector) Detect(f detector.MasterChanged) (err error) + func (md *MasterDetector) Done() <-chan struct{} + type MockConnector struct + func NewMockConnector() *MockConnector + func (conn *MockConnector) Children(path string) ([]string, *zk.Stat, error) + func (conn *MockConnector) ChildrenW(path string) ([]string, *zk.Stat, <-chan zk.Event, error) + func (conn *MockConnector) Close() + func (conn *MockConnector) Get(path string) ([]byte, *zk.Stat, error) + type MockMasterDetector struct + func NewMockMasterDetector(zkurls string) (*MockMasterDetector, error) + func (m *MockMasterDetector) ScheduleConnEvent(s zk.State) + func (m *MockMasterDetector) ScheduleSessEvent(t zk.EventType) + func (m *MockMasterDetector) Start()