 |
fuse_kafka
|
Public Member Functions | |
| def | impersonate |
| def | start_network |
| def | log_path |
| def | shell |
| def | clients_initialize |
| def | cmd |
| def | data_directories_cleanup |
| def | zookeeper_start |
| def | kafka_start |
| def | kafka_stop |
| def | zookeeper_stop |
| def | fuse_kafka_start |
| def | consumer_start |
| def | tearDown |
| def | setUp |
| def | check |
| def | get_consumed_events |
| def | write_to_log |
| def | components_start |
| def | test_basic |
| def | test_shutting_down_kafka |
| def | test_shutting_down_zookeeper |
| def | test_bringing_down_kafka |
| def | test_cutting_kafka |
| def | test_cutting_zookeeper |
| def | test_cutting_kafka_periodically |
Data Fields | |
| net | |
| kafka | |
| zookeeper | |
| fuse_kafka | |
| client | |
| hosts | |
| switch | |
| java_clients | |
| kafka_config | |
| fuse_kafka_path | |
| consumer | |
| launch | |
| stop | |
Utility to create a virtual network to test fuse kafka resiliancy
| def build.TestMininet.clients_initialize | ( | self | ) |
| def build.TestMininet.components_start | ( | self | ) |
| def build.TestMininet.consumer_start | ( | self | ) |
| def build.TestMininet.data_directories_cleanup | ( | self | ) |
| def build.TestMininet.fuse_kafka_start | ( | self | ) |
| def build.TestMininet.impersonate | ( | self, | |
inital_user = True |
|||
| ) |
| def build.TestMininet.kafka_start | ( | self | ) |
| def build.TestMininet.kafka_stop | ( | self | ) |
| def build.TestMininet.setUp | ( | self | ) |
| def build.TestMininet.shell | ( | self | ) |
| def build.TestMininet.start_network | ( | self | ) |
| def build.TestMininet.tearDown | ( | self | ) |
| def build.TestMininet.test_basic | ( | self | ) |
| def build.TestMininet.zookeeper_start | ( | self | ) |
| def build.TestMininet.zookeeper_stop | ( | self | ) |
1.7.6.1
