INNER CODE UNIT · Go

backupOpt

stashed/stash · pkg/backup/backupsession.go:286

	backupOpt := util.BackupOptionsForBackupTarget(targetInfo.Target, inv.GetRetentionPolicy(), *extraOpt)
	return resticWrapper.RunBackup(backupOpt, targetInfo.Target.Ref)
}

func (c *BackupSessionController) electLeaderPod(targetInfo invoker.BackupTargetInfo, invokerRef *core.ObjectReference, stopCh <-chan struct{}) error {
	klog.Infoln("Attempting to elect leader pod")

	rlc := resourcelock.ResourceLockConfig{
		Identity:      meta.PodName(),
		EventRecorder: eventer.NewEventRecorder(c.K8sClient, BackupEventComponent),
	}
	resLock, err := resourcelock.New(
		resourcelock.LeasesResourceLock,
		c.Namespace,
		util.GetBackupConfigmapLockName(targetInfo.Target.Ref),
		c.K8sClient.CoreV1(),
		c.K8sClient.CoordinationV1(),
		rlc,

View source record →