Function classifyLeaseAdoption

internal/controller/primary_lease.go:118–132

classifyLeaseAdoption decides what to do with an existing Lease named after the cluster. It is pure so the three branches can be unit-tested without an apiserver.

(existing *coordinationv1.Lease, cluster *apiv1.Cluster)

// the cluster. It is pure so the three branches can be unit-tested without an
// apiserver.
func classifyLeaseAdoption(existing *coordinationv1.Lease, cluster *apiv1.Cluster) leaseAdoption {
	if metav1.IsControlledBy(existing, cluster) {
		return adoptAlreadyOurs
	}
	owner := metav1.GetControllerOf(existing)
	if owner == nil {
		return adoptOrphan
	}
	if owner.Kind == apiv1.ClusterKind &&
		owner.APIVersion == apiv1.SchemeGroupVersion.String() &&
		owner.Name == cluster.Name {
		return adoptOrphan
	}
	return adoptRefuseForeign
}