diff --git a/agent-node/agent_node/node.py b/agent-node/agent_node/node.py
index b1cb589..931f53b 100644
--- a/agent-node/agent_node/node.py
+++ b/agent-node/agent_node/node.py
@@ -62,14 +62,23 @@
ids = self.skills.get_active_ids()
# Use interval=None but ensure we have a baseline
cpu = psutil.cpu_percent(interval=1.0)
- mem = psutil.virtual_memory().percent
+ vmem = psutil.virtual_memory()
+ mem_percent = vmem.percent
+
+ # GB conversion
+ used_gb = vmem.used / (1024**3)
+ total_gb = vmem.total / (1024**3)
+
yield agent_pb2.Heartbeat(
node_id=self.node_id,
cpu_usage_percent=cpu,
- memory_usage_percent=mem,
+ memory_usage_percent=mem_percent,
active_worker_count=len(ids),
max_worker_capacity=MAX_SKILL_WORKERS,
- running_task_ids=ids
+ running_task_ids=ids,
+ cpu_count=psutil.cpu_count(),
+ memory_used_gb=used_gb,
+ memory_total_gb=total_gb
)
time.sleep(max(0, HEALTH_REPORT_INTERVAL - 1.0))
diff --git a/agent-node/protos/agent.proto b/agent-node/protos/agent.proto
index 96cac03..8d03710 100644
--- a/agent-node/protos/agent.proto
+++ b/agent-node/protos/agent.proto
@@ -194,6 +194,9 @@
int32 max_worker_capacity = 5;
string status_message = 6;
repeated string running_task_ids = 7;
+ int32 cpu_count = 8;
+ float memory_used_gb = 9;
+ float memory_total_gb = 10;
}
message HealthCheckResponse {
diff --git a/agent-node/protos/agent_pb2.py b/agent-node/protos/agent_pb2.py
index e510875..21015d1 100644
--- a/agent-node/protos/agent_pb2.py
+++ b/agent-node/protos/agent_pb2.py
@@ -1,6 +1,6 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
-# source: protos/agent.proto
+# source: agent.proto
# Protobuf Python Version: 4.25.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
@@ -14,83 +14,83 @@
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x12protos/agent.proto\x12\x05\x61gent\"\xde\x01\n\x13RegistrationRequest\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x12\n\nauth_token\x18\x03 \x01(\t\x12\x18\n\x10node_description\x18\x04 \x01(\t\x12\x42\n\x0c\x63\x61pabilities\x18\x05 \x03(\x0b\x32,.agent.RegistrationRequest.CapabilitiesEntry\x1a\x33\n\x11\x43\x61pabilitiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xc5\x01\n\rSandboxPolicy\x12\'\n\x04mode\x18\x01 \x01(\x0e\x32\x19.agent.SandboxPolicy.Mode\x12\x18\n\x10\x61llowed_commands\x18\x02 \x03(\t\x12\x17\n\x0f\x64\x65nied_commands\x18\x03 \x03(\t\x12\x1a\n\x12sensitive_commands\x18\x04 \x03(\t\x12\x18\n\x10working_dir_jail\x18\x05 \x01(\t\"\"\n\x04Mode\x12\n\n\x06STRICT\x10\x00\x12\x0e\n\nPERMISSIVE\x10\x01\"x\n\x14RegistrationResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12$\n\x06policy\x18\x04 \x01(\x0b\x32\x14.agent.SandboxPolicy\"\xa9\x02\n\x11\x43lientTaskMessage\x12,\n\rtask_response\x18\x01 \x01(\x0b\x32\x13.agent.TaskResponseH\x00\x12-\n\ntask_claim\x18\x02 \x01(\x0b\x32\x17.agent.TaskClaimRequestH\x00\x12,\n\rbrowser_event\x18\x03 \x01(\x0b\x32\x13.agent.BrowserEventH\x00\x12\'\n\x08\x61nnounce\x18\x04 \x01(\x0b\x32\x13.agent.NodeAnnounceH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x12(\n\x0bskill_event\x18\x06 \x01(\x0b\x32\x11.agent.SkillEventH\x00\x42\t\n\x07payload\"y\n\nSkillEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12\x0f\n\x07task_id\x18\x02 \x01(\t\x12\x16\n\x0cterminal_out\x18\x03 \x01(\tH\x00\x12\x10\n\x06prompt\x18\x04 \x01(\tH\x00\x12\x14\n\nkeep_alive\x18\x05 \x01(\x08H\x00\x42\x06\n\x04\x64\x61ta\"\x1f\n\x0cNodeAnnounce\x12\x0f\n\x07node_id\x18\x01 \x01(\t\"\x87\x01\n\x0c\x42rowserEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x0b\x63onsole_msg\x18\x02 \x01(\x0b\x32\x15.agent.ConsoleMessageH\x00\x12,\n\x0bnetwork_req\x18\x03 \x01(\x0b\x32\x15.agent.NetworkRequestH\x00\x42\x07\n\x05\x65vent\"\x8d\x02\n\x11ServerTaskMessage\x12*\n\x0ctask_request\x18\x01 \x01(\x0b\x32\x12.agent.TaskRequestH\x00\x12\x31\n\x10work_pool_update\x18\x02 \x01(\x0b\x32\x15.agent.WorkPoolUpdateH\x00\x12\x30\n\x0c\x63laim_status\x18\x03 \x01(\x0b\x32\x18.agent.TaskClaimResponseH\x00\x12/\n\x0btask_cancel\x18\x04 \x01(\x0b\x32\x18.agent.TaskCancelRequestH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x42\t\n\x07payload\"$\n\x11TaskCancelRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\"\xd1\x01\n\x0bTaskRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x11\n\ttask_type\x18\x02 \x01(\t\x12\x16\n\x0cpayload_json\x18\x03 \x01(\tH\x00\x12.\n\x0e\x62rowser_action\x18\x07 \x01(\x0b\x32\x14.agent.BrowserActionH\x00\x12\x12\n\ntimeout_ms\x18\x04 \x01(\x05\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x11\n\tsignature\x18\x06 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\tB\t\n\x07payload\"\xa0\x02\n\rBrowserAction\x12/\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x1f.agent.BrowserAction.ActionType\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x10\n\x08selector\x18\x03 \x01(\t\x12\x0c\n\x04text\x18\x04 \x01(\t\x12\x12\n\nsession_id\x18\x05 \x01(\t\x12\t\n\x01x\x18\x06 \x01(\x05\x12\t\n\x01y\x18\x07 \x01(\x05\"\x86\x01\n\nActionType\x12\x0c\n\x08NAVIGATE\x10\x00\x12\t\n\x05\x43LICK\x10\x01\x12\x08\n\x04TYPE\x10\x02\x12\x0e\n\nSCREENSHOT\x10\x03\x12\x0b\n\x07GET_DOM\x10\x04\x12\t\n\x05HOVER\x10\x05\x12\n\n\x06SCROLL\x10\x06\x12\t\n\x05\x43LOSE\x10\x07\x12\x08\n\x04\x45VAL\x10\x08\x12\x0c\n\x08GET_A11Y\x10\t\"\xe0\x02\n\x0cTaskResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12*\n\x06status\x18\x02 \x01(\x0e\x32\x1a.agent.TaskResponse.Status\x12\x0e\n\x06stdout\x18\x03 \x01(\t\x12\x0e\n\x06stderr\x18\x04 \x01(\t\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x35\n\tartifacts\x18\x06 \x03(\x0b\x32\".agent.TaskResponse.ArtifactsEntry\x12\x30\n\x0e\x62rowser_result\x18\x07 \x01(\x0b\x32\x16.agent.BrowserResponseH\x00\x1a\x30\n\x0e\x41rtifactsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"<\n\x06Status\x12\x0b\n\x07SUCCESS\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x0b\n\x07TIMEOUT\x10\x02\x12\r\n\tCANCELLED\x10\x03\x42\x08\n\x06result\"\xdc\x01\n\x0f\x42rowserResponse\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\r\n\x05title\x18\x02 \x01(\t\x12\x10\n\x08snapshot\x18\x03 \x01(\x0c\x12\x13\n\x0b\x64om_content\x18\x04 \x01(\t\x12\x11\n\ta11y_tree\x18\x05 \x01(\t\x12\x13\n\x0b\x65val_result\x18\x06 \x01(\t\x12.\n\x0f\x63onsole_history\x18\x07 \x03(\x0b\x32\x15.agent.ConsoleMessage\x12.\n\x0fnetwork_history\x18\x08 \x03(\x0b\x32\x15.agent.NetworkRequest\"C\n\x0e\x43onsoleMessage\x12\r\n\x05level\x18\x01 \x01(\t\x12\x0c\n\x04text\x18\x02 \x01(\t\x12\x14\n\x0ctimestamp_ms\x18\x03 \x01(\x03\"h\n\x0eNetworkRequest\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\x05\x12\x15\n\rresource_type\x18\x04 \x01(\t\x12\x12\n\nlatency_ms\x18\x05 \x01(\x03\",\n\x0eWorkPoolUpdate\x12\x1a\n\x12\x61vailable_task_ids\x18\x01 \x03(\t\"4\n\x10TaskClaimRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07node_id\x18\x02 \x01(\t\"E\n\x11TaskClaimResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07granted\x18\x02 \x01(\x08\x12\x0e\n\x06reason\x18\x03 \x01(\t\"\xc1\x01\n\tHeartbeat\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x19\n\x11\x63pu_usage_percent\x18\x02 \x01(\x02\x12\x1c\n\x14memory_usage_percent\x18\x03 \x01(\x02\x12\x1b\n\x13\x61\x63tive_worker_count\x18\x04 \x01(\x05\x12\x1b\n\x13max_worker_capacity\x18\x05 \x01(\x05\x12\x16\n\x0estatus_message\x18\x06 \x01(\t\x12\x18\n\x10running_task_ids\x18\x07 \x03(\t\"-\n\x13HealthCheckResponse\x12\x16\n\x0eserver_time_ms\x18\x01 \x01(\x03\"\xe4\x01\n\x0f\x46ileSyncMessage\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x08manifest\x18\x02 \x01(\x0b\x32\x18.agent.DirectoryManifestH\x00\x12\'\n\tfile_data\x18\x03 \x01(\x0b\x32\x12.agent.FilePayloadH\x00\x12#\n\x06status\x18\x04 \x01(\x0b\x32\x11.agent.SyncStatusH\x00\x12%\n\x07\x63ontrol\x18\x05 \x01(\x0b\x32\x12.agent.SyncControlH\x00\x12\x0f\n\x07task_id\x18\x06 \x01(\tB\t\n\x07payload\"\x93\x02\n\x0bSyncControl\x12)\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x19.agent.SyncControl.Action\x12\x0c\n\x04path\x18\x02 \x01(\t\x12\x15\n\rrequest_paths\x18\x03 \x03(\t\x12\x0f\n\x07\x63ontent\x18\x04 \x01(\x0c\x12\x0e\n\x06is_dir\x18\x05 \x01(\x08\"\x92\x01\n\x06\x41\x63tion\x12\x12\n\x0eSTART_WATCHING\x10\x00\x12\x11\n\rSTOP_WATCHING\x10\x01\x12\x08\n\x04LOCK\x10\x02\x12\n\n\x06UNLOCK\x10\x03\x12\x14\n\x10REFRESH_MANIFEST\x10\x04\x12\n\n\x06RESYNC\x10\x05\x12\x08\n\x04LIST\x10\x06\x12\x08\n\x04READ\x10\x07\x12\t\n\x05WRITE\x10\x08\x12\n\n\x06\x44\x45LETE\x10\t\"F\n\x11\x44irectoryManifest\x12\x11\n\troot_path\x18\x01 \x01(\t\x12\x1e\n\x05\x66iles\x18\x02 \x03(\x0b\x32\x0f.agent.FileInfo\"D\n\x08\x46ileInfo\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0c\n\x04size\x18\x02 \x01(\x03\x12\x0c\n\x04hash\x18\x03 \x01(\t\x12\x0e\n\x06is_dir\x18\x04 \x01(\x08\"_\n\x0b\x46ilePayload\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\x12\x13\n\x0b\x63hunk_index\x18\x03 \x01(\x05\x12\x10\n\x08is_final\x18\x04 \x01(\x08\x12\x0c\n\x04hash\x18\x05 \x01(\t\"\xa0\x01\n\nSyncStatus\x12$\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x16.agent.SyncStatus.Code\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x17\n\x0freconcile_paths\x18\x03 \x03(\t\"B\n\x04\x43ode\x12\x06\n\x02OK\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x16\n\x12RECONCILE_REQUIRED\x10\x02\x12\x0f\n\x0bIN_PROGRESS\x10\x03\x32\xe9\x01\n\x11\x41gentOrchestrator\x12L\n\x11SyncConfiguration\x12\x1a.agent.RegistrationRequest\x1a\x1b.agent.RegistrationResponse\x12\x44\n\nTaskStream\x12\x18.agent.ClientTaskMessage\x1a\x18.agent.ServerTaskMessage(\x01\x30\x01\x12@\n\x0cReportHealth\x12\x10.agent.Heartbeat\x1a\x1a.agent.HealthCheckResponse(\x01\x30\x01\x62\x06proto3')
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0b\x61gent.proto\x12\x05\x61gent\"\xde\x01\n\x13RegistrationRequest\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x12\n\nauth_token\x18\x03 \x01(\t\x12\x18\n\x10node_description\x18\x04 \x01(\t\x12\x42\n\x0c\x63\x61pabilities\x18\x05 \x03(\x0b\x32,.agent.RegistrationRequest.CapabilitiesEntry\x1a\x33\n\x11\x43\x61pabilitiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xc5\x01\n\rSandboxPolicy\x12\'\n\x04mode\x18\x01 \x01(\x0e\x32\x19.agent.SandboxPolicy.Mode\x12\x18\n\x10\x61llowed_commands\x18\x02 \x03(\t\x12\x17\n\x0f\x64\x65nied_commands\x18\x03 \x03(\t\x12\x1a\n\x12sensitive_commands\x18\x04 \x03(\t\x12\x18\n\x10working_dir_jail\x18\x05 \x01(\t\"\"\n\x04Mode\x12\n\n\x06STRICT\x10\x00\x12\x0e\n\nPERMISSIVE\x10\x01\"x\n\x14RegistrationResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12$\n\x06policy\x18\x04 \x01(\x0b\x32\x14.agent.SandboxPolicy\"\xa9\x02\n\x11\x43lientTaskMessage\x12,\n\rtask_response\x18\x01 \x01(\x0b\x32\x13.agent.TaskResponseH\x00\x12-\n\ntask_claim\x18\x02 \x01(\x0b\x32\x17.agent.TaskClaimRequestH\x00\x12,\n\rbrowser_event\x18\x03 \x01(\x0b\x32\x13.agent.BrowserEventH\x00\x12\'\n\x08\x61nnounce\x18\x04 \x01(\x0b\x32\x13.agent.NodeAnnounceH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x12(\n\x0bskill_event\x18\x06 \x01(\x0b\x32\x11.agent.SkillEventH\x00\x42\t\n\x07payload\"y\n\nSkillEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12\x0f\n\x07task_id\x18\x02 \x01(\t\x12\x16\n\x0cterminal_out\x18\x03 \x01(\tH\x00\x12\x10\n\x06prompt\x18\x04 \x01(\tH\x00\x12\x14\n\nkeep_alive\x18\x05 \x01(\x08H\x00\x42\x06\n\x04\x64\x61ta\"\x1f\n\x0cNodeAnnounce\x12\x0f\n\x07node_id\x18\x01 \x01(\t\"\x87\x01\n\x0c\x42rowserEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x0b\x63onsole_msg\x18\x02 \x01(\x0b\x32\x15.agent.ConsoleMessageH\x00\x12,\n\x0bnetwork_req\x18\x03 \x01(\x0b\x32\x15.agent.NetworkRequestH\x00\x42\x07\n\x05\x65vent\"\x8d\x02\n\x11ServerTaskMessage\x12*\n\x0ctask_request\x18\x01 \x01(\x0b\x32\x12.agent.TaskRequestH\x00\x12\x31\n\x10work_pool_update\x18\x02 \x01(\x0b\x32\x15.agent.WorkPoolUpdateH\x00\x12\x30\n\x0c\x63laim_status\x18\x03 \x01(\x0b\x32\x18.agent.TaskClaimResponseH\x00\x12/\n\x0btask_cancel\x18\x04 \x01(\x0b\x32\x18.agent.TaskCancelRequestH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x42\t\n\x07payload\"$\n\x11TaskCancelRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\"\xd1\x01\n\x0bTaskRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x11\n\ttask_type\x18\x02 \x01(\t\x12\x16\n\x0cpayload_json\x18\x03 \x01(\tH\x00\x12.\n\x0e\x62rowser_action\x18\x07 \x01(\x0b\x32\x14.agent.BrowserActionH\x00\x12\x12\n\ntimeout_ms\x18\x04 \x01(\x05\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x11\n\tsignature\x18\x06 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\tB\t\n\x07payload\"\xa0\x02\n\rBrowserAction\x12/\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x1f.agent.BrowserAction.ActionType\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x10\n\x08selector\x18\x03 \x01(\t\x12\x0c\n\x04text\x18\x04 \x01(\t\x12\x12\n\nsession_id\x18\x05 \x01(\t\x12\t\n\x01x\x18\x06 \x01(\x05\x12\t\n\x01y\x18\x07 \x01(\x05\"\x86\x01\n\nActionType\x12\x0c\n\x08NAVIGATE\x10\x00\x12\t\n\x05\x43LICK\x10\x01\x12\x08\n\x04TYPE\x10\x02\x12\x0e\n\nSCREENSHOT\x10\x03\x12\x0b\n\x07GET_DOM\x10\x04\x12\t\n\x05HOVER\x10\x05\x12\n\n\x06SCROLL\x10\x06\x12\t\n\x05\x43LOSE\x10\x07\x12\x08\n\x04\x45VAL\x10\x08\x12\x0c\n\x08GET_A11Y\x10\t\"\xe0\x02\n\x0cTaskResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12*\n\x06status\x18\x02 \x01(\x0e\x32\x1a.agent.TaskResponse.Status\x12\x0e\n\x06stdout\x18\x03 \x01(\t\x12\x0e\n\x06stderr\x18\x04 \x01(\t\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x35\n\tartifacts\x18\x06 \x03(\x0b\x32\".agent.TaskResponse.ArtifactsEntry\x12\x30\n\x0e\x62rowser_result\x18\x07 \x01(\x0b\x32\x16.agent.BrowserResponseH\x00\x1a\x30\n\x0e\x41rtifactsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"<\n\x06Status\x12\x0b\n\x07SUCCESS\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x0b\n\x07TIMEOUT\x10\x02\x12\r\n\tCANCELLED\x10\x03\x42\x08\n\x06result\"\xdc\x01\n\x0f\x42rowserResponse\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\r\n\x05title\x18\x02 \x01(\t\x12\x10\n\x08snapshot\x18\x03 \x01(\x0c\x12\x13\n\x0b\x64om_content\x18\x04 \x01(\t\x12\x11\n\ta11y_tree\x18\x05 \x01(\t\x12\x13\n\x0b\x65val_result\x18\x06 \x01(\t\x12.\n\x0f\x63onsole_history\x18\x07 \x03(\x0b\x32\x15.agent.ConsoleMessage\x12.\n\x0fnetwork_history\x18\x08 \x03(\x0b\x32\x15.agent.NetworkRequest\"C\n\x0e\x43onsoleMessage\x12\r\n\x05level\x18\x01 \x01(\t\x12\x0c\n\x04text\x18\x02 \x01(\t\x12\x14\n\x0ctimestamp_ms\x18\x03 \x01(\x03\"h\n\x0eNetworkRequest\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\x05\x12\x15\n\rresource_type\x18\x04 \x01(\t\x12\x12\n\nlatency_ms\x18\x05 \x01(\x03\",\n\x0eWorkPoolUpdate\x12\x1a\n\x12\x61vailable_task_ids\x18\x01 \x03(\t\"4\n\x10TaskClaimRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07node_id\x18\x02 \x01(\t\"E\n\x11TaskClaimResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07granted\x18\x02 \x01(\x08\x12\x0e\n\x06reason\x18\x03 \x01(\t\"\x85\x02\n\tHeartbeat\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x19\n\x11\x63pu_usage_percent\x18\x02 \x01(\x02\x12\x1c\n\x14memory_usage_percent\x18\x03 \x01(\x02\x12\x1b\n\x13\x61\x63tive_worker_count\x18\x04 \x01(\x05\x12\x1b\n\x13max_worker_capacity\x18\x05 \x01(\x05\x12\x16\n\x0estatus_message\x18\x06 \x01(\t\x12\x18\n\x10running_task_ids\x18\x07 \x03(\t\x12\x11\n\tcpu_count\x18\x08 \x01(\x05\x12\x16\n\x0ememory_used_gb\x18\t \x01(\x02\x12\x17\n\x0fmemory_total_gb\x18\n \x01(\x02\"-\n\x13HealthCheckResponse\x12\x16\n\x0eserver_time_ms\x18\x01 \x01(\x03\"\xe4\x01\n\x0f\x46ileSyncMessage\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x08manifest\x18\x02 \x01(\x0b\x32\x18.agent.DirectoryManifestH\x00\x12\'\n\tfile_data\x18\x03 \x01(\x0b\x32\x12.agent.FilePayloadH\x00\x12#\n\x06status\x18\x04 \x01(\x0b\x32\x11.agent.SyncStatusH\x00\x12%\n\x07\x63ontrol\x18\x05 \x01(\x0b\x32\x12.agent.SyncControlH\x00\x12\x0f\n\x07task_id\x18\x06 \x01(\tB\t\n\x07payload\"\x93\x02\n\x0bSyncControl\x12)\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x19.agent.SyncControl.Action\x12\x0c\n\x04path\x18\x02 \x01(\t\x12\x15\n\rrequest_paths\x18\x03 \x03(\t\x12\x0f\n\x07\x63ontent\x18\x04 \x01(\x0c\x12\x0e\n\x06is_dir\x18\x05 \x01(\x08\"\x92\x01\n\x06\x41\x63tion\x12\x12\n\x0eSTART_WATCHING\x10\x00\x12\x11\n\rSTOP_WATCHING\x10\x01\x12\x08\n\x04LOCK\x10\x02\x12\n\n\x06UNLOCK\x10\x03\x12\x14\n\x10REFRESH_MANIFEST\x10\x04\x12\n\n\x06RESYNC\x10\x05\x12\x08\n\x04LIST\x10\x06\x12\x08\n\x04READ\x10\x07\x12\t\n\x05WRITE\x10\x08\x12\n\n\x06\x44\x45LETE\x10\t\"F\n\x11\x44irectoryManifest\x12\x11\n\troot_path\x18\x01 \x01(\t\x12\x1e\n\x05\x66iles\x18\x02 \x03(\x0b\x32\x0f.agent.FileInfo\"D\n\x08\x46ileInfo\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0c\n\x04size\x18\x02 \x01(\x03\x12\x0c\n\x04hash\x18\x03 \x01(\t\x12\x0e\n\x06is_dir\x18\x04 \x01(\x08\"_\n\x0b\x46ilePayload\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\x12\x13\n\x0b\x63hunk_index\x18\x03 \x01(\x05\x12\x10\n\x08is_final\x18\x04 \x01(\x08\x12\x0c\n\x04hash\x18\x05 \x01(\t\"\xa0\x01\n\nSyncStatus\x12$\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x16.agent.SyncStatus.Code\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x17\n\x0freconcile_paths\x18\x03 \x03(\t\"B\n\x04\x43ode\x12\x06\n\x02OK\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x16\n\x12RECONCILE_REQUIRED\x10\x02\x12\x0f\n\x0bIN_PROGRESS\x10\x03\x32\xe9\x01\n\x11\x41gentOrchestrator\x12L\n\x11SyncConfiguration\x12\x1a.agent.RegistrationRequest\x1a\x1b.agent.RegistrationResponse\x12\x44\n\nTaskStream\x12\x18.agent.ClientTaskMessage\x1a\x18.agent.ServerTaskMessage(\x01\x30\x01\x12@\n\x0cReportHealth\x12\x10.agent.Heartbeat\x1a\x1a.agent.HealthCheckResponse(\x01\x30\x01\x62\x06proto3')
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
-_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'protos.agent_pb2', _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'agent_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
_globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._options = None
_globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_options = b'8\001'
_globals['_TASKRESPONSE_ARTIFACTSENTRY']._options = None
_globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_options = b'8\001'
- _globals['_REGISTRATIONREQUEST']._serialized_start=30
- _globals['_REGISTRATIONREQUEST']._serialized_end=252
- _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_start=201
- _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_end=252
- _globals['_SANDBOXPOLICY']._serialized_start=255
- _globals['_SANDBOXPOLICY']._serialized_end=452
- _globals['_SANDBOXPOLICY_MODE']._serialized_start=418
- _globals['_SANDBOXPOLICY_MODE']._serialized_end=452
- _globals['_REGISTRATIONRESPONSE']._serialized_start=454
- _globals['_REGISTRATIONRESPONSE']._serialized_end=574
- _globals['_CLIENTTASKMESSAGE']._serialized_start=577
- _globals['_CLIENTTASKMESSAGE']._serialized_end=874
- _globals['_SKILLEVENT']._serialized_start=876
- _globals['_SKILLEVENT']._serialized_end=997
- _globals['_NODEANNOUNCE']._serialized_start=999
- _globals['_NODEANNOUNCE']._serialized_end=1030
- _globals['_BROWSEREVENT']._serialized_start=1033
- _globals['_BROWSEREVENT']._serialized_end=1168
- _globals['_SERVERTASKMESSAGE']._serialized_start=1171
- _globals['_SERVERTASKMESSAGE']._serialized_end=1440
- _globals['_TASKCANCELREQUEST']._serialized_start=1442
- _globals['_TASKCANCELREQUEST']._serialized_end=1478
- _globals['_TASKREQUEST']._serialized_start=1481
- _globals['_TASKREQUEST']._serialized_end=1690
- _globals['_BROWSERACTION']._serialized_start=1693
- _globals['_BROWSERACTION']._serialized_end=1981
- _globals['_BROWSERACTION_ACTIONTYPE']._serialized_start=1847
- _globals['_BROWSERACTION_ACTIONTYPE']._serialized_end=1981
- _globals['_TASKRESPONSE']._serialized_start=1984
- _globals['_TASKRESPONSE']._serialized_end=2336
- _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_start=2216
- _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_end=2264
- _globals['_TASKRESPONSE_STATUS']._serialized_start=2266
- _globals['_TASKRESPONSE_STATUS']._serialized_end=2326
- _globals['_BROWSERRESPONSE']._serialized_start=2339
- _globals['_BROWSERRESPONSE']._serialized_end=2559
- _globals['_CONSOLEMESSAGE']._serialized_start=2561
- _globals['_CONSOLEMESSAGE']._serialized_end=2628
- _globals['_NETWORKREQUEST']._serialized_start=2630
- _globals['_NETWORKREQUEST']._serialized_end=2734
- _globals['_WORKPOOLUPDATE']._serialized_start=2736
- _globals['_WORKPOOLUPDATE']._serialized_end=2780
- _globals['_TASKCLAIMREQUEST']._serialized_start=2782
- _globals['_TASKCLAIMREQUEST']._serialized_end=2834
- _globals['_TASKCLAIMRESPONSE']._serialized_start=2836
- _globals['_TASKCLAIMRESPONSE']._serialized_end=2905
- _globals['_HEARTBEAT']._serialized_start=2908
- _globals['_HEARTBEAT']._serialized_end=3101
- _globals['_HEALTHCHECKRESPONSE']._serialized_start=3103
- _globals['_HEALTHCHECKRESPONSE']._serialized_end=3148
- _globals['_FILESYNCMESSAGE']._serialized_start=3151
- _globals['_FILESYNCMESSAGE']._serialized_end=3379
- _globals['_SYNCCONTROL']._serialized_start=3382
- _globals['_SYNCCONTROL']._serialized_end=3657
- _globals['_SYNCCONTROL_ACTION']._serialized_start=3511
- _globals['_SYNCCONTROL_ACTION']._serialized_end=3657
- _globals['_DIRECTORYMANIFEST']._serialized_start=3659
- _globals['_DIRECTORYMANIFEST']._serialized_end=3729
- _globals['_FILEINFO']._serialized_start=3731
- _globals['_FILEINFO']._serialized_end=3799
- _globals['_FILEPAYLOAD']._serialized_start=3801
- _globals['_FILEPAYLOAD']._serialized_end=3896
- _globals['_SYNCSTATUS']._serialized_start=3899
- _globals['_SYNCSTATUS']._serialized_end=4059
- _globals['_SYNCSTATUS_CODE']._serialized_start=3993
- _globals['_SYNCSTATUS_CODE']._serialized_end=4059
- _globals['_AGENTORCHESTRATOR']._serialized_start=4062
- _globals['_AGENTORCHESTRATOR']._serialized_end=4295
+ _globals['_REGISTRATIONREQUEST']._serialized_start=23
+ _globals['_REGISTRATIONREQUEST']._serialized_end=245
+ _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_start=194
+ _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_end=245
+ _globals['_SANDBOXPOLICY']._serialized_start=248
+ _globals['_SANDBOXPOLICY']._serialized_end=445
+ _globals['_SANDBOXPOLICY_MODE']._serialized_start=411
+ _globals['_SANDBOXPOLICY_MODE']._serialized_end=445
+ _globals['_REGISTRATIONRESPONSE']._serialized_start=447
+ _globals['_REGISTRATIONRESPONSE']._serialized_end=567
+ _globals['_CLIENTTASKMESSAGE']._serialized_start=570
+ _globals['_CLIENTTASKMESSAGE']._serialized_end=867
+ _globals['_SKILLEVENT']._serialized_start=869
+ _globals['_SKILLEVENT']._serialized_end=990
+ _globals['_NODEANNOUNCE']._serialized_start=992
+ _globals['_NODEANNOUNCE']._serialized_end=1023
+ _globals['_BROWSEREVENT']._serialized_start=1026
+ _globals['_BROWSEREVENT']._serialized_end=1161
+ _globals['_SERVERTASKMESSAGE']._serialized_start=1164
+ _globals['_SERVERTASKMESSAGE']._serialized_end=1433
+ _globals['_TASKCANCELREQUEST']._serialized_start=1435
+ _globals['_TASKCANCELREQUEST']._serialized_end=1471
+ _globals['_TASKREQUEST']._serialized_start=1474
+ _globals['_TASKREQUEST']._serialized_end=1683
+ _globals['_BROWSERACTION']._serialized_start=1686
+ _globals['_BROWSERACTION']._serialized_end=1974
+ _globals['_BROWSERACTION_ACTIONTYPE']._serialized_start=1840
+ _globals['_BROWSERACTION_ACTIONTYPE']._serialized_end=1974
+ _globals['_TASKRESPONSE']._serialized_start=1977
+ _globals['_TASKRESPONSE']._serialized_end=2329
+ _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_start=2209
+ _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_end=2257
+ _globals['_TASKRESPONSE_STATUS']._serialized_start=2259
+ _globals['_TASKRESPONSE_STATUS']._serialized_end=2319
+ _globals['_BROWSERRESPONSE']._serialized_start=2332
+ _globals['_BROWSERRESPONSE']._serialized_end=2552
+ _globals['_CONSOLEMESSAGE']._serialized_start=2554
+ _globals['_CONSOLEMESSAGE']._serialized_end=2621
+ _globals['_NETWORKREQUEST']._serialized_start=2623
+ _globals['_NETWORKREQUEST']._serialized_end=2727
+ _globals['_WORKPOOLUPDATE']._serialized_start=2729
+ _globals['_WORKPOOLUPDATE']._serialized_end=2773
+ _globals['_TASKCLAIMREQUEST']._serialized_start=2775
+ _globals['_TASKCLAIMREQUEST']._serialized_end=2827
+ _globals['_TASKCLAIMRESPONSE']._serialized_start=2829
+ _globals['_TASKCLAIMRESPONSE']._serialized_end=2898
+ _globals['_HEARTBEAT']._serialized_start=2901
+ _globals['_HEARTBEAT']._serialized_end=3162
+ _globals['_HEALTHCHECKRESPONSE']._serialized_start=3164
+ _globals['_HEALTHCHECKRESPONSE']._serialized_end=3209
+ _globals['_FILESYNCMESSAGE']._serialized_start=3212
+ _globals['_FILESYNCMESSAGE']._serialized_end=3440
+ _globals['_SYNCCONTROL']._serialized_start=3443
+ _globals['_SYNCCONTROL']._serialized_end=3718
+ _globals['_SYNCCONTROL_ACTION']._serialized_start=3572
+ _globals['_SYNCCONTROL_ACTION']._serialized_end=3718
+ _globals['_DIRECTORYMANIFEST']._serialized_start=3720
+ _globals['_DIRECTORYMANIFEST']._serialized_end=3790
+ _globals['_FILEINFO']._serialized_start=3792
+ _globals['_FILEINFO']._serialized_end=3860
+ _globals['_FILEPAYLOAD']._serialized_start=3862
+ _globals['_FILEPAYLOAD']._serialized_end=3957
+ _globals['_SYNCSTATUS']._serialized_start=3960
+ _globals['_SYNCSTATUS']._serialized_end=4120
+ _globals['_SYNCSTATUS_CODE']._serialized_start=4054
+ _globals['_SYNCSTATUS_CODE']._serialized_end=4120
+ _globals['_AGENTORCHESTRATOR']._serialized_start=4123
+ _globals['_AGENTORCHESTRATOR']._serialized_end=4356
# @@protoc_insertion_point(module_scope)
diff --git a/agent-node/protos/agent_pb2_grpc.py b/agent-node/protos/agent_pb2_grpc.py
index f551b0b..932d45e 100644
--- a/agent-node/protos/agent_pb2_grpc.py
+++ b/agent-node/protos/agent_pb2_grpc.py
@@ -2,7 +2,7 @@
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
-from protos import agent_pb2 as protos_dot_agent__pb2
+import agent_pb2 as agent__pb2
class AgentOrchestratorStub(object):
@@ -17,18 +17,18 @@
"""
self.SyncConfiguration = channel.unary_unary(
'/agent.AgentOrchestrator/SyncConfiguration',
- request_serializer=protos_dot_agent__pb2.RegistrationRequest.SerializeToString,
- response_deserializer=protos_dot_agent__pb2.RegistrationResponse.FromString,
+ request_serializer=agent__pb2.RegistrationRequest.SerializeToString,
+ response_deserializer=agent__pb2.RegistrationResponse.FromString,
)
self.TaskStream = channel.stream_stream(
'/agent.AgentOrchestrator/TaskStream',
- request_serializer=protos_dot_agent__pb2.ClientTaskMessage.SerializeToString,
- response_deserializer=protos_dot_agent__pb2.ServerTaskMessage.FromString,
+ request_serializer=agent__pb2.ClientTaskMessage.SerializeToString,
+ response_deserializer=agent__pb2.ServerTaskMessage.FromString,
)
self.ReportHealth = channel.stream_stream(
'/agent.AgentOrchestrator/ReportHealth',
- request_serializer=protos_dot_agent__pb2.Heartbeat.SerializeToString,
- response_deserializer=protos_dot_agent__pb2.HealthCheckResponse.FromString,
+ request_serializer=agent__pb2.Heartbeat.SerializeToString,
+ response_deserializer=agent__pb2.HealthCheckResponse.FromString,
)
@@ -62,18 +62,18 @@
rpc_method_handlers = {
'SyncConfiguration': grpc.unary_unary_rpc_method_handler(
servicer.SyncConfiguration,
- request_deserializer=protos_dot_agent__pb2.RegistrationRequest.FromString,
- response_serializer=protos_dot_agent__pb2.RegistrationResponse.SerializeToString,
+ request_deserializer=agent__pb2.RegistrationRequest.FromString,
+ response_serializer=agent__pb2.RegistrationResponse.SerializeToString,
),
'TaskStream': grpc.stream_stream_rpc_method_handler(
servicer.TaskStream,
- request_deserializer=protos_dot_agent__pb2.ClientTaskMessage.FromString,
- response_serializer=protos_dot_agent__pb2.ServerTaskMessage.SerializeToString,
+ request_deserializer=agent__pb2.ClientTaskMessage.FromString,
+ response_serializer=agent__pb2.ServerTaskMessage.SerializeToString,
),
'ReportHealth': grpc.stream_stream_rpc_method_handler(
servicer.ReportHealth,
- request_deserializer=protos_dot_agent__pb2.Heartbeat.FromString,
- response_serializer=protos_dot_agent__pb2.HealthCheckResponse.SerializeToString,
+ request_deserializer=agent__pb2.Heartbeat.FromString,
+ response_serializer=agent__pb2.HealthCheckResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
@@ -98,8 +98,8 @@
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/agent.AgentOrchestrator/SyncConfiguration',
- protos_dot_agent__pb2.RegistrationRequest.SerializeToString,
- protos_dot_agent__pb2.RegistrationResponse.FromString,
+ agent__pb2.RegistrationRequest.SerializeToString,
+ agent__pb2.RegistrationResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@@ -115,8 +115,8 @@
timeout=None,
metadata=None):
return grpc.experimental.stream_stream(request_iterator, target, '/agent.AgentOrchestrator/TaskStream',
- protos_dot_agent__pb2.ClientTaskMessage.SerializeToString,
- protos_dot_agent__pb2.ServerTaskMessage.FromString,
+ agent__pb2.ClientTaskMessage.SerializeToString,
+ agent__pb2.ServerTaskMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@@ -132,7 +132,7 @@
timeout=None,
metadata=None):
return grpc.experimental.stream_stream(request_iterator, target, '/agent.AgentOrchestrator/ReportHealth',
- protos_dot_agent__pb2.Heartbeat.SerializeToString,
- protos_dot_agent__pb2.HealthCheckResponse.FromString,
+ agent__pb2.Heartbeat.SerializeToString,
+ agent__pb2.HealthCheckResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
diff --git a/ai-hub/app/core/grpc/services/grpc_server.py b/ai-hub/app/core/grpc/services/grpc_server.py
index 8ad19b2..66a9eef 100644
--- a/ai-hub/app/core/grpc/services/grpc_server.py
+++ b/ai-hub/app/core/grpc/services/grpc_server.py
@@ -323,6 +323,9 @@
"active_worker_count": hb.active_worker_count,
"cpu_usage_percent": hb.cpu_usage_percent,
"memory_usage_percent": hb.memory_usage_percent,
+ "cpu_count": hb.cpu_count,
+ "memory_used_gb": hb.memory_used_gb,
+ "memory_total_gb": hb.memory_total_gb,
"running": list(hb.running_task_ids)
})
yield agent_pb2.HealthCheckResponse(server_time_ms=int(time.time()*1000))
diff --git a/ai-hub/app/protos/agent.proto b/ai-hub/app/protos/agent.proto
index 96cac03..8d03710 100644
--- a/ai-hub/app/protos/agent.proto
+++ b/ai-hub/app/protos/agent.proto
@@ -194,6 +194,9 @@
int32 max_worker_capacity = 5;
string status_message = 6;
repeated string running_task_ids = 7;
+ int32 cpu_count = 8;
+ float memory_used_gb = 9;
+ float memory_total_gb = 10;
}
message HealthCheckResponse {
diff --git a/ai-hub/app/protos/agent_pb2.py b/ai-hub/app/protos/agent_pb2.py
index 3b1cdc2..21015d1 100644
--- a/ai-hub/app/protos/agent_pb2.py
+++ b/ai-hub/app/protos/agent_pb2.py
@@ -1,6 +1,6 @@
# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler. DO NOT EDIT!
-# source: app/protos/agent.proto
+# source: agent.proto
# Protobuf Python Version: 4.25.1
"""Generated protocol buffer code."""
from google.protobuf import descriptor as _descriptor
@@ -14,83 +14,83 @@
-DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x16\x61pp/protos/agent.proto\x12\x05\x61gent\"\xde\x01\n\x13RegistrationRequest\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x12\n\nauth_token\x18\x03 \x01(\t\x12\x18\n\x10node_description\x18\x04 \x01(\t\x12\x42\n\x0c\x63\x61pabilities\x18\x05 \x03(\x0b\x32,.agent.RegistrationRequest.CapabilitiesEntry\x1a\x33\n\x11\x43\x61pabilitiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xc5\x01\n\rSandboxPolicy\x12\'\n\x04mode\x18\x01 \x01(\x0e\x32\x19.agent.SandboxPolicy.Mode\x12\x18\n\x10\x61llowed_commands\x18\x02 \x03(\t\x12\x17\n\x0f\x64\x65nied_commands\x18\x03 \x03(\t\x12\x1a\n\x12sensitive_commands\x18\x04 \x03(\t\x12\x18\n\x10working_dir_jail\x18\x05 \x01(\t\"\"\n\x04Mode\x12\n\n\x06STRICT\x10\x00\x12\x0e\n\nPERMISSIVE\x10\x01\"x\n\x14RegistrationResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12$\n\x06policy\x18\x04 \x01(\x0b\x32\x14.agent.SandboxPolicy\"\xa9\x02\n\x11\x43lientTaskMessage\x12,\n\rtask_response\x18\x01 \x01(\x0b\x32\x13.agent.TaskResponseH\x00\x12-\n\ntask_claim\x18\x02 \x01(\x0b\x32\x17.agent.TaskClaimRequestH\x00\x12,\n\rbrowser_event\x18\x03 \x01(\x0b\x32\x13.agent.BrowserEventH\x00\x12\'\n\x08\x61nnounce\x18\x04 \x01(\x0b\x32\x13.agent.NodeAnnounceH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x12(\n\x0bskill_event\x18\x06 \x01(\x0b\x32\x11.agent.SkillEventH\x00\x42\t\n\x07payload\"y\n\nSkillEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12\x0f\n\x07task_id\x18\x02 \x01(\t\x12\x16\n\x0cterminal_out\x18\x03 \x01(\tH\x00\x12\x10\n\x06prompt\x18\x04 \x01(\tH\x00\x12\x14\n\nkeep_alive\x18\x05 \x01(\x08H\x00\x42\x06\n\x04\x64\x61ta\"\x1f\n\x0cNodeAnnounce\x12\x0f\n\x07node_id\x18\x01 \x01(\t\"\x87\x01\n\x0c\x42rowserEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x0b\x63onsole_msg\x18\x02 \x01(\x0b\x32\x15.agent.ConsoleMessageH\x00\x12,\n\x0bnetwork_req\x18\x03 \x01(\x0b\x32\x15.agent.NetworkRequestH\x00\x42\x07\n\x05\x65vent\"\x8d\x02\n\x11ServerTaskMessage\x12*\n\x0ctask_request\x18\x01 \x01(\x0b\x32\x12.agent.TaskRequestH\x00\x12\x31\n\x10work_pool_update\x18\x02 \x01(\x0b\x32\x15.agent.WorkPoolUpdateH\x00\x12\x30\n\x0c\x63laim_status\x18\x03 \x01(\x0b\x32\x18.agent.TaskClaimResponseH\x00\x12/\n\x0btask_cancel\x18\x04 \x01(\x0b\x32\x18.agent.TaskCancelRequestH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x42\t\n\x07payload\"$\n\x11TaskCancelRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\"\xd1\x01\n\x0bTaskRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x11\n\ttask_type\x18\x02 \x01(\t\x12\x16\n\x0cpayload_json\x18\x03 \x01(\tH\x00\x12.\n\x0e\x62rowser_action\x18\x07 \x01(\x0b\x32\x14.agent.BrowserActionH\x00\x12\x12\n\ntimeout_ms\x18\x04 \x01(\x05\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x11\n\tsignature\x18\x06 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\tB\t\n\x07payload\"\xa0\x02\n\rBrowserAction\x12/\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x1f.agent.BrowserAction.ActionType\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x10\n\x08selector\x18\x03 \x01(\t\x12\x0c\n\x04text\x18\x04 \x01(\t\x12\x12\n\nsession_id\x18\x05 \x01(\t\x12\t\n\x01x\x18\x06 \x01(\x05\x12\t\n\x01y\x18\x07 \x01(\x05\"\x86\x01\n\nActionType\x12\x0c\n\x08NAVIGATE\x10\x00\x12\t\n\x05\x43LICK\x10\x01\x12\x08\n\x04TYPE\x10\x02\x12\x0e\n\nSCREENSHOT\x10\x03\x12\x0b\n\x07GET_DOM\x10\x04\x12\t\n\x05HOVER\x10\x05\x12\n\n\x06SCROLL\x10\x06\x12\t\n\x05\x43LOSE\x10\x07\x12\x08\n\x04\x45VAL\x10\x08\x12\x0c\n\x08GET_A11Y\x10\t\"\xe0\x02\n\x0cTaskResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12*\n\x06status\x18\x02 \x01(\x0e\x32\x1a.agent.TaskResponse.Status\x12\x0e\n\x06stdout\x18\x03 \x01(\t\x12\x0e\n\x06stderr\x18\x04 \x01(\t\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x35\n\tartifacts\x18\x06 \x03(\x0b\x32\".agent.TaskResponse.ArtifactsEntry\x12\x30\n\x0e\x62rowser_result\x18\x07 \x01(\x0b\x32\x16.agent.BrowserResponseH\x00\x1a\x30\n\x0e\x41rtifactsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"<\n\x06Status\x12\x0b\n\x07SUCCESS\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x0b\n\x07TIMEOUT\x10\x02\x12\r\n\tCANCELLED\x10\x03\x42\x08\n\x06result\"\xdc\x01\n\x0f\x42rowserResponse\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\r\n\x05title\x18\x02 \x01(\t\x12\x10\n\x08snapshot\x18\x03 \x01(\x0c\x12\x13\n\x0b\x64om_content\x18\x04 \x01(\t\x12\x11\n\ta11y_tree\x18\x05 \x01(\t\x12\x13\n\x0b\x65val_result\x18\x06 \x01(\t\x12.\n\x0f\x63onsole_history\x18\x07 \x03(\x0b\x32\x15.agent.ConsoleMessage\x12.\n\x0fnetwork_history\x18\x08 \x03(\x0b\x32\x15.agent.NetworkRequest\"C\n\x0e\x43onsoleMessage\x12\r\n\x05level\x18\x01 \x01(\t\x12\x0c\n\x04text\x18\x02 \x01(\t\x12\x14\n\x0ctimestamp_ms\x18\x03 \x01(\x03\"h\n\x0eNetworkRequest\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\x05\x12\x15\n\rresource_type\x18\x04 \x01(\t\x12\x12\n\nlatency_ms\x18\x05 \x01(\x03\",\n\x0eWorkPoolUpdate\x12\x1a\n\x12\x61vailable_task_ids\x18\x01 \x03(\t\"4\n\x10TaskClaimRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07node_id\x18\x02 \x01(\t\"E\n\x11TaskClaimResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07granted\x18\x02 \x01(\x08\x12\x0e\n\x06reason\x18\x03 \x01(\t\"\xc1\x01\n\tHeartbeat\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x19\n\x11\x63pu_usage_percent\x18\x02 \x01(\x02\x12\x1c\n\x14memory_usage_percent\x18\x03 \x01(\x02\x12\x1b\n\x13\x61\x63tive_worker_count\x18\x04 \x01(\x05\x12\x1b\n\x13max_worker_capacity\x18\x05 \x01(\x05\x12\x16\n\x0estatus_message\x18\x06 \x01(\t\x12\x18\n\x10running_task_ids\x18\x07 \x03(\t\"-\n\x13HealthCheckResponse\x12\x16\n\x0eserver_time_ms\x18\x01 \x01(\x03\"\xe4\x01\n\x0f\x46ileSyncMessage\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x08manifest\x18\x02 \x01(\x0b\x32\x18.agent.DirectoryManifestH\x00\x12\'\n\tfile_data\x18\x03 \x01(\x0b\x32\x12.agent.FilePayloadH\x00\x12#\n\x06status\x18\x04 \x01(\x0b\x32\x11.agent.SyncStatusH\x00\x12%\n\x07\x63ontrol\x18\x05 \x01(\x0b\x32\x12.agent.SyncControlH\x00\x12\x0f\n\x07task_id\x18\x06 \x01(\tB\t\n\x07payload\"\x93\x02\n\x0bSyncControl\x12)\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x19.agent.SyncControl.Action\x12\x0c\n\x04path\x18\x02 \x01(\t\x12\x15\n\rrequest_paths\x18\x03 \x03(\t\x12\x0f\n\x07\x63ontent\x18\x04 \x01(\x0c\x12\x0e\n\x06is_dir\x18\x05 \x01(\x08\"\x92\x01\n\x06\x41\x63tion\x12\x12\n\x0eSTART_WATCHING\x10\x00\x12\x11\n\rSTOP_WATCHING\x10\x01\x12\x08\n\x04LOCK\x10\x02\x12\n\n\x06UNLOCK\x10\x03\x12\x14\n\x10REFRESH_MANIFEST\x10\x04\x12\n\n\x06RESYNC\x10\x05\x12\x08\n\x04LIST\x10\x06\x12\x08\n\x04READ\x10\x07\x12\t\n\x05WRITE\x10\x08\x12\n\n\x06\x44\x45LETE\x10\t\"F\n\x11\x44irectoryManifest\x12\x11\n\troot_path\x18\x01 \x01(\t\x12\x1e\n\x05\x66iles\x18\x02 \x03(\x0b\x32\x0f.agent.FileInfo\"D\n\x08\x46ileInfo\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0c\n\x04size\x18\x02 \x01(\x03\x12\x0c\n\x04hash\x18\x03 \x01(\t\x12\x0e\n\x06is_dir\x18\x04 \x01(\x08\"_\n\x0b\x46ilePayload\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\x12\x13\n\x0b\x63hunk_index\x18\x03 \x01(\x05\x12\x10\n\x08is_final\x18\x04 \x01(\x08\x12\x0c\n\x04hash\x18\x05 \x01(\t\"\xa0\x01\n\nSyncStatus\x12$\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x16.agent.SyncStatus.Code\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x17\n\x0freconcile_paths\x18\x03 \x03(\t\"B\n\x04\x43ode\x12\x06\n\x02OK\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x16\n\x12RECONCILE_REQUIRED\x10\x02\x12\x0f\n\x0bIN_PROGRESS\x10\x03\x32\xe9\x01\n\x11\x41gentOrchestrator\x12L\n\x11SyncConfiguration\x12\x1a.agent.RegistrationRequest\x1a\x1b.agent.RegistrationResponse\x12\x44\n\nTaskStream\x12\x18.agent.ClientTaskMessage\x1a\x18.agent.ServerTaskMessage(\x01\x30\x01\x12@\n\x0cReportHealth\x12\x10.agent.Heartbeat\x1a\x1a.agent.HealthCheckResponse(\x01\x30\x01\x62\x06proto3')
+DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x0b\x61gent.proto\x12\x05\x61gent\"\xde\x01\n\x13RegistrationRequest\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x0f\n\x07version\x18\x02 \x01(\t\x12\x12\n\nauth_token\x18\x03 \x01(\t\x12\x18\n\x10node_description\x18\x04 \x01(\t\x12\x42\n\x0c\x63\x61pabilities\x18\x05 \x03(\x0b\x32,.agent.RegistrationRequest.CapabilitiesEntry\x1a\x33\n\x11\x43\x61pabilitiesEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\t:\x02\x38\x01\"\xc5\x01\n\rSandboxPolicy\x12\'\n\x04mode\x18\x01 \x01(\x0e\x32\x19.agent.SandboxPolicy.Mode\x12\x18\n\x10\x61llowed_commands\x18\x02 \x03(\t\x12\x17\n\x0f\x64\x65nied_commands\x18\x03 \x03(\t\x12\x1a\n\x12sensitive_commands\x18\x04 \x03(\t\x12\x18\n\x10working_dir_jail\x18\x05 \x01(\t\"\"\n\x04Mode\x12\n\n\x06STRICT\x10\x00\x12\x0e\n\nPERMISSIVE\x10\x01\"x\n\x14RegistrationResponse\x12\x0f\n\x07success\x18\x01 \x01(\x08\x12\x15\n\rerror_message\x18\x02 \x01(\t\x12\x12\n\nsession_id\x18\x03 \x01(\t\x12$\n\x06policy\x18\x04 \x01(\x0b\x32\x14.agent.SandboxPolicy\"\xa9\x02\n\x11\x43lientTaskMessage\x12,\n\rtask_response\x18\x01 \x01(\x0b\x32\x13.agent.TaskResponseH\x00\x12-\n\ntask_claim\x18\x02 \x01(\x0b\x32\x17.agent.TaskClaimRequestH\x00\x12,\n\rbrowser_event\x18\x03 \x01(\x0b\x32\x13.agent.BrowserEventH\x00\x12\'\n\x08\x61nnounce\x18\x04 \x01(\x0b\x32\x13.agent.NodeAnnounceH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x12(\n\x0bskill_event\x18\x06 \x01(\x0b\x32\x11.agent.SkillEventH\x00\x42\t\n\x07payload\"y\n\nSkillEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12\x0f\n\x07task_id\x18\x02 \x01(\t\x12\x16\n\x0cterminal_out\x18\x03 \x01(\tH\x00\x12\x10\n\x06prompt\x18\x04 \x01(\tH\x00\x12\x14\n\nkeep_alive\x18\x05 \x01(\x08H\x00\x42\x06\n\x04\x64\x61ta\"\x1f\n\x0cNodeAnnounce\x12\x0f\n\x07node_id\x18\x01 \x01(\t\"\x87\x01\n\x0c\x42rowserEvent\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x0b\x63onsole_msg\x18\x02 \x01(\x0b\x32\x15.agent.ConsoleMessageH\x00\x12,\n\x0bnetwork_req\x18\x03 \x01(\x0b\x32\x15.agent.NetworkRequestH\x00\x42\x07\n\x05\x65vent\"\x8d\x02\n\x11ServerTaskMessage\x12*\n\x0ctask_request\x18\x01 \x01(\x0b\x32\x12.agent.TaskRequestH\x00\x12\x31\n\x10work_pool_update\x18\x02 \x01(\x0b\x32\x15.agent.WorkPoolUpdateH\x00\x12\x30\n\x0c\x63laim_status\x18\x03 \x01(\x0b\x32\x18.agent.TaskClaimResponseH\x00\x12/\n\x0btask_cancel\x18\x04 \x01(\x0b\x32\x18.agent.TaskCancelRequestH\x00\x12+\n\tfile_sync\x18\x05 \x01(\x0b\x32\x16.agent.FileSyncMessageH\x00\x42\t\n\x07payload\"$\n\x11TaskCancelRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\"\xd1\x01\n\x0bTaskRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x11\n\ttask_type\x18\x02 \x01(\t\x12\x16\n\x0cpayload_json\x18\x03 \x01(\tH\x00\x12.\n\x0e\x62rowser_action\x18\x07 \x01(\x0b\x32\x14.agent.BrowserActionH\x00\x12\x12\n\ntimeout_ms\x18\x04 \x01(\x05\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x11\n\tsignature\x18\x06 \x01(\t\x12\x12\n\nsession_id\x18\x08 \x01(\tB\t\n\x07payload\"\xa0\x02\n\rBrowserAction\x12/\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x1f.agent.BrowserAction.ActionType\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x10\n\x08selector\x18\x03 \x01(\t\x12\x0c\n\x04text\x18\x04 \x01(\t\x12\x12\n\nsession_id\x18\x05 \x01(\t\x12\t\n\x01x\x18\x06 \x01(\x05\x12\t\n\x01y\x18\x07 \x01(\x05\"\x86\x01\n\nActionType\x12\x0c\n\x08NAVIGATE\x10\x00\x12\t\n\x05\x43LICK\x10\x01\x12\x08\n\x04TYPE\x10\x02\x12\x0e\n\nSCREENSHOT\x10\x03\x12\x0b\n\x07GET_DOM\x10\x04\x12\t\n\x05HOVER\x10\x05\x12\n\n\x06SCROLL\x10\x06\x12\t\n\x05\x43LOSE\x10\x07\x12\x08\n\x04\x45VAL\x10\x08\x12\x0c\n\x08GET_A11Y\x10\t\"\xe0\x02\n\x0cTaskResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12*\n\x06status\x18\x02 \x01(\x0e\x32\x1a.agent.TaskResponse.Status\x12\x0e\n\x06stdout\x18\x03 \x01(\t\x12\x0e\n\x06stderr\x18\x04 \x01(\t\x12\x10\n\x08trace_id\x18\x05 \x01(\t\x12\x35\n\tartifacts\x18\x06 \x03(\x0b\x32\".agent.TaskResponse.ArtifactsEntry\x12\x30\n\x0e\x62rowser_result\x18\x07 \x01(\x0b\x32\x16.agent.BrowserResponseH\x00\x1a\x30\n\x0e\x41rtifactsEntry\x12\x0b\n\x03key\x18\x01 \x01(\t\x12\r\n\x05value\x18\x02 \x01(\x0c:\x02\x38\x01\"<\n\x06Status\x12\x0b\n\x07SUCCESS\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x0b\n\x07TIMEOUT\x10\x02\x12\r\n\tCANCELLED\x10\x03\x42\x08\n\x06result\"\xdc\x01\n\x0f\x42rowserResponse\x12\x0b\n\x03url\x18\x01 \x01(\t\x12\r\n\x05title\x18\x02 \x01(\t\x12\x10\n\x08snapshot\x18\x03 \x01(\x0c\x12\x13\n\x0b\x64om_content\x18\x04 \x01(\t\x12\x11\n\ta11y_tree\x18\x05 \x01(\t\x12\x13\n\x0b\x65val_result\x18\x06 \x01(\t\x12.\n\x0f\x63onsole_history\x18\x07 \x03(\x0b\x32\x15.agent.ConsoleMessage\x12.\n\x0fnetwork_history\x18\x08 \x03(\x0b\x32\x15.agent.NetworkRequest\"C\n\x0e\x43onsoleMessage\x12\r\n\x05level\x18\x01 \x01(\t\x12\x0c\n\x04text\x18\x02 \x01(\t\x12\x14\n\x0ctimestamp_ms\x18\x03 \x01(\x03\"h\n\x0eNetworkRequest\x12\x0e\n\x06method\x18\x01 \x01(\t\x12\x0b\n\x03url\x18\x02 \x01(\t\x12\x0e\n\x06status\x18\x03 \x01(\x05\x12\x15\n\rresource_type\x18\x04 \x01(\t\x12\x12\n\nlatency_ms\x18\x05 \x01(\x03\",\n\x0eWorkPoolUpdate\x12\x1a\n\x12\x61vailable_task_ids\x18\x01 \x03(\t\"4\n\x10TaskClaimRequest\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07node_id\x18\x02 \x01(\t\"E\n\x11TaskClaimResponse\x12\x0f\n\x07task_id\x18\x01 \x01(\t\x12\x0f\n\x07granted\x18\x02 \x01(\x08\x12\x0e\n\x06reason\x18\x03 \x01(\t\"\x85\x02\n\tHeartbeat\x12\x0f\n\x07node_id\x18\x01 \x01(\t\x12\x19\n\x11\x63pu_usage_percent\x18\x02 \x01(\x02\x12\x1c\n\x14memory_usage_percent\x18\x03 \x01(\x02\x12\x1b\n\x13\x61\x63tive_worker_count\x18\x04 \x01(\x05\x12\x1b\n\x13max_worker_capacity\x18\x05 \x01(\x05\x12\x16\n\x0estatus_message\x18\x06 \x01(\t\x12\x18\n\x10running_task_ids\x18\x07 \x03(\t\x12\x11\n\tcpu_count\x18\x08 \x01(\x05\x12\x16\n\x0ememory_used_gb\x18\t \x01(\x02\x12\x17\n\x0fmemory_total_gb\x18\n \x01(\x02\"-\n\x13HealthCheckResponse\x12\x16\n\x0eserver_time_ms\x18\x01 \x01(\x03\"\xe4\x01\n\x0f\x46ileSyncMessage\x12\x12\n\nsession_id\x18\x01 \x01(\t\x12,\n\x08manifest\x18\x02 \x01(\x0b\x32\x18.agent.DirectoryManifestH\x00\x12\'\n\tfile_data\x18\x03 \x01(\x0b\x32\x12.agent.FilePayloadH\x00\x12#\n\x06status\x18\x04 \x01(\x0b\x32\x11.agent.SyncStatusH\x00\x12%\n\x07\x63ontrol\x18\x05 \x01(\x0b\x32\x12.agent.SyncControlH\x00\x12\x0f\n\x07task_id\x18\x06 \x01(\tB\t\n\x07payload\"\x93\x02\n\x0bSyncControl\x12)\n\x06\x61\x63tion\x18\x01 \x01(\x0e\x32\x19.agent.SyncControl.Action\x12\x0c\n\x04path\x18\x02 \x01(\t\x12\x15\n\rrequest_paths\x18\x03 \x03(\t\x12\x0f\n\x07\x63ontent\x18\x04 \x01(\x0c\x12\x0e\n\x06is_dir\x18\x05 \x01(\x08\"\x92\x01\n\x06\x41\x63tion\x12\x12\n\x0eSTART_WATCHING\x10\x00\x12\x11\n\rSTOP_WATCHING\x10\x01\x12\x08\n\x04LOCK\x10\x02\x12\n\n\x06UNLOCK\x10\x03\x12\x14\n\x10REFRESH_MANIFEST\x10\x04\x12\n\n\x06RESYNC\x10\x05\x12\x08\n\x04LIST\x10\x06\x12\x08\n\x04READ\x10\x07\x12\t\n\x05WRITE\x10\x08\x12\n\n\x06\x44\x45LETE\x10\t\"F\n\x11\x44irectoryManifest\x12\x11\n\troot_path\x18\x01 \x01(\t\x12\x1e\n\x05\x66iles\x18\x02 \x03(\x0b\x32\x0f.agent.FileInfo\"D\n\x08\x46ileInfo\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\x0c\n\x04size\x18\x02 \x01(\x03\x12\x0c\n\x04hash\x18\x03 \x01(\t\x12\x0e\n\x06is_dir\x18\x04 \x01(\x08\"_\n\x0b\x46ilePayload\x12\x0c\n\x04path\x18\x01 \x01(\t\x12\r\n\x05\x63hunk\x18\x02 \x01(\x0c\x12\x13\n\x0b\x63hunk_index\x18\x03 \x01(\x05\x12\x10\n\x08is_final\x18\x04 \x01(\x08\x12\x0c\n\x04hash\x18\x05 \x01(\t\"\xa0\x01\n\nSyncStatus\x12$\n\x04\x63ode\x18\x01 \x01(\x0e\x32\x16.agent.SyncStatus.Code\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x17\n\x0freconcile_paths\x18\x03 \x03(\t\"B\n\x04\x43ode\x12\x06\n\x02OK\x10\x00\x12\t\n\x05\x45RROR\x10\x01\x12\x16\n\x12RECONCILE_REQUIRED\x10\x02\x12\x0f\n\x0bIN_PROGRESS\x10\x03\x32\xe9\x01\n\x11\x41gentOrchestrator\x12L\n\x11SyncConfiguration\x12\x1a.agent.RegistrationRequest\x1a\x1b.agent.RegistrationResponse\x12\x44\n\nTaskStream\x12\x18.agent.ClientTaskMessage\x1a\x18.agent.ServerTaskMessage(\x01\x30\x01\x12@\n\x0cReportHealth\x12\x10.agent.Heartbeat\x1a\x1a.agent.HealthCheckResponse(\x01\x30\x01\x62\x06proto3')
_globals = globals()
_builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals)
-_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'app.protos.agent_pb2', _globals)
+_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'agent_pb2', _globals)
if _descriptor._USE_C_DESCRIPTORS == False:
DESCRIPTOR._options = None
_globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._options = None
_globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_options = b'8\001'
_globals['_TASKRESPONSE_ARTIFACTSENTRY']._options = None
_globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_options = b'8\001'
- _globals['_REGISTRATIONREQUEST']._serialized_start=34
- _globals['_REGISTRATIONREQUEST']._serialized_end=256
- _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_start=205
- _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_end=256
- _globals['_SANDBOXPOLICY']._serialized_start=259
- _globals['_SANDBOXPOLICY']._serialized_end=456
- _globals['_SANDBOXPOLICY_MODE']._serialized_start=422
- _globals['_SANDBOXPOLICY_MODE']._serialized_end=456
- _globals['_REGISTRATIONRESPONSE']._serialized_start=458
- _globals['_REGISTRATIONRESPONSE']._serialized_end=578
- _globals['_CLIENTTASKMESSAGE']._serialized_start=581
- _globals['_CLIENTTASKMESSAGE']._serialized_end=878
- _globals['_SKILLEVENT']._serialized_start=880
- _globals['_SKILLEVENT']._serialized_end=1001
- _globals['_NODEANNOUNCE']._serialized_start=1003
- _globals['_NODEANNOUNCE']._serialized_end=1034
- _globals['_BROWSEREVENT']._serialized_start=1037
- _globals['_BROWSEREVENT']._serialized_end=1172
- _globals['_SERVERTASKMESSAGE']._serialized_start=1175
- _globals['_SERVERTASKMESSAGE']._serialized_end=1444
- _globals['_TASKCANCELREQUEST']._serialized_start=1446
- _globals['_TASKCANCELREQUEST']._serialized_end=1482
- _globals['_TASKREQUEST']._serialized_start=1485
- _globals['_TASKREQUEST']._serialized_end=1694
- _globals['_BROWSERACTION']._serialized_start=1697
- _globals['_BROWSERACTION']._serialized_end=1985
- _globals['_BROWSERACTION_ACTIONTYPE']._serialized_start=1851
- _globals['_BROWSERACTION_ACTIONTYPE']._serialized_end=1985
- _globals['_TASKRESPONSE']._serialized_start=1988
- _globals['_TASKRESPONSE']._serialized_end=2340
- _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_start=2220
- _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_end=2268
- _globals['_TASKRESPONSE_STATUS']._serialized_start=2270
- _globals['_TASKRESPONSE_STATUS']._serialized_end=2330
- _globals['_BROWSERRESPONSE']._serialized_start=2343
- _globals['_BROWSERRESPONSE']._serialized_end=2563
- _globals['_CONSOLEMESSAGE']._serialized_start=2565
- _globals['_CONSOLEMESSAGE']._serialized_end=2632
- _globals['_NETWORKREQUEST']._serialized_start=2634
- _globals['_NETWORKREQUEST']._serialized_end=2738
- _globals['_WORKPOOLUPDATE']._serialized_start=2740
- _globals['_WORKPOOLUPDATE']._serialized_end=2784
- _globals['_TASKCLAIMREQUEST']._serialized_start=2786
- _globals['_TASKCLAIMREQUEST']._serialized_end=2838
- _globals['_TASKCLAIMRESPONSE']._serialized_start=2840
- _globals['_TASKCLAIMRESPONSE']._serialized_end=2909
- _globals['_HEARTBEAT']._serialized_start=2912
- _globals['_HEARTBEAT']._serialized_end=3105
- _globals['_HEALTHCHECKRESPONSE']._serialized_start=3107
- _globals['_HEALTHCHECKRESPONSE']._serialized_end=3152
- _globals['_FILESYNCMESSAGE']._serialized_start=3155
- _globals['_FILESYNCMESSAGE']._serialized_end=3383
- _globals['_SYNCCONTROL']._serialized_start=3386
- _globals['_SYNCCONTROL']._serialized_end=3661
- _globals['_SYNCCONTROL_ACTION']._serialized_start=3515
- _globals['_SYNCCONTROL_ACTION']._serialized_end=3661
- _globals['_DIRECTORYMANIFEST']._serialized_start=3663
- _globals['_DIRECTORYMANIFEST']._serialized_end=3733
- _globals['_FILEINFO']._serialized_start=3735
- _globals['_FILEINFO']._serialized_end=3803
- _globals['_FILEPAYLOAD']._serialized_start=3805
- _globals['_FILEPAYLOAD']._serialized_end=3900
- _globals['_SYNCSTATUS']._serialized_start=3903
- _globals['_SYNCSTATUS']._serialized_end=4063
- _globals['_SYNCSTATUS_CODE']._serialized_start=3997
- _globals['_SYNCSTATUS_CODE']._serialized_end=4063
- _globals['_AGENTORCHESTRATOR']._serialized_start=4066
- _globals['_AGENTORCHESTRATOR']._serialized_end=4299
+ _globals['_REGISTRATIONREQUEST']._serialized_start=23
+ _globals['_REGISTRATIONREQUEST']._serialized_end=245
+ _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_start=194
+ _globals['_REGISTRATIONREQUEST_CAPABILITIESENTRY']._serialized_end=245
+ _globals['_SANDBOXPOLICY']._serialized_start=248
+ _globals['_SANDBOXPOLICY']._serialized_end=445
+ _globals['_SANDBOXPOLICY_MODE']._serialized_start=411
+ _globals['_SANDBOXPOLICY_MODE']._serialized_end=445
+ _globals['_REGISTRATIONRESPONSE']._serialized_start=447
+ _globals['_REGISTRATIONRESPONSE']._serialized_end=567
+ _globals['_CLIENTTASKMESSAGE']._serialized_start=570
+ _globals['_CLIENTTASKMESSAGE']._serialized_end=867
+ _globals['_SKILLEVENT']._serialized_start=869
+ _globals['_SKILLEVENT']._serialized_end=990
+ _globals['_NODEANNOUNCE']._serialized_start=992
+ _globals['_NODEANNOUNCE']._serialized_end=1023
+ _globals['_BROWSEREVENT']._serialized_start=1026
+ _globals['_BROWSEREVENT']._serialized_end=1161
+ _globals['_SERVERTASKMESSAGE']._serialized_start=1164
+ _globals['_SERVERTASKMESSAGE']._serialized_end=1433
+ _globals['_TASKCANCELREQUEST']._serialized_start=1435
+ _globals['_TASKCANCELREQUEST']._serialized_end=1471
+ _globals['_TASKREQUEST']._serialized_start=1474
+ _globals['_TASKREQUEST']._serialized_end=1683
+ _globals['_BROWSERACTION']._serialized_start=1686
+ _globals['_BROWSERACTION']._serialized_end=1974
+ _globals['_BROWSERACTION_ACTIONTYPE']._serialized_start=1840
+ _globals['_BROWSERACTION_ACTIONTYPE']._serialized_end=1974
+ _globals['_TASKRESPONSE']._serialized_start=1977
+ _globals['_TASKRESPONSE']._serialized_end=2329
+ _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_start=2209
+ _globals['_TASKRESPONSE_ARTIFACTSENTRY']._serialized_end=2257
+ _globals['_TASKRESPONSE_STATUS']._serialized_start=2259
+ _globals['_TASKRESPONSE_STATUS']._serialized_end=2319
+ _globals['_BROWSERRESPONSE']._serialized_start=2332
+ _globals['_BROWSERRESPONSE']._serialized_end=2552
+ _globals['_CONSOLEMESSAGE']._serialized_start=2554
+ _globals['_CONSOLEMESSAGE']._serialized_end=2621
+ _globals['_NETWORKREQUEST']._serialized_start=2623
+ _globals['_NETWORKREQUEST']._serialized_end=2727
+ _globals['_WORKPOOLUPDATE']._serialized_start=2729
+ _globals['_WORKPOOLUPDATE']._serialized_end=2773
+ _globals['_TASKCLAIMREQUEST']._serialized_start=2775
+ _globals['_TASKCLAIMREQUEST']._serialized_end=2827
+ _globals['_TASKCLAIMRESPONSE']._serialized_start=2829
+ _globals['_TASKCLAIMRESPONSE']._serialized_end=2898
+ _globals['_HEARTBEAT']._serialized_start=2901
+ _globals['_HEARTBEAT']._serialized_end=3162
+ _globals['_HEALTHCHECKRESPONSE']._serialized_start=3164
+ _globals['_HEALTHCHECKRESPONSE']._serialized_end=3209
+ _globals['_FILESYNCMESSAGE']._serialized_start=3212
+ _globals['_FILESYNCMESSAGE']._serialized_end=3440
+ _globals['_SYNCCONTROL']._serialized_start=3443
+ _globals['_SYNCCONTROL']._serialized_end=3718
+ _globals['_SYNCCONTROL_ACTION']._serialized_start=3572
+ _globals['_SYNCCONTROL_ACTION']._serialized_end=3718
+ _globals['_DIRECTORYMANIFEST']._serialized_start=3720
+ _globals['_DIRECTORYMANIFEST']._serialized_end=3790
+ _globals['_FILEINFO']._serialized_start=3792
+ _globals['_FILEINFO']._serialized_end=3860
+ _globals['_FILEPAYLOAD']._serialized_start=3862
+ _globals['_FILEPAYLOAD']._serialized_end=3957
+ _globals['_SYNCSTATUS']._serialized_start=3960
+ _globals['_SYNCSTATUS']._serialized_end=4120
+ _globals['_SYNCSTATUS_CODE']._serialized_start=4054
+ _globals['_SYNCSTATUS_CODE']._serialized_end=4120
+ _globals['_AGENTORCHESTRATOR']._serialized_start=4123
+ _globals['_AGENTORCHESTRATOR']._serialized_end=4356
# @@protoc_insertion_point(module_scope)
diff --git a/ai-hub/app/protos/agent_pb2_grpc.py b/ai-hub/app/protos/agent_pb2_grpc.py
index 90b55ee..932d45e 100644
--- a/ai-hub/app/protos/agent_pb2_grpc.py
+++ b/ai-hub/app/protos/agent_pb2_grpc.py
@@ -2,7 +2,7 @@
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
-from app.protos import agent_pb2 as app_dot_protos_dot_agent__pb2
+import agent_pb2 as agent__pb2
class AgentOrchestratorStub(object):
@@ -17,18 +17,18 @@
"""
self.SyncConfiguration = channel.unary_unary(
'/agent.AgentOrchestrator/SyncConfiguration',
- request_serializer=app_dot_protos_dot_agent__pb2.RegistrationRequest.SerializeToString,
- response_deserializer=app_dot_protos_dot_agent__pb2.RegistrationResponse.FromString,
+ request_serializer=agent__pb2.RegistrationRequest.SerializeToString,
+ response_deserializer=agent__pb2.RegistrationResponse.FromString,
)
self.TaskStream = channel.stream_stream(
'/agent.AgentOrchestrator/TaskStream',
- request_serializer=app_dot_protos_dot_agent__pb2.ClientTaskMessage.SerializeToString,
- response_deserializer=app_dot_protos_dot_agent__pb2.ServerTaskMessage.FromString,
+ request_serializer=agent__pb2.ClientTaskMessage.SerializeToString,
+ response_deserializer=agent__pb2.ServerTaskMessage.FromString,
)
self.ReportHealth = channel.stream_stream(
'/agent.AgentOrchestrator/ReportHealth',
- request_serializer=app_dot_protos_dot_agent__pb2.Heartbeat.SerializeToString,
- response_deserializer=app_dot_protos_dot_agent__pb2.HealthCheckResponse.FromString,
+ request_serializer=agent__pb2.Heartbeat.SerializeToString,
+ response_deserializer=agent__pb2.HealthCheckResponse.FromString,
)
@@ -62,18 +62,18 @@
rpc_method_handlers = {
'SyncConfiguration': grpc.unary_unary_rpc_method_handler(
servicer.SyncConfiguration,
- request_deserializer=app_dot_protos_dot_agent__pb2.RegistrationRequest.FromString,
- response_serializer=app_dot_protos_dot_agent__pb2.RegistrationResponse.SerializeToString,
+ request_deserializer=agent__pb2.RegistrationRequest.FromString,
+ response_serializer=agent__pb2.RegistrationResponse.SerializeToString,
),
'TaskStream': grpc.stream_stream_rpc_method_handler(
servicer.TaskStream,
- request_deserializer=app_dot_protos_dot_agent__pb2.ClientTaskMessage.FromString,
- response_serializer=app_dot_protos_dot_agent__pb2.ServerTaskMessage.SerializeToString,
+ request_deserializer=agent__pb2.ClientTaskMessage.FromString,
+ response_serializer=agent__pb2.ServerTaskMessage.SerializeToString,
),
'ReportHealth': grpc.stream_stream_rpc_method_handler(
servicer.ReportHealth,
- request_deserializer=app_dot_protos_dot_agent__pb2.Heartbeat.FromString,
- response_serializer=app_dot_protos_dot_agent__pb2.HealthCheckResponse.SerializeToString,
+ request_deserializer=agent__pb2.Heartbeat.FromString,
+ response_serializer=agent__pb2.HealthCheckResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
@@ -98,8 +98,8 @@
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/agent.AgentOrchestrator/SyncConfiguration',
- app_dot_protos_dot_agent__pb2.RegistrationRequest.SerializeToString,
- app_dot_protos_dot_agent__pb2.RegistrationResponse.FromString,
+ agent__pb2.RegistrationRequest.SerializeToString,
+ agent__pb2.RegistrationResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@@ -115,8 +115,8 @@
timeout=None,
metadata=None):
return grpc.experimental.stream_stream(request_iterator, target, '/agent.AgentOrchestrator/TaskStream',
- app_dot_protos_dot_agent__pb2.ClientTaskMessage.SerializeToString,
- app_dot_protos_dot_agent__pb2.ServerTaskMessage.FromString,
+ agent__pb2.ClientTaskMessage.SerializeToString,
+ agent__pb2.ServerTaskMessage.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@@ -132,7 +132,7 @@
timeout=None,
metadata=None):
return grpc.experimental.stream_stream(request_iterator, target, '/agent.AgentOrchestrator/ReportHealth',
- app_dot_protos_dot_agent__pb2.Heartbeat.SerializeToString,
- app_dot_protos_dot_agent__pb2.HealthCheckResponse.FromString,
+ agent__pb2.Heartbeat.SerializeToString,
+ agent__pb2.HealthCheckResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
diff --git a/ui/client-app/src/pages/NodesPage.js b/ui/client-app/src/pages/NodesPage.js
index d9cc606..75362a5 100644
--- a/ui/client-app/src/pages/NodesPage.js
+++ b/ui/client-app/src/pages/NodesPage.js
@@ -127,6 +127,40 @@
}
};
+ const NodeHealthMetrics = ({ nodeId, stats, compact = false }) => {
+ const isOnline = meshStatus[nodeId]?.status === 'online' || meshStatus[nodeId]?.status === 'idle' || meshStatus[nodeId]?.status === 'busy';
+ if (!isOnline && compact) return null;
+
+ const cpu = stats?.cpu_usage_percent || 0;
+ const mem = stats?.memory_usage_percent || 0;
+ const cpuCount = stats?.cpu_count || 0;
+ const memUsed = (stats?.memory_used_gb || 0).toFixed(1);
+ const memTotal = (stats?.memory_total_gb || 0).toFixed(1);
+
+ return (
+
+
+
+ CPU
+ {cpu.toFixed(0)}%
+
+
+
+
+
+ RAM
+ {mem.toFixed(0)}%
+
+
+
+
{/* Header */}
@@ -210,7 +244,10 @@
-
{node.display_name}
+
+
{node.display_name}
+
+
{node.is_active ? 'Active' : 'Disabled'}
@@ -437,20 +474,7 @@