Merge branch 'master' into bulk-subscriber-grpc

dapr · Jan 17, 2024 · 0e4f50c · 0e4f50c
2 parents d080a40 + 7eb24ff
commit 0e4f50c
Show file tree

Hide file tree

Showing 41 changed files with 2,510 additions and 308 deletions.
diff --git a/.github/workflows/automerge-bot.yml b/.github/workflows/automerge-bot.yml
@@ -22,7 +22,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout repo
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
       - name: Install dependencies
         run: pip install PyGithub
       - name: Automerge and update

diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -21,22 +21,19 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [ 11, 13, 15, 16 ]
-        spring-boot-version: [ 2.7.8 ]
+        java: [ 17 ]
+        spring-boot-version: [ 3.0.13 ]
         experimental: [ false ]
         include:
-          - java: 11
+          - java: 17
+            spring-boot-version: 2.7.8
+            experimental: false
+          - java: 17
             spring-boot-version: 2.6.14
             experimental: false
-          - java: 11
+          - java: 17
             spring-boot-version: 2.5.7
             experimental: false
-          - java: 11
-            spring-boot-version: 2.4.0
-            experimental: false
-          - java: 11
-            spring-boot-version: 2.3.6.RELEASE
-            experimental: false
     env:
       GOVER: "1.20"
       GOOS: linux
@@ -50,28 +47,28 @@ jobs:
       DAPR_REF:
       TOXIPROXY_URL: https://github.com/Shopify/toxiproxy/releases/download/v2.5.0/toxiproxy-server-linux-amd64
     steps:
-    - uses: actions/checkout@v3
+    - uses: actions/checkout@v4
     - name: Set up OpenJDK ${{ env.JDK_VER }}
-      uses: actions/setup-java@v3
+      uses: actions/setup-java@v4
       with:
         distribution: 'adopt'
         java-version: ${{ env.JDK_VER }}
     - name: Set up Dapr CLI
       run: wget -q ${{ env.DAPR_INSTALL_URL }} -O - | /bin/bash -s ${{ env.DAPR_CLI_VER }}
     - name: Set up Go ${{ env.GOVER }}
       if: env.DAPR_REF != '' || env.DAPR_CLI_REF != ''
-      uses: actions/setup-go@v4
+      uses: actions/setup-go@v5
       with:
         go-version: ${{ env.GOVER }}
     - name: Checkout Dapr CLI repo to override dapr command.
-      uses: actions/checkout@v3
+      uses: actions/checkout@v4
       if: env.DAPR_CLI_REF != ''
       with:
         repository: dapr/cli
         ref: ${{ env.DAPR_CLI_REF }}
         path: cli
     - name: Checkout Dapr repo to override daprd.
-      uses: actions/checkout@v3
+      uses: actions/checkout@v4
       if: env.DAPR_REF != ''
       with:
         repository: dapr/dapr
@@ -152,15 +149,15 @@ jobs:
     runs-on: ubuntu-latest
     needs: build
     env:
-      JDK_VER: 11
+      JDK_VER: 17
       OSSRH_USER_TOKEN: ${{ secrets.OSSRH_USER_TOKEN }}
       OSSRH_PWD_TOKEN: ${{ secrets.OSSRH_PWD_TOKEN }}
       GPG_KEY: ${{ secrets.GPG_KEY }}
       GPG_PWD: ${{ secrets.GPG_PWD }}
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
       - name: Set up OpenJDK ${{ env.JDK_VER }}
-        uses: actions/setup-java@v3
+        uses: actions/setup-java@v4
         with:
           distribution: 'adopt'
           java-version: ${{ env.JDK_VER }}
@@ -178,7 +175,7 @@ jobs:
           echo "DEPLOY_OSSRH=true" >> $GITHUB_ENV
       - name: Install jars
         if: env.DEPLOY_OSSRH == 'true'
-        run: ./mvnw clean install -B -q
+        run: ./mvnw install -B -q
       - name: Publish to ossrh
         if: env.DEPLOY_OSSRH == 'true'
         run: |

diff --git a/.github/workflows/dapr_bot.yml b/.github/workflows/dapr_bot.yml
@@ -9,7 +9,7 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Comment analyzer
-        uses: actions/github-script@v6
+        uses: actions/github-script@v7
         with:
           github-token: ${{secrets.DAPR_BOT_TOKEN}}
           script: |

diff --git a/.github/workflows/fossa.yml b/.github/workflows/fossa.yml
@@ -32,7 +32,7 @@ jobs:
       FOSSA_API_KEY: b88e1f4287c3108c8751bf106fb46db6 # This is a push-only token that is safe to be exposed.
     steps:
       - name: "Checkout code"
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
 
       - name: "Run FOSSA Scan"
         uses: fossas/fossa-action@v1.3.1 # Use a specific version if locking is preferred

diff --git a/.github/workflows/validate.yml b/.github/workflows/validate.yml
@@ -30,7 +30,7 @@ jobs:
     strategy:
       fail-fast: false # Keep running if one leg fails.
       matrix:
