Skip to content

Commit b98be5c

Browse files
committed
added isCluster method
1 parent e35f040 commit b98be5c

File tree

4 files changed

+18
-0
lines changed

4 files changed

+18
-0
lines changed

src/main/java/com/redislabs/testcontainers/RedisClusterContainer.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,12 @@ protected RedisClusterContainer(final String dockerImageName) {
3434
waitingFor(Wait.forLogMessage(".*Cluster state changed: ok*\\n", 1));
3535
}
3636

37+
@Override
38+
public boolean isCluster() {
39+
return true;
40+
}
41+
42+
3743
public RedisClusterContainer withKeyspaceNotifications() {
3844
setDockerImageName(KEYSPACE_NOTIFICATIONS_IMAGE_NAME);
3945
return this;

src/main/java/com/redislabs/testcontainers/RedisContainer.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,4 +4,6 @@ public interface RedisContainer {
44

55
String getRedisURI();
66

7+
boolean isCluster();
8+
79
}

src/main/java/com/redislabs/testcontainers/RedisModulesContainer.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,11 @@ public RedisModulesContainer() {
1111
this(DEFAULT_IMAGE_NAME.withTag(DEFAULT_TAG));
1212
}
1313

14+
@Override
15+
public boolean isCluster() {
16+
return false;
17+
}
18+
1419
protected RedisModulesContainer(final DockerImageName dockerImageName) {
1520
super(dockerImageName);
1621
}

src/main/java/com/redislabs/testcontainers/RedisStandaloneContainer.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,11 @@ protected RedisStandaloneContainer(final DockerImageName dockerImageName) {
1616
super(dockerImageName);
1717
}
1818

19+
@Override
20+
public boolean isCluster() {
21+
return false;
22+
}
23+
1924
@SuppressWarnings("unchecked")
2025
public <C extends RedisStandaloneContainer> C withKeyspaceNotifications() {
2126
withCopyFileToContainer(MountableFile.forClasspathResource("redis-keyspace-notifications.conf"), "/data/redis.conf");

0 commit comments

Comments
 (0)