protected EncryptedRestoreBase()

in priam/src/main/java/com/netflix/priam/restore/EncryptedRestoreBase.java [52:91]

39 lines of code
1 McCabe index (conditional complexity)


    protected EncryptedRestoreBase(
            IConfiguration config,
            IBackupFileSystem fs,
            String jobName,
            Sleeper sleeper,
            ICassandraProcess cassProcess,
            Provider<AbstractBackupPath> pathProvider,
            InstanceIdentity instanceIdentity,
            RestoreTokenSelector tokenSelector,
            ICredentialGeneric pgpCredential,
            IFileCryptography fileCryptography,
            ICompression compress,
            MetaData metaData,
            InstanceState instanceState,
            IPostRestoreHook postRestoreHook) {
        super(
                config,
                fs,
                jobName,
                sleeper,
                pathProvider,
                instanceIdentity,
                tokenSelector,
                cassProcess,
                metaData,
                instanceState,
                postRestoreHook);

        this.jobName = jobName;
        this.pgpCredential = pgpCredential;
        this.fileCryptography = fileCryptography;
        this.compress = compress;
        executor = new NamedThreadPoolExecutor(config.getRestoreThreads(), jobName);
        executor.allowCoreThreadTimeOut(true);
        logger.info(
                "Trying to restore cassandra cluster with filesystem: {}, RestoreStrategy: {}, Encryption: ON, Compression: {}",
                fs.getClass(),
                jobName,
                compress.getClass());
    }