Force sync on the insert

jakubno · jakubno · commit 3fb2ebb4d70c · 2025-12-01T16:11:04.000+01:00
diff --git a/packages/api/internal/edge/cluster_instances.go b/packages/api/internal/edge/cluster_instances.go
@@ -163,13 +163,15 @@ func (d clusterSynchronizationStore) PoolInsert(ctx context.Context, item api.Cl
 		ServiceVersion:       item.ServiceVersion,
 		ServiceVersionCommit: item.ServiceVersionCommit,
 
-		// initial values before first sync
 		status: infogrpc.ServiceInfoStatus_Unhealthy,
 		roles:  make([]infogrpc.ServiceInfoRole, 0),
 
 		mutex: sync.RWMutex{},
 	}
 
+	// Force sync to get initial values
+	d.cluster.syncInstance(ctx, instance)
+
 	d.cluster.instances.Insert(item.NodeID, instance)
 }
 

Original file line number	Diff line number	Diff line change
`@@ -163,13 +163,15 @@ func (d clusterSynchronizationStore) PoolInsert(ctx context.Context, item api.Cl`
`163`	`163`	`ServiceVersion: item.ServiceVersion,`
`164`	`164`	`ServiceVersionCommit: item.ServiceVersionCommit,`
`165`	`165`
`166`		`- // initial values before first sync`
`167`	`166`	`status: infogrpc.ServiceInfoStatus_Unhealthy,`
`168`	`167`	`roles: make([]infogrpc.ServiceInfoRole, 0),`
`169`	`168`
`170`	`169`	`mutex: sync.RWMutex{},`
`171`	`170`	`}`
`172`	`171`
	`172`	`+ // Force sync to get initial values`
	`173`	`+ d.cluster.syncInstance(ctx, instance)`
	`174`	`+`
`173`	`175`	`d.cluster.instances.Insert(item.NodeID, instance)`
`174`	`176`	`}`
`175`	`177`