| 1 | import time |
| 2 | |
| 3 | class Tera: |
| 4 | def __init__(self, ip, port, mode, log_prefix): |
| 5 | self.ip = ip |
| 6 | self.port = port |
| 7 | self.mode = mode |
| 8 | self.path = self.get_log_path(log_prefix) |
| 9 | |
| 10 | def get_log_path(self, log_prefix): |
| 11 | path = '{pre}/tera/{ip}-{port}-{mode}-{time}'.format(pre=log_prefix, ip=self.ip, port=self.port,\ |
| 12 | mode=self.mode, time=time.strftime('%Y%m%d%H%M%S')) |
| 13 | return path |
| 14 | |
| 15 | def to_string(self): |
| 16 | info = 'tera\t{ip}:{port}\t{mode}\tlog:{log}'.format(ip=self.ip, port=self.port, mode=self.mode, log=self.path) |
| 17 | return info |
| 18 | |
| 19 | def to_cmd(self, docker, zk, hdfs_master, hdfs_slave): |
| 20 | cmd = 'docker run -t -d -v {dir}:/opt/share -p {port}:{port} --net=host {docker} /usr/bin/python /opt/tera_setup.py \ |
| 21 | --ip {ip} --zk {zk} --port {port} --mode {mode} --hdfs_master {mip} --hdfs_slaves {sip}'.\ |
| 22 | format(dir=self.path, port=self.port, ip=self.ip, zk=zk, docker=docker, mode=self.mode, mip=hdfs_master, sip=hdfs_slave) |
| 23 | return cmd |
| 24 | |
| 25 | class TeraCluster(): |
| 26 | def __init__(self, ip_list, num_of_tera, log_prefix): |
no outgoing calls
no test coverage detected