m/rdp-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Advertise health-aware peer cache ranking

Browse Source
This commit is contained in:
Mikhail
2026-05-16 11:29:12 +03:00
parent 6817d150f8
commit dbbdaa63f3
3 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agents/rap-node-agent/cmd/rap-node-agent/main.go
+1
View File
@@ -2980,6 +2980,7 @@ func heartbeatPayload(cfg config.Config, identity state.Identity, meshState *syn
payload.Metadata["mesh_peer_recovery_report"] = meshPeerRecoveryReport(meshState, observedAt)
payload.Metadata["mesh_peer_connection_intent_report"] = meshPeerConnectionIntentReport(meshState, observedAt)
payload.Metadata["mesh_peer_connection_manager_report"] = meshPeerConnectionManagerReport(meshState, observedAt)
payload.Capabilities["mesh_peer_cache_endpoint_health_ranking"] = true
payload.Metadata["mesh_rendezvous_lease_report"] = meshRendezvousLeaseReport(meshState, identity, observedAt)
payload.Metadata["mesh_route_path_decision_report"] = meshRoutePathDecisionReport(meshState, identity, observedAt)
payload.Metadata["mesh_route_generation_report"] = meshRouteGenerationReport(meshState, identity, observedAt)
agents/rap-node-agent/cmd/rap-node-agent/main_test.go
+3
View File
@@ -1302,6 +1302,9 @@ func TestHeartbeatPayloadIncludesPeerRecoveryReportWithoutAdvertisedEndpoint(t *
if payload.Capabilities["mesh_peer_connection_intent_planning"] != true {
t.Fatalf("connection intent capability missing: %+v", payload.Capabilities)
}
if payload.Capabilities["mesh_peer_cache_endpoint_health_ranking"] != true {
t.Fatalf("peer cache endpoint health capability missing: %+v", payload.Capabilities)
}
if _, ok := payload.Metadata["mesh_endpoint_report"]; ok {
t.Fatalf("endpoint report should not be emitted without advertised endpoint: %+v", payload.Metadata)
}