GetLeaderInfoFromLease gathers leader holderIdentity from the lease
( ctx context.Context, kubeInterface kubernetes.Interface, operatorNamespace string, )
| 334 | |
| 335 | // GetLeaderInfoFromLease gathers leader holderIdentity from the lease |
| 336 | func GetLeaderInfoFromLease( |
| 337 | ctx context.Context, |
| 338 | kubeInterface kubernetes.Interface, |
| 339 | operatorNamespace string, |
| 340 | ) (string, error) { |
| 341 | leaseInterface := kubeInterface.CoordinationV1().Leases(operatorNamespace) |
| 342 | lease, err := leaseInterface.Get(ctx, controller.LeaderElectionID, metav1.GetOptions{}) |
| 343 | if err != nil { |
| 344 | return "", err |
| 345 | } |
| 346 | return *lease.Spec.HolderIdentity, nil |
| 347 | } |