chore(dynomite): Removing dynomite from codebase

README.md

@@ -44,7 +44,6 @@ All these metrics can be grouped by a `monitor` tag (e.g. `DockerMonitor`, `Jenk
 The following storage backends are supported:
 
 - Redis
-- Dynomite
 
 Relevant properties:
 ```

igor-web/igor-web.gradle

@@ -74,7 +74,6 @@ dependencies {
     implementation "com.netflix.spinnaker.kork:kork-stackdriver"
     implementation "com.netflix.spinnaker.kork:kork-web"
     implementation "com.netflix.spinnaker.kork:kork-jedis"
-    implementation "com.netflix.spinnaker.kork:kork-dynomite"
     implementation "com.netflix.spinnaker.kork:kork-telemetry"
     implementation "com.netflix.spinnaker.kork:kork-hystrix"
     implementation "com.netflix.spinnaker.kork:kork-secrets-aws"

igor-web/src/main/groovy/com/netflix/spinnaker/igor/docker/DockerRegistryCacheV2KeysMigration.java

@@ -17,11 +17,7 @@
 
 import static java.lang.String.format;
 
-import com.netflix.dyno.connectionpool.CursorBasedResult;
-import com.netflix.dyno.connectionpool.exception.DynoException;
-import com.netflix.dyno.jedis.DynoJedisClient;
 import com.netflix.spinnaker.igor.IgorConfigurationProperties;
-import com.netflix.spinnaker.kork.dynomite.DynomiteClientDelegate;
 import com.netflix.spinnaker.kork.jedis.RedisClientDelegate;
 import java.time.Duration;
 import java.util.List;
@@ -134,9 +130,6 @@ private void migrateBatch(List<DockerRegistryV1Key> oldKeys) {
    */
   private int getV1Keys(MultiKeyCommands client) {
     try {
-      if (redis instanceof DynomiteClientDelegate) {
-        return v1Keys((DynoJedisClient) client);
-      }
       return v1Keys((Jedis) client);
     } catch (InterruptedException e) {
       log.error("Migration could not complete because it was interrupted", e);
@@ -160,38 +153,6 @@ private int getV1Keys(MultiKeyCommands client) {
         return size;
       };
 
-  /** Dynomite-compat v1keys */
-  private int v1Keys(DynoJedisClient dyno) throws InterruptedException {
-    int numMigrated = 0;
-    int failures = 0;
-
-    String pattern = oldIndexPattern();
-    CursorBasedResult<String> result = null;
-    do {
-      try {
-        // This is a really weird interface.
-        if (result == null) {
-          result = dyno.dyno_scan(pattern);
-        } else {
-          result = dyno.dyno_scan(result, 10, pattern);
-        }
-
-        numMigrated += oldKeysCallback.apply(result.getResult());
-        failures = 0;
-      } catch (DynoException e) {
-        failures++;
-        if (failures >= 5) {
-          log.error("Failed migrating v1 key batch after 5 attempts, aborting", e);
-          throw new AbortedAfterExcessiveFailures(e);
-        }
-        log.error("Failed migrating v1 key batch, retrying", e);
-        Thread.sleep(5000);
-      }
-    } while (result == null || !result.isComplete());
-
-    return numMigrated;
-  }
-
   /** Redis-compat v1keys */
   private int v1Keys(Jedis jedis) throws InterruptedException {
     int numMigrated = 0;