MCPcopy Create free account
hub / github.com/cloudnative-pg/cloudnative-pg / GetLeaderInfoFromLease

Function GetLeaderInfoFromLease

tests/utils/operator/operator.go:336–347  ·  view source on GitHub ↗

GetLeaderInfoFromLease gathers leader holderIdentity from the lease

(
	ctx context.Context,
	kubeInterface kubernetes.Interface,
	operatorNamespace string,
)

Source from the content-addressed store, hash-verified

334
335// GetLeaderInfoFromLease gathers leader holderIdentity from the lease
336func 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}

Callers 1

Calls 1

GetMethod · 0.45

Tested by

no test coverage detected