Bootstrap repo

creek-service · Mar 6, 2023 · 129bb2c · 129bb2c
1 parent 43e21d6
commit 129bb2c
Show file tree

Hide file tree

Showing 62 changed files with 74 additions and 1,046 deletions.
diff --git a/.creek/bootstrap.sh b/.creek/bootstrap.sh
diff --git a/.creek/service_template/example-service/Dockerfile b/.creek/service_template/example-service/Dockerfile
@@ -3,7 +3,7 @@ ARG APP_NAME
 ARG APP_VERSION
 ENV VERSION=$APP_VERSION
 
-LABEL org.opencontainers.image.source=https://github.com/creek-service/basic-kafka-streams-demo/tree/main/example-service
+LABEL org.opencontainers.image.source=https://github.com/creek-service/connected-services-demo/tree/main/example-service
 
 RUN yum update -y
 RUN yum install -y tar lsof

diff --git a/.creek/service_template/example-service/build.gradle.kts b/.creek/service_template/example-service/build.gradle.kts
@@ -40,8 +40,8 @@ dependencies {
 modularity.patchModule("kafka.streams", "kafka-streams-test-utils-$kafkaVersion.jar")
 
 application {
-    mainModule.set("basic.kafka.streams.demo.example.service")
-    mainClass.set("io.github.creek.service.basic.kafka.streams.demo.example.service.ServiceMain")
+    mainModule.set("connected.services.demo.example.service")
+    mainClass.set("io.github.creek.service.connected.services.demo.example.service.ServiceMain")
 }
 
 val buildAppImage = tasks.register<DockerBuildImage>("buildAppImage") {

diff --git a/.creek/service_template/example-service/include/bin/run.sh b/.creek/service_template/example-service/include/bin/run.sh
@@ -20,4 +20,4 @@ exec java \
  -Xms64m -Xmx256m \
  -Dlog4j.configurationFile=/log/log4j2.xml \
  --module-path "/opt/creek/service/lib" \
- --module basic.kafka.streams.demo.example.service/io.github.creek.service.basic.kafka.streams.demo.example.service.ServiceMain
+ --module connected.services.demo.example.service/io.github.creek.service.connected.services.demo.example.service.ServiceMain
diff --git a/...ams/demo/example/service/ServiceMain.java → ...ces/demo/example/service/ServiceMain.java b/...ams/demo/example/service/ServiceMain.java → ...ces/demo/example/service/ServiceMain.java
@@ -14,10 +14,10 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.example.service;
+package io.github.creek.service.connected.services.demo.example.service;
 
-import io.github.creek.service.basic.kafka.streams.demo.example.service.kafka.streams.TopologyBuilder;
-import io.github.creek.service.basic.kafka.streams.demo.services.ExampleServiceDescriptor;
+import io.github.creek.service.connected.services.demo.example.service.kafka.streams.TopologyBuilder;
+import io.github.creek.service.connected.services.demo.services.ExampleServiceDescriptor;
 import org.apache.kafka.streams.Topology;
 import org.creekservice.api.kafka.streams.extension.KafkaStreamsExtension;
 import org.creekservice.api.kafka.streams.extension.KafkaStreamsExtensionOptions;

diff --git a/...ervice/kafka/streams/TopologyBuilder.java → ...ervice/kafka/streams/TopologyBuilder.java b/...ervice/kafka/streams/TopologyBuilder.java → ...ervice/kafka/streams/TopologyBuilder.java
@@ -14,12 +14,12 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.example.service.kafka.streams;
+package io.github.creek.service.connected.services.demo.example.service.kafka.streams;
 
 import static java.util.Objects.requireNonNull;
 import static org.creekservice.api.kafka.metadata.KafkaTopicDescriptor.DEFAULT_CLUSTER_NAME;
 
-import io.github.creek.service.basic.kafka.streams.demo.services.ExampleServiceDescriptor;
+import io.github.creek.service.connected.services.demo.services.ExampleServiceDescriptor;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.StreamsBuilder;
 import org.apache.kafka.streams.Topology;

diff --git a/.creek/service_template/example-service/src/main/java/module-info.java b/.creek/service_template/example-service/src/main/java/module-info.java
@@ -1,5 +1,5 @@
-module basic.kafka.streams.demo.example.service {
-    requires basic.kafka.streams.demo.services;
+module connected.services.demo.example.service {
+    requires connected.services.demo.services;
     requires creek.service.context;
     requires creek.kafka.streams.extension;
     requires org.apache.logging.log4j;

diff --git a/.../example/streams/TopologyBuilderTest.java → .../example/streams/TopologyBuilderTest.java b/.../example/streams/TopologyBuilderTest.java → .../example/streams/TopologyBuilderTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.example.streams;
+package io.github.creek.service.connected.services.demo.example.streams;
 
 import static org.apache.kafka.streams.KeyValue.pair;
 import static org.creekservice.api.kafka.metadata.KafkaTopicDescriptor.DEFAULT_CLUSTER_NAME;
@@ -24,8 +24,8 @@
 import static org.hamcrest.Matchers.contains;
 import static org.hamcrest.Matchers.is;
 
-import io.github.creek.service.basic.kafka.streams.demo.example.service.kafka.streams.TopologyBuilder;
-import io.github.creek.service.basic.kafka.streams.demo.services.ExampleServiceDescriptor;
+import io.github.creek.service.connected.services.demo.example.service.kafka.streams.TopologyBuilder;
+import io.github.creek.service.connected.services.demo.services.ExampleServiceDescriptor;
 import org.apache.kafka.streams.TestInputTopic;
 import org.apache.kafka.streams.TestOutputTopic;
 import org.apache.kafka.streams.Topology;

diff --git a/.creek/service_template/example-service/src/test/java/module-info.test b/.creek/service_template/example-service/src/test/java/module-info.test
@@ -2,7 +2,7 @@
   org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest,creek.kafka.streams.test
 
 --add-reads
-  basic.kafka.streams.demo.example.service=org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest,creek.kafka.streams.test
+  connected.services.demo.example.service=org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest,creek.kafka.streams.test
 
 --add-opens
   org.junitpioneer/org.junitpioneer.jupiter=org.junit.platform.commons
diff --git a/.creek/service_template/root.package b/.creek/service_template/root.package
@@ -1 +1 @@
-io.github.creek.service.basic.kafka.streams.demo
+io.github.creek.service.connected.services.demo
diff --git a/...mo/services/ExampleServiceDescriptor.java → ...mo/services/ExampleServiceDescriptor.java b/...mo/services/ExampleServiceDescriptor.java → ...mo/services/ExampleServiceDescriptor.java
@@ -14,15 +14,15 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.services;
+package io.github.creek.service.connected.services.demo.services;
 
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.inputTopic;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.inputTopic;
 
 import java.util.ArrayList;
 import java.util.Collection;
 import java.util.List;
-import io.github.creek.service.basic.kafka.streams.demo.api.BasicKafkaStreamsDemoAggregateDescriptor;
-import io.github.creek.service.basic.kafka.streams.demo.internal.TopicConfigBuilder;
+import io.github.creek.service.connected.services.demo.api.ConnectedServicesDemoAggregateDescriptor;
+import io.github.creek.service.connected.services.demo.internal.TopicConfigBuilder;
 import org.creekservice.api.kafka.metadata.OwnedKafkaTopicInput;
 import org.creekservice.api.kafka.metadata.OwnedKafkaTopicOutput;
 import org.creekservice.api.platform.metadata.ComponentInput;
@@ -40,7 +40,7 @@ public ExampleServiceDescriptor() {}
 
     @Override
     public String dockerImage() {
-        return "ghcr.io/creek-service/basic-kafka-streams-demo-example-service";
+        return "ghcr.io/creek-service/connected-services-demo-example-service";
     }
 
     @Override

diff --git a/.github/CODEOWNERS b/.github/CODEOWNERS
diff --git a/README.md b/README.md
@@ -1,15 +1,15 @@
 [![License](https://img.shields.io/badge/License-Apache%202.0-blue.svg)](https://opensource.org/licenses/Apache-2.0)
-[![Coverage Status](https://coveralls.io/repos/github/creek-service/basic-kafka-streams-demo/badge.svg?branch=main)](https://coveralls.io/github/creek-service/basic-kafka-streams-demo?branch=main)
-[![build](https://github.com/creek-service/basic-kafka-streams-demo/actions/workflows/build.yml/badge.svg)](https://github.com/creek-service/basic-kafka-streams-demo/actions/workflows/build.yml)
-[![CodeQL](https://github.com/creek-service/basic-kafka-streams-demo/actions/workflows/codeql.yml/badge.svg)](https://github.com/creek-service/basic-kafka-streams-demo/actions/workflows/codeql.yml)
+[![Coverage Status](https://coveralls.io/repos/github/creek-service/connected-services-demo/badge.svg?branch=main)](https://coveralls.io/github/creek-service/connected-services-demo?branch=main)
+[![build](https://github.com/creek-service/connected-services-demo/actions/workflows/build.yml/badge.svg)](https://github.com/creek-service/connected-services-demo/actions/workflows/build.yml)
+[![CodeQL](https://github.com/creek-service/connected-services-demo/actions/workflows/codeql.yml/badge.svg)](https://github.com/creek-service/connected-services-demo/actions/workflows/codeql.yml)
 
 # Basic Kafka Streams Demo
 
-Repo containing the completed [Basic Kafka Streams demo](https://www.creekservice.org/basic-kafka-streams-demo)
+Repo containing the completed [Basic Kafka Streams demo](https://www.creekservice.org/connected-services-demo)
 and associated [docs](docs/README.md).
 
 This repository is also a template repository to enable later tutorials, that build on this one. 
-Click the [Use this template](https://github.com/creek-service/basic-kafka-streams-demo/generate) button at the top to create a new repository from this template.
+Click the [Use this template](https://github.com/creek-service/connected-services-demo/generate) button at the top to create a new repository from this template.
 
 ### Gradle commands
 

diff --git a/...cKafkaStreamsDemoAggregateDescriptor.java → ...ectedServicesDemoAggregateDescriptor.java b/...cKafkaStreamsDemoAggregateDescriptor.java → ...ectedServicesDemoAggregateDescriptor.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.api;
+package io.github.creek.service.connected.services.demo.api;
 
 import java.util.ArrayList;
 import java.util.Collection;
@@ -23,12 +23,12 @@
 import org.creekservice.api.platform.metadata.ComponentInput;
 import org.creekservice.api.platform.metadata.ComponentOutput;
 
-public final class BasicKafkaStreamsDemoAggregateDescriptor implements AggregateDescriptor {
+public final class ConnectedServicesDemoAggregateDescriptor implements AggregateDescriptor {
 
     private static final List<ComponentInput> INPUTS = new ArrayList<>();
     private static final List<ComponentOutput> OUTPUTS = new ArrayList<>();
 
-    public BasicKafkaStreamsDemoAggregateDescriptor() {}
+    public ConnectedServicesDemoAggregateDescriptor() {}
 
     @Override
     public Collection<ComponentInput> inputs() {

diff --git a/...ams/demo/internal/TopicConfigBuilder.java → ...ces/demo/internal/TopicConfigBuilder.java b/...ams/demo/internal/TopicConfigBuilder.java → ...ces/demo/internal/TopicConfigBuilder.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.internal;
+package io.github.creek.service.connected.services.demo.internal;
 
 import static java.util.Objects.requireNonNull;
 

diff --git a/...reams/demo/internal/TopicDescriptors.java → ...vices/demo/internal/TopicDescriptors.java b/...reams/demo/internal/TopicDescriptors.java → ...vices/demo/internal/TopicDescriptors.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.internal;
+package io.github.creek.service.connected.services.demo.internal;
 
 import static java.util.Objects.requireNonNull;
 import static org.creekservice.api.kafka.metadata.SerializationFormat.serializationFormat;

diff --git a/api/src/main/java/module-info.java b/api/src/main/java/module-info.java
@@ -1,8 +1,8 @@
-module basic.kafka.streams.demo.api {
+module connected.services.demo.api {
     requires transitive creek.kafka.metadata;
 
-    exports io.github.creek.service.basic.kafka.streams.demo.api;
-    exports io.github.creek.service.basic.kafka.streams.demo.internal to
-            basic.kafka.streams.demo.services,
-            basic.kafka.streams.demo.service;
+    exports io.github.creek.service.connected.services.demo.api;
+    exports io.github.creek.service.connected.services.demo.internal to
+            connected.services.demo.services,
+            connected.services.demo.service;
 }
diff --git a/...demo/internal/TopicConfigBuilderTest.java → ...demo/internal/TopicConfigBuilderTest.java b/...demo/internal/TopicConfigBuilderTest.java → ...demo/internal/TopicConfigBuilderTest.java
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.internal;
+package io.github.creek.service.connected.services.demo.internal;
 
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.hasEntry;

diff --git a/...s/demo/internal/TopicDescriptorsTest.java → ...s/demo/internal/TopicDescriptorsTest.java b/...s/demo/internal/TopicDescriptorsTest.java → ...s/demo/internal/TopicDescriptorsTest.java
@@ -14,13 +14,13 @@
  * limitations under the License.
  */
 
-package io.github.creek.service.basic.kafka.streams.demo.internal;
+package io.github.creek.service.connected.services.demo.internal;
 
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.KAFKA_FORMAT;
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.creatableInternalTopic;
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.inputTopic;
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.internalTopic;
-import static io.github.creek.service.basic.kafka.streams.demo.internal.TopicDescriptors.outputTopic;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.KAFKA_FORMAT;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.creatableInternalTopic;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.inputTopic;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.internalTopic;
+import static io.github.creek.service.connected.services.demo.internal.TopicDescriptors.outputTopic;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.is;
 import static org.hamcrest.Matchers.sameInstance;

diff --git a/api/src/test/java/module-info.test b/api/src/test/java/module-info.test
@@ -2,7 +2,7 @@
   org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest
 
 --add-reads
-  basic.kafka.streams.demo.api=org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest
+  connected.services.demo.api=org.junitpioneer,org.hamcrest,guava.testlib,creek.test.util,creek.test.hamcrest
 
 --add-opens
   org.junitpioneer/org.junitpioneer.jupiter=org.junit.platform.commons
diff --git a/docs/.gitignore b/docs/.gitignore
diff --git a/docs/Gemfile b/docs/Gemfile
Original file line number	Diff line number	Diff line change
		@@ -1 +1 @@
		io.github.creek.service.basic.kafka.streams.demo
		io.github.creek.service.connected.services.demo