mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

update logs
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m45s
Details

Browse Source
This commit is contained in:
matst80
2024-11-09 14:01:03 +01:00
parent c7306bb526
commit f9d14f1d7f
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
synced-pool.go
View File

@@ -36,7 +36,6 @@ func (k *K8sDiscovery) DiscoverInNamespace(namespace string) ([]string, error) {
hosts := make([]string, 0, len(pods.Items)) hosts := make([]string, 0, len(pods.Items))
for _, pod := range pods.Items { for _, pod := range pods.Items {
hosts = append(hosts, pod.Name) hosts = append(hosts, pod.Name)
log.Printf("Found pod %s\n", pod.Name)
} }
return hosts, nil return hosts, nil
} }
@@ -92,6 +91,10 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
return return
} }
for _, h := range hosts { for _, h := range hosts {
if h == hostname {
continue
}
log.Printf("Discovered host %s\n", h)
err := pool.AddRemote(h) err := pool.AddRemote(h)
if err != nil { if err != nil {
log.Printf("Error adding remote %s: %v\n", h, err) log.Printf("Error adding remote %s: %v\n", h, err)