You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by if...@apache.org on 2020/06/10 10:27:03 UTC
[cassandra-in-jvm-dtest-api] branch master updated: CASSANDRA-15851
- add instance initializer
This is an automated email from the ASF dual-hosted git repository.
ifesdjeen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/cassandra-in-jvm-dtest-api.git
The following commit(s) were added to refs/heads/master by this push:
new c2feaad CASSANDRA-15851 - add instance initializer
new ad54e22 Merge pull request #11 from krummas/marcuse/15851
c2feaad is described below
commit c2feaad0543f7872791c67cfd8d5b9672a0998db
Author: Marcus Eriksson <ma...@apache.org>
AuthorDate: Thu Jun 4 10:03:50 2020 +0200
CASSANDRA-15851 - add instance initializer
---
pom.xml | 2 +-
.../cassandra/distributed/shared/AbstractBuilder.java | 13 +++++++++++++
2 files changed, 14 insertions(+), 1 deletion(-)
diff --git a/pom.xml b/pom.xml
index 62c90d8..0ba9add 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>org.apache.cassandra</groupId>
<artifactId>dtest-api</artifactId>
- <version>0.0.2-SNAPSHOT</version>
+ <version>0.0.3-SNAPSHOT</version>
<name>In JVM Test API</name>
<description>In JVM Test API</description>
diff --git a/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java b/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
index cc341a3..d601cda 100644
--- a/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
+++ b/src/main/java/org/apache/cassandra/distributed/shared/AbstractBuilder.java
@@ -29,6 +29,7 @@ import java.nio.file.Files;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
+import java.util.function.BiConsumer;
import java.util.function.Consumer;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
@@ -52,6 +53,7 @@ public abstract class AbstractBuilder<I extends IInstance, C extends ICluster, B
private Consumer<IInstanceConfig> configUpdater;
private ClassLoader sharedClassLoader = Thread.currentThread().getContextClassLoader();
private int broadcastPort = 7012;
+ private BiConsumer<ClassLoader, Integer> instanceInitializer = (cl, id) -> {};
public AbstractBuilder(Factory<I, C, B> factory)
{
@@ -94,6 +96,11 @@ public abstract class AbstractBuilder<I extends IInstance, C extends ICluster, B
return broadcastPort;
}
+ public BiConsumer<ClassLoader, Integer> getInstanceInitializer()
+ {
+ return instanceInitializer;
+ }
+
public C start() throws IOException
{
C cluster = createWithoutStarting();
@@ -255,6 +262,12 @@ public abstract class AbstractBuilder<I extends IInstance, C extends ICluster, B
return (B) this;
}
+ public B withInstanceInitializer(BiConsumer<ClassLoader, Integer> instanceInitializer)
+ {
+ this.instanceInitializer = instanceInitializer;
+ return (B) this;
+ }
+
static String dcName(int index)
{
return "datacenter" + index;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org