-        java: [ 11, 13, 15, 16 ]
+        java: [ 17 ]
     env:
       GOVER: "1.20"
       GOOS: linux
@@ -43,28 +43,28 @@ jobs:
       DAPR_CLI_REF:
       DAPR_REF:
     steps:
-      - uses: actions/checkout@v3
+      - uses: actions/checkout@v4
       - name: Set up OpenJDK ${{ env.JDK_VER }}
-        uses: actions/setup-java@v3
+        uses: actions/setup-java@v4
         with:
           distribution: 'adopt'
           java-version: ${{ env.JDK_VER }}
       - name: Set up Dapr CLI
         run: wget -q ${{ env.DAPR_INSTALL_URL }} -O - | /bin/bash -s ${{ env.DAPR_CLI_VER }}
       - name: Set up Go ${{ env.GOVER }}
         if: env.DAPR_REF != '' || env.DAPR_CLI_REF != ''
-        uses: actions/setup-go@v4
+        uses: actions/setup-go@v5
         with:
           go-version: ${{ env.GOVER }}
       - name: Checkout Dapr CLI repo to override dapr command.
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
         if: env.DAPR_CLI_REF != ''
         with:
           repository: dapr/cli
           ref: ${{ env.DAPR_CLI_REF }}
           path: cli
       - name: Checkout Dapr repo to override daprd.
-        uses: actions/checkout@v3
+        uses: actions/checkout@v4
         if: env.DAPR_REF != ''
         with:
           repository: dapr/dapr

diff --git a/daprdocs/content/en/java-sdk-docs/_index.md b/daprdocs/content/en/java-sdk-docs/_index.md
@@ -11,6 +11,8 @@ cascade:
   github_branch: master
 ---
 
+Dapr offers a variety of packages to help with the development of Java applications. Using them you can create Java clients, servers, and virtual actors with Dapr.
+
 ## Prerequisites
 
 - [Dapr CLI]({{< ref install-dapr-cli.md >}}) installed
@@ -123,173 +125,21 @@ try (DaprClient client = (new DaprClientBuilder()).build()) {
 - For a full guide on output bindings visit [How-To: Output bindings]({{< ref howto-bindings.md >}}).
 - Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/bindings/http) for code samples and instructions to try out output bindings.
 
