(id, node_id, worker_id)
| 79 | |
| 80 | |
| 81 | async def generate_actor_data(id, node_id, worker_id): |
| 82 | if worker_id: |
| 83 | worker_id = worker_id.binary() |
| 84 | message = ActorTableData( |
| 85 | actor_id=id.binary(), |
| 86 | state=ActorTableData.ActorState.ALIVE, |
| 87 | name="abc", |
| 88 | pid=1234, |
| 89 | class_name="class", |
| 90 | address=Address( |
| 91 | node_id=node_id.binary(), |
| 92 | ip_address="127.0.0.1", |
| 93 | port=1234, |
| 94 | worker_id=worker_id, |
| 95 | ), |
| 96 | ) |
| 97 | return message |
| 98 | |
| 99 | |
| 100 | # Unit Tests (Log Agent) |
no test coverage detected
searching dependent graphs…