github/goldpinger
1
0
Fork 0
mirror of https://github.com/bloomberg/goldpinger.git synced 2026-02-14 18:09:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Compare all nodes return the expected nodes that Kubernetes returns

Browse Source 
Signed-off-by: Mikolaj Pawlikowski <mikolaj@pawlikowski.pl>
This commit is contained in:
Mikolaj Pawlikowski
2021-03-12 17:16:58 +00:00
parent 52ff43ec7d
commit 13ae09d93e
1 changed files with 12 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
pkg/goldpinger/client.go
View File

@@ -62,30 +62,29 @@ func CheckCluster(ctx context.Context) *models.ClusterHealthResults {
response := models.ClusterHealthResults{
GeneratedAt: strfmt.DateTime(start),
}
selectedPods := SelectPods()
// precompute the expected set of nodes
expectedNodes := []string{}
for _, peer := range selectedPods {
expectedNodes = append(expectedNodes, peer.HostIP)
}
sort.Strings(expectedNodes)
// get the response we serve for check_all
checkAll := CheckNeighboursNeighbours(ctx)
checkAll := CheckAllPods(ctx, selectedPods)
// 1. check that all nodes report OK
for node, resp := range checkAll.Responses {
for _, resp := range checkAll.Responses {
if *resp.OK {
response.NodesHealthy = append(response.NodesHealthy, node)
response.NodesHealthy = append(response.NodesHealthy, resp.HostIP.String())
} else {
response.NodesUnhealthy = append(response.NodesUnhealthy, node)
response.NodesUnhealthy = append(response.NodesUnhealthy, resp.HostIP.String())
response.OK = false
}
// pick the first node that has responses and fill it in with the peers it saw
if len(expectedNodes) == 0 {
for peer := range resp.Response.PodResults {
expectedNodes = append(expectedNodes, peer)
}
sort.Strings(expectedNodes)
}
// count the nodes reported by the instance
response.NodesTotal++
}
// 2. check that all nodes report the same peers
// 2. check that all nodes report the expected peers
if len(checkAll.Responses) < 1 {
response.OK = false
} else {