Prepare for 1.0.9 release (#168)

CHANGELOG.md

@@ -16,6 +16,13 @@
 
 # KAR: A Runtime for the Hybrid Cloud
 
+# KAR 1.0.9 - 2021-09-10
++ Implement a Reactive Java SDK using Quarkus
++ Add a retry loop around failed redis connection attempts (#163)
++ Also allow controlling sidecar ports via envvar (#153)
++ Move from alpine 3.11 to 3.14 for sidecar/webhook images (#151)
++ Fixup kafka-bench and re-enable building it. (#150)
+
 # KAR 1.0.8 - 2021-08-13
 + Upgrade to zookeeper 3.6 and kafka 2.7 (#146)
 + Upgrade to use Redis 6 (#145)

docs/dev/release-procedures.md

@@ -83,7 +83,9 @@ npm notice total files:   5
 
 3. Commit changes to release-prep.
 
-4. PR the release-prep branch. Travis should pass. Merge PR.
+### PR & Merge the release-prep branch
+
+1. PR the release-prep branch. Travis should pass. Merge PR.
 
 ### Tag repository
 

examples/actors-dp-java-reactive/pom.xml

@@ -8,7 +8,7 @@
   <packaging>jar</packaging>
 
   <properties>
-    <version.kar-java-sdk>1.0.9-SNAPSHOT</version.kar-java-sdk>
+    <version.kar-java-sdk>1.0.9</version.kar-java-sdk>
     <version.java-compiler>11</version.java-compiler>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

examples/actors-dp-java/pom.xml

@@ -8,7 +8,7 @@
   <packaging>war</packaging>
 
   <properties>
-    <version.kar-java-sdk>1.0.8</version.kar-java-sdk>
+    <version.kar-java-sdk>1.0.9</version.kar-java-sdk>
     <version.java-compiler>11</version.java-compiler>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

examples/actors-dp-js/package.json

@@ -6,7 +6,7 @@
   },
   "dependencies": {
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8",
+    "kar-sdk": "^1.0.9",
     "uuid": "^8.3.0"
   },
   "devDependencies": {

examples/actors-events/package.json

@@ -7,7 +7,7 @@
   "dependencies": {
     "cloudevents": "^4.0.0",
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8"
+    "kar-sdk": "^1.0.9"
   },
   "devDependencies": {
     "mocha": "^7.1.1",

examples/actors-ykt/package.json

@@ -7,7 +7,7 @@
   "dependencies": {
     "cloudevents": "^4.0.0",
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8"
+    "kar-sdk": "^1.0.9"
   },
   "devDependencies": {
     "mocha": "^7.1.1",

examples/camel-k/package.json

@@ -7,7 +7,7 @@
   "dependencies": {
     "cloudevents": "^4.0.0",
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8"
+    "kar-sdk": "^1.0.9"
   },
   "devDependencies": {
     "mocha": "^7.1.1",

examples/misc/actor-timeout-java/pom.xml

@@ -8,7 +8,7 @@
   <packaging>war</packaging>
 
   <properties>
-    <version.kar-java-sdk>1.0.8</version.kar-java-sdk>
+    <version.kar-java-sdk>1.0.9</version.kar-java-sdk>
     <version.java-compiler>11</version.java-compiler>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>

examples/misc/actor-timeout-js/package.json

@@ -6,7 +6,7 @@
   },
   "dependencies": {
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8"
+    "kar-sdk": "^1.0.9"
   },
   "devDependencies": {
     "mocha": "^7.1.1",

examples/misc/fault-tolerance/package.json

@@ -6,7 +6,7 @@
   },
   "dependencies": {
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8",
+    "kar-sdk": "^1.0.9",
     "node-fetch": "^2.6.0"
   },
   "devDependencies": {

examples/misc/service-timeout-java/pom.xml

@@ -18,7 +18,7 @@
   </modules>
 
   <properties>
-    <version.kar-java-sdk>1.0.8</version.kar-java-sdk>
+    <version.kar-java-sdk>1.0.9</version.kar-java-sdk>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <failOnMissingWebXml>false</failOnMissingWebXml>

examples/service-hello-js/package.json

@@ -7,7 +7,7 @@
   "dependencies": {
     "express": "^4.17.1",
     "fetch-retry": "^3.1.0",
-    "kar-sdk": "^1.0.8",
+    "kar-sdk": "^1.0.9",
     "node-fetch": "^2.6.0"
   },
   "devDependencies": {

examples/unit-tests/package.json

@@ -8,7 +8,7 @@
     "axios": "^0.21.1",
     "cloudevents": "^4.0.0",
     "express": "^4.17.1",
-    "kar-sdk": "^1.0.8"
+    "kar-sdk": "^1.0.9"
   },
   "devDependencies": {
     "mocha": "^7.1.1",

scripts/helm/kar/Chart.yaml

@@ -18,8 +18,8 @@ apiVersion: v2
 name: kar
 description: Kubernetes Application Runtime (KAR)
 type: application
-version: 1.0.8
-appVersion: 1.0.8
+version: 1.0.9
+appVersion: 1.0.9
 dependencies:
 - name: kar-kafka
   condition: kafka.internal

scripts/helm/kar/values.yaml

@@ -33,7 +33,7 @@ redis:
     user: 'mustOverrideIfInternalIsFalse'
 
 kar:
-  version: 1.0.8
+  version: 1.0.9
   injector:
     replicaCount: 1
     imageName: 'quay.io/ibm/kar-injector'

sdk-java/kar-runtime-core/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>com.ibm.research.kar</groupId>
     <artifactId>kar-java</artifactId>
-    <version>1.0.9-SNAPSHOT</version>
+    <version>1.0.9</version>
   </parent>
 
   <artifactId>kar-runtime-core</artifactId>

sdk-java/kar-runtime-liberty/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>com.ibm.research.kar</groupId>
     <artifactId>kar-java</artifactId>
-    <version>1.0.9-SNAPSHOT</version>
+    <version>1.0.9</version>
   </parent>
 
   <artifactId>kar-runtime-liberty</artifactId>

sdk-java/kar-runtime-quarkus/pom.xml

@@ -6,7 +6,7 @@
   <parent>
     <groupId>com.ibm.research.kar</groupId>
     <artifactId>kar-java</artifactId>
-    <version>1.0.9-SNAPSHOT</version>
+    <version>1.0.9</version>
   </parent>
 
   <artifactId>kar-runtime-quarkus</artifactId>

sdk-java/kar-runtime-quarkus/src/main/java/com/ibm/research/kar/Kar.java

@@ -289,6 +289,7 @@ public static Uni<HttpResponse<Buffer>> put(String service, String path, JsonVal
 		 * @param service The name of the service to invoke.
 		 * @param path    The service endpoint to invoke.
 		 * @param body    The request body with which to invoke the service endpoint.
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> tell(String service, String path, JsonValue body) {
 			return sidecar.tellPost(service, path, body).chain(resp -> {
@@ -333,6 +334,7 @@ public static ActorRef ref(String type, String id) {
 		 * Asynchronously remove all user-level and runtime state of an Actor.
 		 *
 		 * @param actor The Actor instance.
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> remove(ActorRef actor) {
 			return sidecar.actorDelete(actor.getType(), actor.getId()).chain(resp -> {
@@ -348,6 +350,7 @@ public static Uni<Void> remove(ActorRef actor) {
 		 * @param actor The target actor.
 		 * @param path  The actor method to invoke.
 		 * @param args  The arguments with which to invoke the actor method.
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> tell(ActorRef actor, String path, JsonValue... args) {
 			return sidecar.actorTell(actor.getType(), actor.getId(), path, packArgs(args))
@@ -512,6 +515,7 @@ public static Uni<Reminder[]> get(ActorRef actor, String reminderId) {
 			 * @param period     For periodic reminders, a String that is compatible with
 			 *                   GoLang's Duration
 			 * @param args       The arguments with which to invoke the actor method.
+			 * @return A Uni representing the continuation.
 			 */
 			public static Uni<Void> schedule(ActorRef actor, String path, String reminderId, Instant targetTime,
 					Duration period, JsonValue... args) {
@@ -630,6 +634,7 @@ public static Uni<Integer> set(ActorRef actor, String key, JsonValue value) {
 			 * @param actor The Actor instance.
 			 * @param key   The key to use to access the instance's state
 			 * @param value The value to store
+			 * @return A Uni representing the continuation
 			 */
 			public static Uni<Void> setV(ActorRef actor, String key, JsonValue value) {
 				return sidecar.actorSetState(actor.getType(), actor.getId(), key, value).chain(resp -> {
@@ -658,6 +663,7 @@ public static Uni<Integer> set(ActorRef actor, Map<String, JsonValue> updates) {
 			 *
 			 * @param actor   The Actor instance.
 			 * @param updates A map containing the state updates to perform
+			 * @return A Uni representing the continuation.
 			 */
 			public static Uni<Void> setV(ActorRef actor, Map<String, JsonValue> updates) {
 				if (updates.isEmpty()) {
@@ -865,6 +871,7 @@ public static Uni<Integer> set(ActorRef actor, String submap, String key, JsonVa
 				 * @param submap The name of the submap to update
 				 * @param key    The key in the submap to update
 				 * @param value  The value to store at `key/subkey`
+				 * @return A Uni representing the continuation.
 				 */
 				public static Uni<Void> setV(ActorRef actor, String submap, String key, JsonValue value) {
 					return sidecar.actorSetWithSubkeyState(actor.getType(), actor.getId(), submap, key, value).chain(resp -> {
@@ -1076,9 +1083,10 @@ public static Uni<Subscription[]> getSubscription(ActorRef actor, String subscri
 		 * @param actor The Actor instance to subscribe
 		 * @param path  The actor method to invoke on each event received on the topic
 		 * @param topic The topic to which to subscribe
+		 * @return A Uni representing the continuation.
 		 */
-		public static void subscribe(ActorRef actor, String path, String topic) {
-			subscribe(actor, path, topic, topic);
+		public static Uni<Void> subscribe(ActorRef actor, String path, String topic) {
+			return subscribe(actor, path, topic, topic);
 		}
 
 		/**
@@ -1089,6 +1097,7 @@ public static void subscribe(ActorRef actor, String path, String topic) {
 		 *                       the topic
 		 * @param topic          The topic to which to subscribe
 		 * @param subscriptionId The subscriptionId to use for this subscription
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> subscribe(ActorRef actor, String path, String topic, String subscriptionId) {
 			JsonObjectBuilder builder = factory.createObjectBuilder();
@@ -1105,6 +1114,7 @@ public static Uni<Void> subscribe(ActorRef actor, String path, String topic, Str
 		 * Create a topic using the default Kafka configuration options.
 		 *
 		 * @param topic The name of the topic to create
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> createTopic(String topic) {
 			return sidecar.eventCreateTopic(topic, JsonValue.EMPTY_JSON_OBJECT).chain(resp -> {
@@ -1117,6 +1127,7 @@ public static Uni<Void> createTopic(String topic) {
 		 * Delete a topic.
 		 *
 		 * @param topic the name of the topic to delete
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> deleteTopic(String topic) {
 			return sidecar.eventDeleteTopic(topic).chain(resp -> {
@@ -1130,6 +1141,7 @@ public static Uni<Void> deleteTopic(String topic) {
 		 *
 		 * @param topic the name of the topic on which to publish
 		 * @param event the event to publish
+		 * @return A Uni representing the continuation.
 		 */
 		public static Uni<Void> publish(String topic, JsonValue event) {
 			return sidecar.eventPublish(topic, event).chain(resp -> {