-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
53 changed files
with
1,293 additions
and
138 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
41 changes: 41 additions & 0 deletions
41
.../deployment/src/main/java/io/quarkiverse/temporal/deployment/devui/TemporalContainer.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,41 @@ | ||
| package io.quarkiverse.temporal.deployment.devui; | ||
|
|
||
| import org.testcontainers.containers.GenericContainer; | ||
| import org.testcontainers.utility.DockerImageName; | ||
|
|
||
| // import io.quarkus.devservices.common.ConfigureUtil; | ||
|
|
||
| public class TemporalContainer extends GenericContainer<TemporalContainer> { | ||
|
|
||
| private static final Integer SERVER_EXPOSED_PORT = 7233; | ||
| private static final Integer UI_EXPOSED_PORT = 8233; | ||
|
|
||
| private final TemporalDevserviceConfig config; | ||
| private String serviceName; | ||
| // private String hostname; | ||
|
|
||
| public TemporalContainer(DockerImageName dockerImageName, TemporalDevserviceConfig config) { | ||
| super(dockerImageName); | ||
| this.config = config; | ||
| this.serviceName = "temporal"; | ||
| } | ||
|
|
||
| @Override | ||
| protected void configure() { | ||
| super.configure(); | ||
|
|
||
| withCreateContainerCmdModifier(cmd -> { | ||
| cmd.withEntrypoint("/usr/local/bin/temporal"); | ||
| cmd.withCmd("server", "start-dev", "--ip", "0.0.0.0"); | ||
| }); | ||
|
|
||
| withExposedPorts(SERVER_EXPOSED_PORT, UI_EXPOSED_PORT); | ||
|
|
||
| withLabel("quarkus-devservice-temporal", serviceName); | ||
|
|
||
| withReuse(config.reuse()); | ||
|
|
||
| // hostname = ConfigureUtil.configureSharedNetwork(this, "temporal-" + serviceName); | ||
| } | ||
|
|
||
| } |
37 changes: 37 additions & 0 deletions
37
...ment/src/main/java/io/quarkiverse/temporal/deployment/devui/TemporalDevserviceConfig.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,37 @@ | ||
| package io.quarkiverse.temporal.deployment.devui; | ||
|
|
||
| import io.quarkus.runtime.annotations.ConfigPhase; | ||
| import io.quarkus.runtime.annotations.ConfigRoot; | ||
| import io.smallrye.config.ConfigMapping; | ||
| import io.smallrye.config.WithDefault; | ||
|
|
||
| @ConfigMapping(prefix = "quarkus.temporal.devservice") | ||
| @ConfigRoot(phase = ConfigPhase.BUILD_TIME) | ||
| public interface TemporalDevserviceConfig { | ||
|
|
||
| /** | ||
| * Enable the Temporal Devservice. | ||
| */ | ||
| @WithDefault("true") | ||
| Boolean enabled(); | ||
|
|
||
| /** | ||
| * The image to use for the Temporal Devservice. | ||
| */ | ||
| // @WithDefault("temporalio/auto-setup") | ||
| @WithDefault("temporaliotest/auto-setup") | ||
| String image(); | ||
|
|
||
| /** | ||
| * The version of the image to use for the Temporal Devservice. | ||
| */ | ||
| @WithDefault("latest") | ||
| String version(); | ||
|
|
||
| /** | ||
| * Whether to reuse the Temporal Devservice. | ||
| */ | ||
| @WithDefault("true") | ||
| Boolean reuse(); | ||
|
|
||
| } |
41 changes: 41 additions & 0 deletions
41
...t/src/main/java/io/quarkiverse/temporal/deployment/devui/TemporalDevserviceProcessor.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,41 @@ | ||
| package io.quarkiverse.temporal.deployment.devui; | ||
|
|
||
| import java.util.Map; | ||
|
|
||
| import org.testcontainers.utility.DockerImageName; | ||
|
|
||
| import io.quarkus.deployment.IsNormal; | ||
| import io.quarkus.deployment.annotations.BuildProducer; | ||
| import io.quarkus.deployment.annotations.BuildStep; | ||
| import io.quarkus.deployment.annotations.BuildSteps; | ||
| import io.quarkus.deployment.builditem.DevServicesResultBuildItem; | ||
| import io.quarkus.deployment.dev.devservices.GlobalDevServicesConfig; | ||
| import io.quarkus.devservices.common.ContainerLocator; | ||
|
|
||
| @BuildSteps(onlyIfNot = IsNormal.class, onlyIf = { GlobalDevServicesConfig.Enabled.class }) | ||
| public class TemporalDevserviceProcessor { | ||
|
|
||
| private static final Integer SERVER_EXPOSED_PORT = 7233; | ||
| private static final Integer UI_EXPOSED_PORT = 8233; | ||
| private static final String DEV_SERVICE_LABEL = "quarkus-devservice-temporal"; | ||
| private static final ContainerLocator containerLocator = new ContainerLocator(DEV_SERVICE_LABEL, SERVER_EXPOSED_PORT); | ||
|
|
||
| @BuildStep | ||
| public void build(TemporalDevserviceConfig config, BuildProducer<DevServicesResultBuildItem> devServiceProducer) { | ||
| if (Boolean.FALSE.equals(config.enabled())) { | ||
| return; | ||
| } | ||
|
|
||
| var imageStr = config.image() + ":" + config.version(); | ||
| var image = DockerImageName.parse(imageStr) | ||
| .asCompatibleSubstituteFor(imageStr); | ||
|
|
||
| var serverContainer = new TemporalContainer(image, config); | ||
| serverContainer.start(); | ||
|
|
||
| var serverPort = serverContainer.getMappedPort(SERVER_EXPOSED_PORT); | ||
| devServiceProducer.produce(new DevServicesResultBuildItem("temporal", serverContainer.getContainerId(), Map.of( | ||
| "quarkus.temporal.connection.target", "localhost:" + serverPort))); | ||
| } | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,140 @@ | ||
| <?xml version="1.0" encoding="UTF-8"?> | ||
| <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> | ||
| <modelVersion>4.0.0</modelVersion> | ||
| <parent> | ||
| <groupId>io.quarkiverse.temporal</groupId> | ||
| <artifactId>quarkus-temporal-parent</artifactId> | ||
| <version>999-SNAPSHOT</version> | ||
| </parent> | ||
| <artifactId>integration-tests-devservice</artifactId> | ||
| <name>Temporal - Integration Tests - Devservice</name> | ||
| <properties> | ||
| <skipITs>true</skipITs> | ||
| </properties> | ||
| <dependencies> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-arc</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-resteasy-jackson</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-smallrye-openapi</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-smallrye-health</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-opentelemetry</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-micrometer-registry-prometheus</artifactId> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkiverse.temporal</groupId> | ||
| <artifactId>quarkus-temporal</artifactId> | ||
| <version>${project.version}</version> | ||
| </dependency> | ||
| <!-- <dependency> | ||
| <groupId>io.quarkiverse.temporal</groupId> | ||
| <artifactId>quarkus-temporal-test</artifactId> | ||
| <version>${project.version}</version> | ||
| <scope>test</scope> | ||
| </dependency> --> | ||
| <!-- <dependency> | ||
| <groupId>io.quarkiverse.temporal</groupId> | ||
| <artifactId>quarkus-temporal-test-deployment</artifactId> | ||
| <version>${project.version}</version> | ||
| </dependency> --> | ||
| <dependency> | ||
| <groupId>io.quarkiverse.temporal</groupId> | ||
| <artifactId>quarkus-temporal-deployment</artifactId> | ||
| <version>${project.version}</version> | ||
| <exclusions> | ||
| <exclusion> | ||
| <groupId>*</groupId> | ||
| <artifactId>*</artifactId> | ||
| </exclusion> | ||
| </exclusions> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-junit5</artifactId> | ||
| <scope>test</scope> | ||
| </dependency> | ||
| <dependency> | ||
| <groupId>io.rest-assured</groupId> | ||
| <artifactId>rest-assured</artifactId> | ||
| <scope>test</scope> | ||
| </dependency> | ||
| <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 --> | ||
| <dependency> | ||
| <groupId>org.apache.commons</groupId> | ||
| <artifactId>commons-lang3</artifactId> | ||
| <!-- <version>3.0</version> --> | ||
| </dependency> | ||
| </dependencies> | ||
| <build> | ||
| <plugins> | ||
| <plugin> | ||
| <groupId>io.quarkus</groupId> | ||
| <artifactId>quarkus-maven-plugin</artifactId> | ||
| <executions> | ||
| <execution> | ||
| <goals> | ||
| <goal>build</goal> | ||
| </goals> | ||
| </execution> | ||
| </executions> | ||
| </plugin> | ||
| <plugin> | ||
| <artifactId>maven-failsafe-plugin</artifactId> | ||
| <executions> | ||
| <execution> | ||
| <goals> | ||
| <goal>integration-test</goal> | ||
| <goal>verify</goal> | ||
| </goals> | ||
| </execution> | ||
| </executions> | ||
| <configuration> | ||
| <systemPropertyVariables> | ||
| <native.image.path>${project.build.directory}/${project.build.finalName}-runner</native.image.path> | ||
| <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager> | ||
| <maven.home>${maven.home}</maven.home> | ||
| </systemPropertyVariables> | ||
| </configuration> | ||
| </plugin> | ||
| </plugins> | ||
| </build> | ||
| <profiles> | ||
| <profile> | ||
| <id>native-image</id> | ||
| <activation> | ||
| <property> | ||
| <name>native</name> | ||
| </property> | ||
| </activation> | ||
| <build> | ||
| <plugins> | ||
| <plugin> | ||
| <artifactId>maven-surefire-plugin</artifactId> | ||
| <configuration> | ||
| <skipTests>${native.surefire.skip}</skipTests> | ||
| </configuration> | ||
| </plugin> | ||
| </plugins> | ||
| </build> | ||
| <properties> | ||
| <skipITs>false</skipITs> | ||
| <quarkus.native.enabled>true</quarkus.native.enabled> | ||
| </properties> | ||
| </profile> | ||
| </profiles> | ||
| </project> |
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
File renamed without changes.
Empty file.
File renamed without changes.
File renamed without changes.
Oops, something went wrong.