kuma

1
package framework
2

3
import (
4
	"strings"
5
)
6

7
// IsDataplaneOnline returns online, found, error
8
func IsDataplaneOnline(cluster Cluster, mesh, name string) (bool, bool, error) {
9
	out, err := cluster.GetKumactlOptions().RunKumactlAndGetOutput("inspect", "dataplanes", "--mesh", mesh)
10
	if err != nil {
11
		return false, false, err
12
	}
13
	for _, line := range strings.Split(out, "\n") {
14
		if strings.Contains(line, name) {
15
			return strings.Contains(line, "Online"), true, nil
16
		}
17
	}
18
	return false, false, nil
19
}
20

21
func DataplaneReceivedConfig(cluster Cluster, mesh, name string) (bool, error) {
22
	out, err := cluster.GetKumactlOptions().RunKumactlAndGetOutput("inspect", "dataplanes", "--mesh", mesh, "-o", "yaml", name)
23
	if err != nil {
24
		return false, err
25
	}
26
	return strings.Contains(out, `responsesAcknowledged`), nil
27
}
28