util

func CertificateRevisions ¶

func CertificateRevisions(certs []*certmanagerv1.Certificate) (map[string]string, bool)

CertificateRevisions returns a map of name to revision for each certificate. It returns false if any Certificate is not ready.

func EngageFor ¶

func EngageFor(opts []mcbuilder.EngageOptions) []mcbuilder.ForOption

EngageFor casts engage options for For. mcbuilder has no controller-wide engage setting, so the same options must be cast per builder method.

func EngageOwns ¶

func EngageOwns(opts []mcbuilder.EngageOptions) []mcbuilder.OwnsOption

EngageOwns casts engage options for Owns.

func EngageWatches ¶

func EngageWatches(opts []mcbuilder.EngageOptions) []mcbuilder.WatchesOption

EngageWatches casts engage options for Watches.

func EnqueueAllInNamespace ¶

func EnqueueAllInNamespace(newList func() ctrlruntimeclient.ObjectList) mchandler.EventHandlerFunc

EnqueueAllInNamespace wakes every object the given list type yields in the changed object's namespace. The compiled controllers mount Secrets they do not own, so an ownership-based watch would never fire for them and a Deployment blocked on a missing mount would never be retried.

func EnqueueMapped ¶

func EnqueueMapped(mapFunc ClusterMapFunc) mchandler.EventHandlerFunc

EnqueueMapped adapts a ClusterMapFunc to Watches, which takes a factory rather than a handler because the cluster is only known once it is engaged.

func FakeSingleCluster ¶

func FakeSingleCluster(c ctrlruntimeclient.Client) func(context.Context, multicluster.ClusterName) (cluster.Cluster, error)

FakeSingleCluster serves the given client for every cluster name, so a reconciler can be tested without a manager or a provider.

func FetchRootShard ¶

func FetchRootShard(ctx context.Context, client ctrlruntimeclient.Client, namespace string, ref *corev1.LocalObjectReference) (metav1.Condition, *operatorv1alpha1.RootShard)

func GetCompiledAvailableCondition ¶

func GetCompiledAvailableCondition(conditions []metav1.Condition, compiledName string) metav1.Condition

GetCompiledAvailableCondition adopts the Available condition published on a Compiled* object, so the source object still reports on the Deployment it no longer owns.

func GetDeploymentAvailableCondition ¶

func GetDeploymentAvailableCondition(ctx context.Context, client ctrlruntimeclient.Client, key types.NamespacedName) (metav1.Condition, error)

func GetRootShardChildren ¶

func GetRootShardChildren(ctx context.Context, client ctrlruntimeclient.Client, rootShard *operatorv1alpha1.RootShard) ([]operatorv1alpha1.Shard, error)

GetRootShardChildren returns all shards that are currently registered with the given root shard. The shards are sorted by name before returning.

func GetTestScheme ¶

func GetTestScheme() *runtime.Scheme

func MutateKeys ¶

func MutateKeys(m map[string]string, prefix, suffix string) map[string]string

MutateKeys returns a copy of m with each key wrapped by prefix and suffix.

func UpdateCondition ¶

func UpdateCondition(conditions []metav1.Condition, newCondition metav1.Condition) []metav1.Condition