INNER CODE UNIT · Go

assertServiceAccountsExist

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

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

	client := clientMap[flags.centralCluster]
	sa, err := client.CoreV1().ServiceAccounts(flags.centralClusterNamespace).Get(context.TODO(), flags.serviceAccount, metav1.GetOptions{})
	assert.NoError(t, err)
	assert.NotNil(t, sa)
	assert.Equal(t, flags.serviceAccount, sa.Name)
	assert.Equal(t, sa.Labels, multiClusterLabels())
}

View source record →