-### Interact with input bindings
-
-```java
-import org.springframework.web.bind.annotation.*;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@RestController
-@RequestMapping("/")
-public class myClass {
-    private static final Logger log = LoggerFactory.getLogger(myClass);
-        @PostMapping(path = "/checkout")
-        public Mono<String> getCheckout(@RequestBody(required = false) byte[] body) {
-            return Mono.fromRunnable(() ->
-                    log.info("Received Message: " + new String(body)));
-        }
-}
-```
-
-- For a full guide on input bindings, visit [How-To: Input bindings]({{< ref howto-triggers >}}).
-- Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/bindings/http) for code samples and instructions to try out input bindings.
-
-### Retrieve secrets
-
-```java
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.dapr.client.DaprClient;
-import io.dapr.client.DaprClientBuilder;
-import java.util.Map;
-
-try (DaprClient client = (new DaprClientBuilder()).build()) {
-  Map<String, String> secret = client.getSecret(SECRET_STORE_NAME, secretKey).block();
-  System.out.println(JSON_SERIALIZER.writeValueAsString(secret));
-}
-```
-
-- For a full guide on secrets visit [How-To: Retrieve secrets]({{< ref howto-secrets.md >}}).
-- Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/secrets) for code samples and instructions to try out retrieving secrets
-
-### Actors
-An actor is an isolated, independent unit of compute and state with single-threaded execution. Dapr provides an actor implementation based on the [Virtual Actor pattern](https://www.microsoft.com/en-us/research/project/orleans-virtual-actors/), which provides a single-threaded programming model and where actors are garbage collected when not in use. With Dapr's implementaiton, you write your Dapr actors according to the Actor model, and Dapr leverages the scalability and reliability that the underlying platform provides. 
-
-```java
-import io.dapr.actors.ActorMethod;
-import io.dapr.actors.ActorType;
-import reactor.core.publisher.Mono;
-
-@ActorType(name = "DemoActor")
-public interface DemoActor {
-
-  void registerReminder();
-
-  @ActorMethod(name = "echo_message")
-  String say(String something);
-
-  void clock(String message);
-
-  @ActorMethod(returns = Integer.class)
-  Mono<Integer> incrementAndGet(int delta);
-}
-```
-
-- For a full guide on actors visit [How-To: Use virtual actors in Dapr]({{< ref howto-actors.md >}}).
-- Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/actors) for code samples and instructions to try actors
-
-### Get & Subscribe to application configurations
-
-> Note this is a preview API and thus will only be accessible via the DaprPreviewClient interface and not the normal DaprClient interface
-
-```java
-import io.dapr.client.DaprClient;
-import io.dapr.client.DaprClientBuilder;
-import io.dapr.client.domain.ConfigurationItem;
-import io.dapr.client.domain.GetConfigurationRequest;
-import io.dapr.client.domain.SubscribeConfigurationRequest;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
-try (DaprClient client = (new DaprClientBuilder()).build()) {
-  // Get configuration for a single key
-  Mono<ConfigurationItem> item = client.getConfiguration(CONFIG_STORE_NAME, CONFIG_KEY).block();
-
-  // Get configurations for multiple keys
-  Mono<Map<String, ConfigurationItem>> items =
-          client.getConfiguration(CONFIG_STORE_NAME, CONFIG_KEY_1, CONFIG_KEY_2);
-
-  // Subscribe to configuration changes
-  Flux<SubscribeConfigurationResponse> outFlux = client.subscribeConfiguration(CONFIG_STORE_NAME, CONFIG_KEY_1, CONFIG_KEY_2);
-  outFlux.subscribe(configItems -> configItems.forEach(...));
-
-  // Unsubscribe from configuration changes
-  Mono<UnsubscribeConfigurationResponse> unsubscribe = client.unsubscribeConfiguration(SUBSCRIPTION_ID, CONFIG_STORE_NAME)
-}
-```
-
-- For a full list of configuration operations visit [How-To: Manage configuration from a store]({{< ref howto-manage-configuration.md >}}).
-- Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/configuration) for code samples and instructions to try out different configuration operations.
-
-### Query saved state
-
-> Note this is a preview API and thus will only be accessible via the DaprPreviewClient interface and not the normal DaprClient interface
-
-```java
-import io.dapr.client.DaprClient;
-import io.dapr.client.DaprClientBuilder;
-import io.dapr.client.DaprPreviewClient;
-import io.dapr.client.domain.QueryStateItem;
-import io.dapr.client.domain.QueryStateRequest;
-import io.dapr.client.domain.QueryStateResponse;
-import io.dapr.client.domain.query.Query;
-import io.dapr.client.domain.query.Sorting;
-import io.dapr.client.domain.query.filters.EqFilter;
-
-try (DaprClient client = builder.build(); DaprPreviewClient previewClient = builder.buildPreviewClient()) {
-        String searchVal = args.length == 0 ? "searchValue" : args[0];
-
-        // Create JSON data
-        Listing first = new Listing();
-        first.setPropertyType("apartment");
-        first.setId("1000");
-        ...
-        Listing second = new Listing();
-        second.setPropertyType("row-house");
-        second.setId("1002");
-        ...
-        Listing third = new Listing();
-        third.setPropertyType("apartment");
-        third.setId("1003");
-        ...
-        Listing fourth = new Listing();
-        fourth.setPropertyType("apartment");
-        fourth.setId("1001");
-        ...
-        Map<String, String> meta = new HashMap<>();
-        meta.put("contentType", "application/json");
-
-        // Save state
-        SaveStateRequest request = new SaveStateRequest(STATE_STORE_NAME).setStates(
-          new State<>("1", first, null, meta, null),
-          new State<>("2", second, null, meta, null),
-          new State<>("3", third, null, meta, null),
-          new State<>("4", fourth, null, meta, null)
-        );
-        client.saveBulkState(request).block();
-
-
-        // Create query and query state request
-
-        Query query = new Query()
-          .setFilter(new EqFilter<>("propertyType", "apartment"))
-          .setSort(Arrays.asList(new Sorting("id", Sorting.Order.DESC)));
-        QueryStateRequest request = new QueryStateRequest(STATE_STORE_NAME)
-          .setQuery(query);
-
-        // Use preview client to call query state API
-        QueryStateResponse<MyData> result = previewClient.queryState(request, MyData.class).block();
-
-        // View Query state response 
-        System.out.println("Found " + result.getResults().size() + " items.");
-        for (QueryStateItem<Listing> item : result.getResults()) {
-          System.out.println("Key: " + item.getKey());
-          System.out.println("Data: " + item.getValue());
-        }
-}
-
-```
-- For a full list of configuration operations visit [How-To: Query state]({{< ref howto-state-query-api.md >}}).
-- Visit [Java SDK examples](https://github.com/dapr/java-sdk/tree/master/examples/src/main/java/io/dapr/examples/querystate) for complete code sample.
-
-Learn more about the [Dapr Java SDK packages available to add to your Java applications](https://dapr.github.io/java-sdk/).
+## Available packages
+
+<div class="card-deck">
+  <div class="card">
+    <div class="card-body">
+      <h5 class="card-title"><b>Client</b></h5>
+      <p class="card-text">Create Java clients that interact with a Dapr sidecar and other Dapr applications.</p>
+      <a href="{{< ref java-client >}}" class="stretched-link"></a>
+    </div>
+  </div>
+  <div class="card">
+    <div class="card-body">
+      <h5 class="card-title"><b>Workflow</b></h5>
+      <p class="card-text">Create and manage workflows that work with other Dapr APIs in Java.</p>
+      <a href="{{< ref workflow >}}" class="stretched-link"></a>
+    </div>
+  </div>
+</div>