INNER CODE UNIT · Go

assertMemberClusterNamespacesExist

mongodb/mongodb-enterprise-kubernetes · tools/multicluster/main_test.go:381

func assertMemberClusterNamespacesExist(t *testing.T, clientMap map[string]kubernetes.Interface, flags flags) {
	for _, clusterName := range flags.memberClusters {
		client := clientMap[clusterName]
		ns, err := client.CoreV1().Namespaces().Get(context.TODO(), flags.memberClusterNamespace, metav1.GetOptions{})
		assert.NoError(t, err)
		assert.NotNil(t, ns)
		assert.Equal(t, flags.memberClusterNamespace, ns.Name)
		assert.Equal(t, ns.Labels, multiClusterLabels())
	}
}

// assertCentralClusterNamespacesExist asserts the Namespace in the central cluster exists..
func assertCentralClusterNamespacesExist(t *testing.T, clientMap map[string]kubernetes.Interface, flags flags) {
	client := clientMap[flags.centralCluster]
	ns, err := client.CoreV1().Namespaces().Get(context.TODO(), flags.centralClusterNamespace, metav1.GetOptions{})
	assert.NoError(t, err)
	assert.NotNil(t, ns)
	assert.Equal(t, flags.centralClusterNamespace, ns.Name)

View source record →