k8up-io/k8up

Similar blocks of code found in 8 locations. Consider refactoring.

Open

func (in *PruneList) DeepCopyInto(out *PruneList) {
    *out = *in
    out.TypeMeta = in.TypeMeta
    in.ListMeta.DeepCopyInto(&out.ListMeta)
    if in.Items != nil {

• Read up
  Read up

Method Backend.DeepCopyInto has 64 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (in *Backend) DeepCopyInto(out *Backend) {
    *out = *in
    if in.RepoPasswordSecretRef != nil {
        in, out := &in.RepoPasswordSecretRef, &out.RepoPasswordSecretRef
        *out = new(corev1.SecretKeySelector)

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (c *CheckExecutor) attachTLSVolumeMounts() []corev1.VolumeMount {
    var tlsVolumeMounts []corev1.VolumeMount
    if c.check.Spec.Backend != nil && !utils.ZeroLen(c.check.Spec.Backend.VolumeMounts) {
        tlsVolumeMounts = append(tlsVolumeMounts, *c.check.Spec.Backend.VolumeMounts...)
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (b *BackupExecutor) attachTLSVolumeMounts() []corev1.VolumeMount {
    var tlsVolumeMounts []corev1.VolumeMount
    if b.backup.Spec.Backend != nil && !utils.ZeroLen(b.backup.Spec.Backend.VolumeMounts) {
        tlsVolumeMounts = append(tlsVolumeMounts, *b.backup.Spec.Backend.VolumeMounts...)
    }

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func (p *PruneExecutor) attachTLSVolumeMounts() []corev1.VolumeMount {
    var tlsVolumeMounts []corev1.VolumeMount
    if p.prune.Spec.Backend != nil && !utils.ZeroLen(p.prune.Spec.Backend.VolumeMounts) {
        tlsVolumeMounts = append(tlsVolumeMounts, *p.prune.Spec.Backend.VolumeMounts...)
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

                    S3: &v1.S3Spec{
                        Endpoint: restore.Cfg.S3Endpoint,
                        Bucket:   restore.Cfg.S3Bucket,
                        AccessKeyIDSecretRef: &corev1.SecretKeySelector{
                            Key: restore.Cfg.S3SecretRefUsernameKey,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        S3: &v1.S3Spec{
            Endpoint: restore.Cfg.RestoreToS3Endpoint,
            Bucket:   restore.Cfg.RestoreToS3Bucket,
            AccessKeyIDSecretRef: &corev1.SecretKeySelector{
                Key: restore.Cfg.RestoreToS3SecretUsernameKey,

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    if in.VolumeMounts != nil {
        in, out := &in.VolumeMounts, &out.VolumeMounts
        *out = new([]corev1.VolumeMount)
        if **in != nil {
            in, out := *in, *out

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    if in.VolumeMounts != nil {
        in, out := &in.VolumeMounts, &out.VolumeMounts
        *out = new([]corev1.VolumeMount)
        if **in != nil {
            in, out := *in, *out

• Read up
  Read up

Method ScheduleSpec.DeepCopyInto has 52 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (in *ScheduleSpec) DeepCopyInto(out *ScheduleSpec) {
    *out = *in
    if in.Restore != nil {
        in, out := &in.Restore, &out.Restore
        *out = new(RestoreSchedule)

Method Restic.Prune has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (r *Restic) Prune(tags ArrayOpts) error {
    prunelogger := r.logger.WithName("prune")

    prunelogger.Info("pruning repository")

Method PodLister.ListPods has 51 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (p *PodLister) ListPods() ([]BackupPod, error) {
    p.log.Info("listing all pods", "annotation", p.backupCommandAnnotation, "namespace", p.namespace)

    if p.err != nil {
        return nil, p.err

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func SetSucceeded(ctx context.Context, name, ns string, typ k8upv1.JobType, objStatus *k8upv1.Status, message string) {
    log := controllerruntime.LoggerFrom(ctx)

    if !objStatus.HasSucceeded() {
        // only increase success counter if new condition

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func SetFailed(ctx context.Context, name, ns string, typ k8upv1.JobType, objStatus *k8upv1.Status, message string) {
    log := controllerruntime.LoggerFrom(ctx)

    if !objStatus.HasFailed() {
        // only increase fail counter if new condition

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    restoreOptions := resticCli.RestoreOptions{
        RestoreType:   resticCli.RestoreType(cfg.Config.RestoreType),
        RestoreDir:    cfg.Config.RestoreDir,
        RestoreFilter: cfg.Config.RestoreFilter,
        Verify:        cfg.Config.VerifyRestore,

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    restoreOptions := resticCli.RestoreOptions{
        RestoreType:   resticCli.RestoreType(cfg.Config.RestoreType),
        RestoreDir:    cfg.Config.RestoreDir,
        RestoreFilter: cfg.Config.RestoreFilter,
        Verify:        cfg.Config.VerifyRestore,

• Read up
  Read up

Method BackupExecutor.startBackup has 10 return statements (exceeds 4 allowed).

Open

func (b *BackupExecutor) startBackup(ctx context.Context) error {
    ready, err := b.StartPreBackup(ctx)
    if err != nil {
        return err
    }

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func RandomStringGenerator(n int) string {
    var characters = []rune("abcdefghijklmnopqrstuvwxyz1234567890")
    rand.New(rand.NewSource(time.Now().UnixNano()))
    b := make([]rune, n)
    for i := range b {

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

func RandomStringGenerator(n int) string {
    var characters = []rune("abcdefghijklmnopqrstuvwxyz1234567890")
    rand.New(rand.NewSource(time.Now().UnixNano()))
    b := make([]rune, n)
    for i := range b {

• Read up
  Read up

Function RunRestore has 8 return statements (exceeds 4 allowed).

Open

func RunRestore(ctx *cli.Context) error {
    var restoreName, snapshot string
    var s3, pvc v1.RestoreMethod
    logger := cmd.AppLogger(ctx).WithName("cli-restore")