HCE Project Python language Distributed Tasks Manager Application, Distributed Crawler Application and client API bindings.
2.0.0-chaika
Hierarchical Cluster Engine Python language binding
|
Go to the source code of this file.
Namespaces | |
ftests.ftest_scheduling_TTR | |
Functions | |
def | ftests.ftest_scheduling_TTR.create_new_task (taskId, command, delta_time) |
def | ftests.ftest_scheduling_TTR.create_get_tasks_status (taskId) |
def | ftests.ftest_scheduling_TTR.get_response_event (clientConnection, timeout) |
Variables | |
int | ftests.ftest_scheduling_TTR.taskId = 10 |
int | ftests.ftest_scheduling_TTR.delta_time = 30 |
int | ftests.ftest_scheduling_TTR.wait_response_timeout = 5000 |
string | ftests.ftest_scheduling_TTR.addr = "192.168.1.135:5501" |
ftests.ftest_scheduling_TTR.connectBuilder = ConnectionBuilderLight() | |
ftests.ftest_scheduling_TTR.eventBuilder = EventBuilder() | |
ftests.ftest_scheduling_TTR.client = connectBuilder.build(consts.CLIENT_CONNECT, addr, consts.TCP_TYPE) | |
ftests.ftest_scheduling_TTR.new_task_event = eventBuilder.build(EVENT_TYPES.NEW_TASK, create_new_task(taskId, "ls -la", delta_time)) | |
ftests.ftest_scheduling_TTR.get_tasks_status_event = eventBuilder.build(EVENT_TYPES.GET_TASK_STATUS, create_get_tasks_status(taskId)) | |
def | ftests.ftest_scheduling_TTR.response_event = get_response_event(client, wait_response_timeout) |
def | ftests.ftest_scheduling_TTR.taskManagerFields = response_event.eventObj[0] |