multiclusterservice

func BuildMultiClusterService ¶

func BuildMultiClusterService(cd *kcmv1.ClusterDeployment, multiClusterServiceTemplate, multiClusterServiceMatchLabel, name string) *kcmv1.MultiClusterService

BuildMultiClusterService constructs a MultiClusterService spec for the given ClusterDeployment.

func CreateMultiClusterService ¶

func CreateMultiClusterService(ctx context.Context, cl client.Client, mcs *kcmv1.MultiClusterService)

func CreateMultiClusterServiceWithDelete ¶ added in v1.6.0

func CreateMultiClusterServiceWithDelete(
	ctx context.Context,
	cl client.Client,
	mcs *kcmv1.MultiClusterService,
) func() error

func DeleteMultiClusterService ¶ added in v1.6.0

func DeleteMultiClusterService(ctx context.Context, cl client.Client, mc *kcmv1.MultiClusterService)

func GetMultiClusterService ¶ added in v1.6.0

func GetMultiClusterService(ctx context.Context, cl client.Client, key client.ObjectKey) (*kcmv1.MultiClusterService, error)

func ValidateMCSConditions ¶ added in v1.6.0

func ValidateMCSConditions(ctx context.Context, cl client.Client, mcsKey client.ObjectKey, expectedConditions []metav1.Condition)

ValidateMCSConditions validates that the provided list of expected conditions eventually exist in the status of the MCS object represented by the provided key.

func ValidateMultiClusterService ¶

func ValidateMultiClusterService(ctx context.Context, kc *kubeclient.KubeClient, name string, expectedCount int)

ValidateMultiClusterService wraps the Eventually check for validation.

func ValidateServiceSet ¶ added in v1.6.0

func ValidateServiceSet(ctx context.Context, cl client.Client, systemNamespace string, cd *kcmv1.ClusterDeployment, mcs *kcmv1.MultiClusterService)

ValidateServiceSet validates the ServiceSet associated with the provided CD and MCS.