diff --git a/adapter-amqp/src/main/java/io/nosqlbench/adapter/amqp/AmqpDriverAdapter.java b/adapter-amqp/src/main/java/io/nosqlbench/adapter/amqp/AmqpDriverAdapter.java index 559ffbe06..b7a18e93b 100644 --- a/adapter-amqp/src/main/java/io/nosqlbench/adapter/amqp/AmqpDriverAdapter.java +++ b/adapter-amqp/src/main/java/io/nosqlbench/adapter/amqp/AmqpDriverAdapter.java @@ -57,12 +57,4 @@ public class AmqpDriverAdapter extends BaseDriverAdapter { return remappers; } - @Service(value = DriverAdapterLoader.class,selector = "cqld4") - public static class Loader implements DriverAdapterLoader { - @Override - public Cqld4DriverAdapter load(NBComponent parent, NBLabels childLabels) { - return new Cqld4DriverAdapter(parent,childLabels); - } - } - } diff --git a/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4DriverAdapterLoader.java b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4DriverAdapterLoader.java new file mode 100644 index 000000000..ea18bcc2d --- /dev/null +++ b/adapter-cqld4/src/main/java/io/nosqlbench/adapter/cqld4/Cqld4DriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.cqld4; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "cqld4") +public class Cqld4DriverAdapterLoader implements DriverAdapterLoader { + @Override + public Cqld4DriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new Cqld4DriverAdapter(parent, childLabels); + } +} diff --git a/adapter-diag/src/main/java/io/nosqlbench/adapter/diag/DiagDriverAdapterLoader.java b/adapter-diag/src/main/java/io/nosqlbench/adapter/diag/DiagDriverAdapterLoader.java index 1b990b053..050a42c32 100644 --- a/adapter-diag/src/main/java/io/nosqlbench/adapter/diag/DiagDriverAdapterLoader.java +++ b/adapter-diag/src/main/java/io/nosqlbench/adapter/diag/DiagDriverAdapterLoader.java @@ -1,5 +1,23 @@ package io.nosqlbench.adapter.diag; +/* + * Copyright (c) 2022 nosqlbench + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + + import io.nosqlbench.api.labels.NBLabels; import io.nosqlbench.components.NBComponent; import io.nosqlbench.nb.annotations.Service; diff --git a/adapter-dynamodb/src/main/java/io/nosqlbench/adapter/dynamodb/DynamoDBDriverAdapter.java b/adapter-dynamodb/src/main/java/io/nosqlbench/adapter/dynamodb/DynamoDBDriverAdapter.java index 615f11a88..1c7e6f929 100644 --- a/adapter-dynamodb/src/main/java/io/nosqlbench/adapter/dynamodb/DynamoDBDriverAdapter.java +++ b/adapter-dynamodb/src/main/java/io/nosqlbench/adapter/dynamodb/DynamoDBDriverAdapter.java @@ -55,12 +55,4 @@ public class DynamoDBDriverAdapter extends BaseDriverAdapter { return super.getConfigModel().add(HttpSpace.getConfigModel()).add(thisCfgModel); } - @Service(value = DriverAdapterLoader.class,selector = "http") - public static class Loader implements DriverAdapterLoader { - @Override - public HttpDriverAdapter load(NBComponent parent, NBLabels childLabels) { - return new HttpDriverAdapter(parent,childLabels); - } - } - } diff --git a/adapter-http/src/main/java/io/nosqlbench/adapter/http/HttpDriverAdapterLoader.java b/adapter-http/src/main/java/io/nosqlbench/adapter/http/HttpDriverAdapterLoader.java new file mode 100644 index 000000000..0c400606b --- /dev/null +++ b/adapter-http/src/main/java/io/nosqlbench/adapter/http/HttpDriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.http; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "http") +public class HttpDriverAdapterLoader implements DriverAdapterLoader { + @Override + public HttpDriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new HttpDriverAdapter(parent, childLabels); + } +} diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapter.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapter.java index 705a8956a..8962f4f83 100644 --- a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapter.java +++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapter.java @@ -56,12 +56,5 @@ public class KafkaDriverAdapter extends BaseDriverAdapter { public NBConfigModel getConfigModel() { return super.getConfigModel().add(KafkaSpace.getConfigModel()); } - @Service(value = DriverAdapterLoader.class,selector = "kafka") - public static class Loader implements DriverAdapterLoader { - @Override - public KafkaDriverAdapter load(NBComponent parent, NBLabels childLabels) { - return new KafkaDriverAdapter(parent,childLabels); - } - } } diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapterLoader.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapterLoader.java new file mode 100644 index 000000000..a1a3fbc18 --- /dev/null +++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/KafkaDriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.kafka; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "kafka") +public class KafkaDriverAdapterLoader implements DriverAdapterLoader { + @Override + public KafkaDriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new KafkaDriverAdapter(parent, childLabels); + } +} diff --git a/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/KafkaDriverAdapterLoader.java b/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/KafkaDriverAdapterLoader.java new file mode 100644 index 000000000..0a7040fd1 --- /dev/null +++ b/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/KafkaDriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.mongodb.core; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "mongodb") +public class KafkaDriverAdapterLoader implements DriverAdapterLoader { + @Override + public MongodbDriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new MongodbDriverAdapter(parent, childLabels); + } +} diff --git a/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/MongodbDriverAdapter.java b/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/MongodbDriverAdapter.java index 42fc4c4ff..0e4553bb3 100644 --- a/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/MongodbDriverAdapter.java +++ b/adapter-mongodb/src/main/java/io/nosqlbench/adapter/mongodb/core/MongodbDriverAdapter.java @@ -54,12 +54,4 @@ public class MongodbDriverAdapter extends BaseDriverAdapter { return super.getConfigModel().add(MongoSpace.getConfigModel()); } - @Service(value = DriverAdapterLoader.class,selector = "mongodb") - public static class Loader implements DriverAdapterLoader { - @Override - public MongodbDriverAdapter load(NBComponent parent, NBLabels childLabels) { - return new MongodbDriverAdapter(parent,childLabels); - } - } - } diff --git a/adapter-pgvector/src/main/java/io/nosqlbench/adapter/pgvector/PGVectorDriverAdapterLoader.java b/adapter-pgvector/src/main/java/io/nosqlbench/adapter/pgvector/PGVectorDriverAdapterLoader.java new file mode 100644 index 000000000..914c1522b --- /dev/null +++ b/adapter-pgvector/src/main/java/io/nosqlbench/adapter/pgvector/PGVectorDriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.pgvector; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "jdbc") +public class PGVectorDriverAdapterLoader implements DriverAdapterLoader { + @Override + public PGVectorDriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new PGVectorDriverAdapter(parent, childLabels); + } +} diff --git a/adapter-pinecone/src/main/java/io/nosqlbench/adapter/pinecone/PineconeDriverAdapter.java b/adapter-pinecone/src/main/java/io/nosqlbench/adapter/pinecone/PineconeDriverAdapter.java index 0774274ce..0ecdadba8 100644 --- a/adapter-pinecone/src/main/java/io/nosqlbench/adapter/pinecone/PineconeDriverAdapter.java +++ b/adapter-pinecone/src/main/java/io/nosqlbench/adapter/pinecone/PineconeDriverAdapter.java @@ -54,12 +54,4 @@ public class PineconeDriverAdapter extends BaseDriverAdapter { return super.getConfigModel().add(S4JSpace.getConfigModel()); } - @Service(value = DriverAdapterLoader.class,selector = "s4j") - public static class Loader implements DriverAdapterLoader { - @Override - public S4JDriverAdapter load(NBComponent parent, NBLabels childLabels) { - return new S4JDriverAdapter(parent,childLabels); - } - } - } diff --git a/adapter-s4j/src/main/java/io/nosqlbench/adapter/s4j/S4JDriverAdapterLoader.java b/adapter-s4j/src/main/java/io/nosqlbench/adapter/s4j/S4JDriverAdapterLoader.java new file mode 100644 index 000000000..8946b857e --- /dev/null +++ b/adapter-s4j/src/main/java/io/nosqlbench/adapter/s4j/S4JDriverAdapterLoader.java @@ -0,0 +1,14 @@ +package io.nosqlbench.adapter.s4j; + +import io.nosqlbench.adapter.diag.DriverAdapterLoader; +import io.nosqlbench.api.labels.NBLabels; +import io.nosqlbench.components.NBComponent; +import io.nosqlbench.nb.annotations.Service; + +@Service(value = DriverAdapterLoader.class, selector = "s4j") +public class S4JDriverAdapterLoader implements DriverAdapterLoader { + @Override + public S4JDriverAdapter load(NBComponent parent, NBLabels childLabels) { + return new S4JDriverAdapter(parent, childLabels); + } +} diff --git a/adapter-stdout/src/main/java/io/nosqlbench/adapter/stdout/StdoutDriverAdapter.java b/adapter-stdout/src/main/java/io/nosqlbench/adapter/stdout/StdoutDriverAdapter.java index 1b681cb12..a8b3be99a 100644 --- a/adapter-stdout/src/main/java/io/nosqlbench/adapter/stdout/StdoutDriverAdapter.java +++ b/adapter-stdout/src/main/java/io/nosqlbench/adapter/stdout/StdoutDriverAdapter.java @@ -116,13 +116,5 @@ public class StdoutDriverAdapter extends BaseDriverAdapter ACTIVITYTYPE_SPI_FINDER = new SimpleServiceLoader(ActivityType.class, Maturity.Any); private final SimpleServiceLoader DRIVERADAPTER_SPI_FINDER = new SimpleServiceLoader<>(DriverAdapter.class, Maturity.Any); + private final SimpleServiceLoader DRIVERADAPTERLOADER_SPI_FINDER = new SimpleServiceLoader<>(DriverAdapterLoader.class, Maturity.Any); private final Set jarUrls = new HashSet<>(); public ActivityTypeLoader setMaturity(final Maturity maturity) { @@ -153,11 +155,12 @@ public class ActivityTypeLoader { } public Set getAllSelectors() { - final Map allSelectors = this.ACTIVITYTYPE_SPI_FINDER.getAllSelectors(); - final Map addAdapters = this.DRIVERADAPTER_SPI_FINDER.getAllSelectors(); +// final Map allSelectors = this.ACTIVITYTYPE_SPI_FINDER.getAllSelectors(); +// final Map allAdapters = this.DRIVERADAPTER_SPI_FINDER.getAllSelectors(); + final Map allAdapterLoaders = this.DRIVERADAPTERLOADER_SPI_FINDER.getAllSelectors(); final Set all = new LinkedHashSet<>(); - all.addAll(allSelectors.keySet()); - all.addAll(addAdapters.keySet()); +// all.addAll(allSelectors.keySet()); + all.addAll(allAdapterLoaders.keySet()); return all; } }