Skip to content

DXP-2486 Add streamx run, stream and batch commands for StreamX 2.0 (and remove streamx publish/unpublish/cloud/dev/init commands for now) #219

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
stan-r-ds wants to merge 32 commits into
base: main
Choose a base branch
from
Open

DXP-2486 Add streamx run, stream and batch commands for StreamX 2.0 (and remove streamx publish/unpublish/cloud/dev/init commands for now) #219

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
32 commits
Select commit Hold shift + click to select a range
243064b
DXP-2486 Add streamx run, stream and batch commands for StreamX 2.0 (…
stan-r-ds Dec 29, 2025
eb63811
mockito
stan-r-ds Dec 29, 2025
288ccf8
java 21
stan-r-ds Dec 29, 2025
e8ac81a
add missing validation
stan-r-ds Dec 29, 2025
9761683
Remove Resource class
stan-r-ds Dec 29, 2025
46a6874
Restore banner
stan-r-ds Dec 29, 2025
74f6c6d
Remove unnecessary plugin
stan-r-ds Dec 29, 2025
cad43e5
Use cli source
stan-r-ds Dec 29, 2025
c8ca778
Increase test coverage
stan-r-ds Dec 29, 2025
9776c77
Use jvm
stan-r-ds Dec 29, 2025
dca7a18
Use temurin
stan-r-ds Dec 30, 2025
18fdda4
Move test file, add test for default values
stan-r-ds Dec 30, 2025
f08a25d
Better newline diff comparison
stan-r-ds Dec 30, 2025
16501c8
Use native
stan-r-ds Dec 30, 2025
dd8a24b
restore {}
stan-r-ds Dec 30, 2025
0b9fcd3
Improve handling of ByteBuffer fields
stan-r-ds Dec 31, 2025
2145fc8
CloudEventBuilder fixes
stan-r-ds Dec 31, 2025
403fd23
fixes
stan-r-ds Dec 31, 2025
d3f7eae
fix codestyle
stan-r-ds Dec 31, 2025
1f13cc6
Small fix
stan-r-ds Dec 31, 2025
811cab5
Use new streamx-service-mesh version
stan-r-ds Jan 5, 2026
6b6e62d
Don't use native
stan-r-ds Jan 5, 2026
ec213a6
Minor fixes
stan-r-ds Jan 5, 2026
c6eba11
add debug logging
stan-r-ds Jan 5, 2026
cd8b684
Remove repository volume
stan-r-ds Jan 5, 2026
976a3d6
Volumes cleanup
stan-r-ds Jan 5, 2026
0158222
Temporarily allow releasing preview on demand
stan-r-ds Jan 5, 2026
58337de
Temporarily embed releasing preview on demand into PR CI
stan-r-ds Jan 5, 2026
8e1100e
Make release preview to use specific branch
stan-r-ds Jan 5, 2026
3ba20b4
Restore recent changes regarding preview releasing
stan-r-ds Jan 5, 2026
ee83d91
Rename json.paths.to.encode.to.base64 to json.fields.as-base64
stan-r-ds Jan 12, 2026
a0b9cc6
Formatting agnostic verification
stan-r-ds Jan 14, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 7 additions & 6 deletions .github/workflows/ci-test-build.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,16 +26,17 @@ jobs:
workload_identity_provider: ${{ secrets.GCP_STREAMX_RELEASES_WORKLOAD_IDENTITY_PROVIDER }}
service_account: ${{ secrets.GCP_STREAMX_RELEASES_READ_SA }}

- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v3
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
Copy link
Contributor Author

@stan-r-ds stan-r-ds Dec 29, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The builds fail on java 17 when importing com.streamx ingestion client that's built with java 21

distribution: 'temurin'
cache: 'maven'

- name: Build project
run: |
./mvnw clean verify -P all-tests

windows-test-build:
runs-on: windows-latest
steps:
Expand All @@ -51,11 +52,11 @@ jobs:
workload_identity_provider: ${{ secrets.GCP_STREAMX_RELEASES_WORKLOAD_IDENTITY_PROVIDER }}
service_account: ${{ secrets.GCP_STREAMX_RELEASES_READ_SA }}

- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v3
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'
cache: 'maven'

- name: Build project
Expand Down
4 changes: 2 additions & 2 deletions .github/workflows/mvn-build-and-check-streamx-cli-commands-linux.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@ jobs:
- name: Set up JDK 17s
uses: actions/setup-java@v4
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'

- name: Set up homebrew
if: inputs.streamx_source == 'installed'
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/release-preview.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,11 +35,11 @@ jobs:
printf '%s\n' "${{ secrets.SSH_SECRET_KEY }}" > ~/.ssh/id_rsa
chmod 0600 ~/.ssh/id_rsa

- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v3
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'

- name: Preview release prepare
run: ./mvnw -B clean install -DskipTests -P preview
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/release.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,11 +31,11 @@ jobs:
printf '%s\n' "${{ secrets.SSH_SECRET_KEY }}" > ~/.ssh/id_rsa
chmod 0600 ~/.ssh/id_rsa

- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v3
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'

- name: Release prepare
id: prepare-release
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/streamx-homebrew-instalation-check.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,11 @@ jobs:
runs-on: ${{ matrix.os }}

steps:
- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v4
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'

- name: Set up homebrew
uses: 'Homebrew/actions/setup-homebrew@master'
Expand Down
6 changes: 3 additions & 3 deletions .github/workflows/streamx-scoop-instalation-check.yaml.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,11 @@ jobs:
runs-on: windows-latest

steps:
- name: Set up JDK 17
- name: Set up JDK 21
uses: actions/setup-java@v4
with:
java-version: '17'
distribution: 'adopt'
java-version: '21'
distribution: 'temurin'

- name: Set up Scoop
uses: MinoruSekine/setup-scoop@v4
Expand Down
10 changes: 3 additions & 7 deletions core/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@

<name>StreamX Cli : Core</name>
<properties>
<maven.compiler.release>17</maven.compiler.release>
<maven.compiler.release>21</maven.compiler.release>

<skipITs>true</skipITs>
<quarkus.package.type>uber-jar</quarkus.package.type>
Expand Down Expand Up @@ -44,13 +44,9 @@
<artifactId>bcpkix-jdk18on</artifactId>
</dependency>
<dependency>
<groupId>dev.streamx</groupId>
<groupId>com.streamx</groupId>
<artifactId>streamx-runner</artifactId>
</dependency>
<dependency>
<groupId>dev.streamx</groupId>
<artifactId>streamx-operator-mesh-api</artifactId>
</dependency>
Copy link
Contributor Author

@stan-r-ds stan-r-ds Dec 29, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

To be restored / added when the cloud-related CLI operations are refined

<dependency>
<groupId>com.fasterxml.jackson.datatype</groupId>
<artifactId>jackson-datatype-jdk8</artifactId>
Expand All @@ -60,7 +56,7 @@
<artifactId>jackson-datatype-jsr310</artifactId>
</dependency>
<dependency>
<groupId>dev.streamx</groupId>
<groupId>com.streamx</groupId>
<artifactId>ingestion-client</artifactId>
</dependency>
<dependency>
Expand Down
3 changes: 1 addition & 2 deletions core/src/main/java/dev/streamx/cli/BannerPrinter.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@

import static dev.streamx.cli.util.Output.print;

import dev.streamx.cli.command.dev.DevCommand;
import dev.streamx.cli.command.run.RunCommand;
import jakarta.enterprise.context.ApplicationScoped;
import java.util.Set;
Expand All @@ -13,7 +12,7 @@
public class BannerPrinter {

private static final Set<String> COMMANDS_REQUIRING_PRINTING_BANNER =
Set.of(DevCommand.COMMAND_NAME, RunCommand.COMMAND_NAME);
Set.of(RunCommand.COMMAND_NAME);
Copy link
Contributor Author

@stan-r-ds stan-r-ds Dec 31, 2025 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The not migrated (so - removed) commands are

  • dev
  • cloud (deploy/undeploy)
  • init
  • publish
  • unpublish


private static final String BANNER = """
____ _ __ __
Expand Down
96 changes: 0 additions & 96 deletions core/src/main/java/dev/streamx/cli/SchemaProvider.java
View file
Open in desktop

This file was deleted.

13 changes: 2 additions & 11 deletions core/src/main/java/dev/streamx/cli/StreamxCommand.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,13 +1,7 @@
package dev.streamx.cli;

import dev.streamx.cli.command.cloud.deploy.DeployCommand;
import dev.streamx.cli.command.cloud.undeploy.UndeployCommand;
import dev.streamx.cli.command.dev.DevCommand;
import dev.streamx.cli.command.ingestion.batch.BatchCommand;
import dev.streamx.cli.command.ingestion.publish.PublishCommand;
import dev.streamx.cli.command.ingestion.stream.StreamCommand;
import dev.streamx.cli.command.ingestion.unpublish.UnpublishCommand;
import dev.streamx.cli.command.init.InitCommand;
import dev.streamx.cli.command.run.RunCommand;
import dev.streamx.cli.config.ArgumentConfigSource;
import dev.streamx.cli.config.validation.ConfigSourcesValidator;
Expand All @@ -30,11 +24,8 @@
@Command(mixinStandardHelpOptions = true,
name = "streamx",
subcommands = {
InitCommand.class,
RunCommand.class, DevCommand.class,
PublishCommand.class, UnpublishCommand.class,
RunCommand.class,
BatchCommand.class, StreamCommand.class,
DeployCommand.class, UndeployCommand.class,
HelpCommand.class
},
versionProvider = VersionProvider.class)
Expand Down Expand Up @@ -82,7 +73,7 @@ private static void initializeArgumentConfigSource(String[] args) {
}

@Override
public int run(String... args) throws Exception {
public int run(String... args) {
this.args = args;

commandLine = new CommandLine(this, factory)
Expand Down
30 changes: 0 additions & 30 deletions core/src/main/java/dev/streamx/cli/command/cloud/KubernetesArguments.java
View file
Open in desktop

This file was deleted.

24 changes: 0 additions & 24 deletions core/src/main/java/dev/streamx/cli/command/cloud/KubernetesConfig.java
View file
Open in desktop

This file was deleted.

Loading