Function New

internal/cmd/manager/instance/run/lease/runnable.go:117–141

New creates a new Runnable.

(
	kubeClient kubernetes.Interface,
	instance *postgres.Instance,
)

// New creates a new Runnable.
func New(
	kubeClient kubernetes.Interface,
	instance *postgres.Instance,
) *Runnable {
	return &Runnable{
		instance: instance,
		config:   defaultConfig(),
		lock: &resourcelock.LeaseLock{
			LeaseMeta: metav1.ObjectMeta{
				Namespace: instance.GetNamespaceName(),
				Name:      instance.GetClusterName(),
			},
			Client: kubeClient.CoordinationV1(),
			LockConfig: resourcelock.ResourceLockConfig{
				// Identity is the pod name alone. The operator creates Pods
				// directly and reuses a pod name only after the previous
				// incarnation is confirmed dead, so any process running under
				// this Identity is the legitimate holder.
				Identity: instance.GetPodName(),
			},
		},
		activateCh: make(chan struct{}),
		heldCh:     make(chan struct{}),
	}
}

// Acquire signals the runnable to start competing for the lease using the
// provided configuration, then blocks until the lease is held or ctx is