mirror of https://github.com/k3s-io/k3s
Make Elasticsearch logging test check for node failures
parent
8b235210c6
commit
492d22972b
|
@ -164,6 +164,18 @@ func ClusterLevelLoggingWithElasticsearch(f *Framework) {
|
||||||
if nodeCount == 0 {
|
if nodeCount == 0 {
|
||||||
Failf("Failed to find any nodes")
|
Failf("Failed to find any nodes")
|
||||||
}
|
}
|
||||||
|
Logf("Found %d nodes.", len(nodes.Items))
|
||||||
|
|
||||||
|
// Filter out unhealthy nodes.
|
||||||
|
// Previous tests may have cause failures of some nodes. Let's skip
|
||||||
|
// 'Not Ready' nodes, just in case (there is no need to fail the test).
|
||||||
|
filterNodes(nodes, func(node api.Node) bool {
|
||||||
|
return isNodeReadySetAsExpected(&node, true)
|
||||||
|
})
|
||||||
|
if len(nodes.Items) < 2 {
|
||||||
|
Failf("Less than two nodes were found Ready.")
|
||||||
|
}
|
||||||
|
Logf("Found %d healthy nodes.", len(nodes.Items))
|
||||||
|
|
||||||
// Create a unique root name for the resources in this test to permit
|
// Create a unique root name for the resources in this test to permit
|
||||||
// parallel executions of this test.
|
// parallel executions of this test.
|
||||||
|
|
Loading…
Reference in New Issue