Documentation ¶ Index ¶ func WhenZkHasSession(zkEvents <-chan zk.Event, fn func()) func WithTestZkCluster(t *testing.T, size int, fn func(zkServers []string)) func WithZk(t *testing.T, size int, defaultServer string, fn func(zkServers []string)) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func WhenZkHasSession ¶ func WhenZkHasSession(zkEvents <-chan zk.Event, fn func()) func WithTestZkCluster ¶ func WithTestZkCluster(t *testing.T, size int, fn func(zkServers []string)) func WithZk ¶ func WithZk(t *testing.T, size int, defaultServer string, fn func(zkServers []string)) WithZk allows for a default ZooKeeper address to be specified, and if the port is reachable that connection info will be used. Otherwise a full test cluster is launched (NB: this can take 6+ seconds). Types ¶ This section is empty. Source Files ¶ View all Source files with_zk.go zk_test_util.go Click to show internal directories. Click to hide internal directories.
Documentation
¶
Source Files