FS2 Kinesis Producers (#55)

etspaceman · Feb 22, 2023 · a3648db · a3648db
1 parent 2dccda5
commit a3648db
Show file tree

Hide file tree

Showing 31 changed files with 1,538 additions and 55 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -66,6 +66,11 @@ jobs:
             ~/Library/Caches/Coursier/v1
           key: ${{ runner.os }}-sbt-cache-v2-${{ hashFiles('**/*.sbt') }}-${{ hashFiles('project/build.properties') }}
 
+      - name: Setup protoc
+        uses: arduino/setup-protoc@v1
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Check that workflows are up to date
         run: sbt githubWorkflowCheck
 
@@ -87,11 +92,11 @@ jobs:
 
       - name: Make target directories
         if: github.event_name != 'pull_request' && (startsWith(github.ref, 'refs/tags/v') || github.ref == 'refs/heads/main')
-        run: mkdir -p smithy4s-client-tests/target/jvm-2.13 shared-ciris/target/jvm-3 smithy4s-client-producer-tests/target/jvm-2.13 aws-v1-localstack/target/jvm-2.12 kpl/target/jvm-3 target shared/target/jvm-2.13 kpl/target/jvm-2.12 kcl-ciris/target/jvm-3 kpl-ciris/target/jvm-2.13 kinesis-client-tests/target/jvm-2.12 kpl-ciris/target/jvm-2.12 smithy4s-client-localstack/target/jvm-3 smithy4s-client/target/jvm-3 unidocs/target/jvm-2.13 kernel-tests/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-2.13 kcl-logging-circe/target/jvm-3 .js/target kcl-fs2-ciris/target/jvm-2.12 kinesis-client-logging-circe/target/jvm-3 aws-v1-localstack/target/jvm-3 kcl-tests/target/jvm-2.12 site/target/jvm-2.13 kinesis-client-localstack/target/jvm-3 shared/target/jvm-3 kpl-tests/target/jvm-2.13 kcl-localstack/target/jvm-2.13 kcl-fs2-ciris/target/jvm-3 kcl/target/jvm-3 kcl/target/jvm-2.12 unidocs/target/jvm-2.12 smithy4s-client-transformers/target/jvm-2.12 kpl-tests/target/jvm-3 shared-ciris/target/jvm-2.12 shared-localstack/target/jvm-2.12 kpl-tests/target/jvm-2.12 kcl-localstack/target/jvm-2.12 kpl/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-3 shared-circe/target/jvm-2.12 shared-tests/target/jvm-3 kcl-logging-circe/target/jvm-2.13 kinesis-client-tests/target/jvm-3 kcl-tests/target/jvm-2.13 kcl-ciris/target/jvm-2.13 kinesis-client-logging-circe/target/jvm-2.13 unidocs/target/jvm-3 smithy4s-client-producer-tests/target/jvm-3 compat/target/jvm-3 kinesis-client-logging-circe/target/jvm-2.12 shared-circe/target/jvm-2.13 kinesis-client/target/jvm-2.12 kpl-logging-circe/target/jvm-2.13 kcl-tests/target/jvm-3 aws-v2-localstack/target/jvm-3 kernel-tests/target/jvm-2.13 kcl-http4s/target/jvm-2.12 aws-v2-localstack/target/jvm-2.12 kcl-logging-circe/target/jvm-2.12 kinesis-client/target/jvm-2.13 .jvm/target kcl/target/jvm-2.13 kpl-localstack/target/jvm-3 kpl-localstack/target/jvm-2.13 kcl-ciris/target/jvm-2.12 .native/target kinesis-client-tests/target/jvm-2.13 kcl-fs2/target/jvm-2.13 kcl-localstack/target/jvm-3 kcl-fs2/target/jvm-2.12 kinesis-client/target/jvm-3 shared-localstack/target/jvm-2.13 shared-tests/target/jvm-2.12 aws-v1-localstack/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-2.13 shared-tests/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.13 kernel-tests/target/jvm-3 kpl-logging-circe/target/jvm-3 smithy4s-client-localstack/target/jvm-2.13 aws-v2-localstack/target/jvm-2.13 kpl-logging-circe/target/jvm-2.12 kcl-fs2/target/jvm-3 shared/target/jvm-2.12 smithy4s-client-tests/target/jvm-3 shared-circe/target/jvm-3 kinesis-client-producer-tests/target/jvm-2.12 shared-ciris/target/jvm-2.13 shared-localstack/target/jvm-3 compat/target/jvm-2.12 kpl-ciris/target/jvm-3 smithy4s-client/target/jvm-2.13 kpl-localstack/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-3 kcl-http4s/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.12 kcl-fs2-ciris/target/jvm-2.13 kcl-http4s/target/jvm-3 compat/target/jvm-2.13 project/target
+        run: mkdir -p smithy4s-client-tests/target/jvm-2.13 shared-ciris/target/jvm-3 smithy4s-client-producer-tests/target/jvm-2.13 aws-v1-localstack/target/jvm-2.12 kpl/target/jvm-3 target shared/target/jvm-2.13 kpl/target/jvm-2.12 kcl-ciris/target/jvm-3 kpl-ciris/target/jvm-2.13 kinesis-client-tests/target/jvm-2.12 kpl-ciris/target/jvm-2.12 smithy4s-client-localstack/target/jvm-3 smithy4s-client/target/jvm-3 unidocs/target/jvm-2.13 kernel-tests/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-2.13 kcl-logging-circe/target/jvm-3 .js/target kcl-fs2-ciris/target/jvm-2.12 kinesis-client-logging-circe/target/jvm-3 aws-v1-localstack/target/jvm-3 kcl-tests/target/jvm-2.12 site/target/jvm-2.13 kinesis-client-localstack/target/jvm-3 shared/target/jvm-3 kpl-tests/target/jvm-2.13 kcl-localstack/target/jvm-2.13 kcl-fs2-ciris/target/jvm-3 kcl/target/jvm-3 kcl/target/jvm-2.12 unidocs/target/jvm-2.12 smithy4s-client-transformers/target/jvm-2.12 kpl-tests/target/jvm-3 shared-ciris/target/jvm-2.12 shared-localstack/target/jvm-2.12 kpl-tests/target/jvm-2.12 kcl-localstack/target/jvm-2.12 kpl/target/jvm-2.13 kinesis-client-fs2/target/jvm-2.12 kinesis-client-producer-tests/target/jvm-3 shared-circe/target/jvm-2.12 shared-tests/target/jvm-3 kcl-logging-circe/target/jvm-2.13 kinesis-client-tests/target/jvm-3 kcl-tests/target/jvm-2.13 shared-fs2/target/jvm-2.13 kcl-ciris/target/jvm-2.13 kinesis-client-logging-circe/target/jvm-2.13 unidocs/target/jvm-3 smithy4s-client-producer-tests/target/jvm-3 compat/target/jvm-3 kinesis-client-logging-circe/target/jvm-2.12 shared-circe/target/jvm-2.13 kinesis-client/target/jvm-2.12 kpl-logging-circe/target/jvm-2.13 kcl-tests/target/jvm-3 aws-v2-localstack/target/jvm-3 kernel-tests/target/jvm-2.13 kcl-http4s/target/jvm-2.12 aws-v2-localstack/target/jvm-2.12 kcl-logging-circe/target/jvm-2.12 kinesis-client/target/jvm-2.13 kinesis-client-fs2/target/jvm-2.13 .jvm/target kcl/target/jvm-2.13 kpl-localstack/target/jvm-3 kpl-localstack/target/jvm-2.13 kcl-ciris/target/jvm-2.12 .native/target kinesis-client-tests/target/jvm-2.13 kcl-fs2/target/jvm-2.13 kcl-localstack/target/jvm-3 smithy4s-client-fs2/target/jvm-2.13 kcl-fs2/target/jvm-2.12 shared-fs2/target/jvm-2.12 kinesis-client-fs2/target/jvm-3 kinesis-client/target/jvm-3 shared-localstack/target/jvm-2.13 shared-tests/target/jvm-2.12 aws-v1-localstack/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-2.13 shared-tests/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.13 kernel-tests/target/jvm-3 kpl-logging-circe/target/jvm-3 smithy4s-client-localstack/target/jvm-2.13 aws-v2-localstack/target/jvm-2.13 kpl-logging-circe/target/jvm-2.12 kcl-fs2/target/jvm-3 smithy4s-client-fs2/target/jvm-3 shared/target/jvm-2.12 smithy4s-client-tests/target/jvm-3 shared-circe/target/jvm-3 kinesis-client-producer-tests/target/jvm-2.12 shared-ciris/target/jvm-2.13 shared-fs2/target/jvm-3 shared-localstack/target/jvm-3 compat/target/jvm-2.12 kpl-ciris/target/jvm-3 smithy4s-client/target/jvm-2.13 kpl-localstack/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-3 kcl-http4s/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.12 kcl-fs2-ciris/target/jvm-2.13 kcl-http4s/target/jvm-3 compat/target/jvm-2.13 project/target
 
       - name: Compress target directories
         if: github.event_name != 'pull_request' && (startsWith(github.ref, 'refs/tags/v') || github.ref == 'refs/heads/main')
-        run: tar cf targets.tar smithy4s-client-tests/target/jvm-2.13 shared-ciris/target/jvm-3 smithy4s-client-producer-tests/target/jvm-2.13 aws-v1-localstack/target/jvm-2.12 kpl/target/jvm-3 target shared/target/jvm-2.13 kpl/target/jvm-2.12 kcl-ciris/target/jvm-3 kpl-ciris/target/jvm-2.13 kinesis-client-tests/target/jvm-2.12 kpl-ciris/target/jvm-2.12 smithy4s-client-localstack/target/jvm-3 smithy4s-client/target/jvm-3 unidocs/target/jvm-2.13 kernel-tests/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-2.13 kcl-logging-circe/target/jvm-3 .js/target kcl-fs2-ciris/target/jvm-2.12 kinesis-client-logging-circe/target/jvm-3 aws-v1-localstack/target/jvm-3 kcl-tests/target/jvm-2.12 site/target/jvm-2.13 kinesis-client-localstack/target/jvm-3 shared/target/jvm-3 kpl-tests/target/jvm-2.13 kcl-localstack/target/jvm-2.13 kcl-fs2-ciris/target/jvm-3 kcl/target/jvm-3 kcl/target/jvm-2.12 unidocs/target/jvm-2.12 smithy4s-client-transformers/target/jvm-2.12 kpl-tests/target/jvm-3 shared-ciris/target/jvm-2.12 shared-localstack/target/jvm-2.12 kpl-tests/target/jvm-2.12 kcl-localstack/target/jvm-2.12 kpl/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-3 shared-circe/target/jvm-2.12 shared-tests/target/jvm-3 kcl-logging-circe/target/jvm-2.13 kinesis-client-tests/target/jvm-3 kcl-tests/target/jvm-2.13 kcl-ciris/target/jvm-2.13 kinesis-client-logging-circe/target/jvm-2.13 unidocs/target/jvm-3 smithy4s-client-producer-tests/target/jvm-3 compat/target/jvm-3 kinesis-client-logging-circe/target/jvm-2.12 shared-circe/target/jvm-2.13 kinesis-client/target/jvm-2.12 kpl-logging-circe/target/jvm-2.13 kcl-tests/target/jvm-3 aws-v2-localstack/target/jvm-3 kernel-tests/target/jvm-2.13 kcl-http4s/target/jvm-2.12 aws-v2-localstack/target/jvm-2.12 kcl-logging-circe/target/jvm-2.12 kinesis-client/target/jvm-2.13 .jvm/target kcl/target/jvm-2.13 kpl-localstack/target/jvm-3 kpl-localstack/target/jvm-2.13 kcl-ciris/target/jvm-2.12 .native/target kinesis-client-tests/target/jvm-2.13 kcl-fs2/target/jvm-2.13 kcl-localstack/target/jvm-3 kcl-fs2/target/jvm-2.12 kinesis-client/target/jvm-3 shared-localstack/target/jvm-2.13 shared-tests/target/jvm-2.12 aws-v1-localstack/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-2.13 shared-tests/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.13 kernel-tests/target/jvm-3 kpl-logging-circe/target/jvm-3 smithy4s-client-localstack/target/jvm-2.13 aws-v2-localstack/target/jvm-2.13 kpl-logging-circe/target/jvm-2.12 kcl-fs2/target/jvm-3 shared/target/jvm-2.12 smithy4s-client-tests/target/jvm-3 shared-circe/target/jvm-3 kinesis-client-producer-tests/target/jvm-2.12 shared-ciris/target/jvm-2.13 shared-localstack/target/jvm-3 compat/target/jvm-2.12 kpl-ciris/target/jvm-3 smithy4s-client/target/jvm-2.13 kpl-localstack/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-3 kcl-http4s/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.12 kcl-fs2-ciris/target/jvm-2.13 kcl-http4s/target/jvm-3 compat/target/jvm-2.13 project/target
+        run: tar cf targets.tar smithy4s-client-tests/target/jvm-2.13 shared-ciris/target/jvm-3 smithy4s-client-producer-tests/target/jvm-2.13 aws-v1-localstack/target/jvm-2.12 kpl/target/jvm-3 target shared/target/jvm-2.13 kpl/target/jvm-2.12 kcl-ciris/target/jvm-3 kpl-ciris/target/jvm-2.13 kinesis-client-tests/target/jvm-2.12 kpl-ciris/target/jvm-2.12 smithy4s-client-localstack/target/jvm-3 smithy4s-client/target/jvm-3 unidocs/target/jvm-2.13 kernel-tests/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-2.13 kcl-logging-circe/target/jvm-3 .js/target kcl-fs2-ciris/target/jvm-2.12 kinesis-client-logging-circe/target/jvm-3 aws-v1-localstack/target/jvm-3 kcl-tests/target/jvm-2.12 site/target/jvm-2.13 kinesis-client-localstack/target/jvm-3 shared/target/jvm-3 kpl-tests/target/jvm-2.13 kcl-localstack/target/jvm-2.13 kcl-fs2-ciris/target/jvm-3 kcl/target/jvm-3 kcl/target/jvm-2.12 unidocs/target/jvm-2.12 smithy4s-client-transformers/target/jvm-2.12 kpl-tests/target/jvm-3 shared-ciris/target/jvm-2.12 shared-localstack/target/jvm-2.12 kpl-tests/target/jvm-2.12 kcl-localstack/target/jvm-2.12 kpl/target/jvm-2.13 kinesis-client-fs2/target/jvm-2.12 kinesis-client-producer-tests/target/jvm-3 shared-circe/target/jvm-2.12 shared-tests/target/jvm-3 kcl-logging-circe/target/jvm-2.13 kinesis-client-tests/target/jvm-3 kcl-tests/target/jvm-2.13 shared-fs2/target/jvm-2.13 kcl-ciris/target/jvm-2.13 kinesis-client-logging-circe/target/jvm-2.13 unidocs/target/jvm-3 smithy4s-client-producer-tests/target/jvm-3 compat/target/jvm-3 kinesis-client-logging-circe/target/jvm-2.12 shared-circe/target/jvm-2.13 kinesis-client/target/jvm-2.12 kpl-logging-circe/target/jvm-2.13 kcl-tests/target/jvm-3 aws-v2-localstack/target/jvm-3 kernel-tests/target/jvm-2.13 kcl-http4s/target/jvm-2.12 aws-v2-localstack/target/jvm-2.12 kcl-logging-circe/target/jvm-2.12 kinesis-client/target/jvm-2.13 kinesis-client-fs2/target/jvm-2.13 .jvm/target kcl/target/jvm-2.13 kpl-localstack/target/jvm-3 kpl-localstack/target/jvm-2.13 kcl-ciris/target/jvm-2.12 .native/target kinesis-client-tests/target/jvm-2.13 kcl-fs2/target/jvm-2.13 kcl-localstack/target/jvm-3 smithy4s-client-fs2/target/jvm-2.13 kcl-fs2/target/jvm-2.12 shared-fs2/target/jvm-2.12 kinesis-client-fs2/target/jvm-3 kinesis-client/target/jvm-3 shared-localstack/target/jvm-2.13 shared-tests/target/jvm-2.12 aws-v1-localstack/target/jvm-2.13 kinesis-client-producer-tests/target/jvm-2.13 shared-tests/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.13 kernel-tests/target/jvm-3 kpl-logging-circe/target/jvm-3 smithy4s-client-localstack/target/jvm-2.13 aws-v2-localstack/target/jvm-2.13 kpl-logging-circe/target/jvm-2.12 kcl-fs2/target/jvm-3 smithy4s-client-fs2/target/jvm-3 shared/target/jvm-2.12 smithy4s-client-tests/target/jvm-3 shared-circe/target/jvm-3 kinesis-client-producer-tests/target/jvm-2.12 shared-ciris/target/jvm-2.13 shared-fs2/target/jvm-3 shared-localstack/target/jvm-3 compat/target/jvm-2.12 kpl-ciris/target/jvm-3 smithy4s-client/target/jvm-2.13 kpl-localstack/target/jvm-2.12 smithy4s-client-logging-circe/target/jvm-3 kcl-http4s/target/jvm-2.13 kinesis-client-localstack/target/jvm-2.12 kcl-fs2-ciris/target/jvm-2.13 kcl-http4s/target/jvm-3 compat/target/jvm-2.13 project/target
 
       - name: Upload target directories
         if: github.event_name != 'pull_request' && (startsWith(github.ref, 'refs/tags/v') || github.ref == 'refs/heads/main')
@@ -144,6 +149,11 @@ jobs:
             ~/Library/Caches/Coursier/v1
           key: ${{ runner.os }}-sbt-cache-v2-${{ hashFiles('**/*.sbt') }}-${{ hashFiles('project/build.properties') }}
 
+      - name: Setup protoc
+        uses: arduino/setup-protoc@v1
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Download target directories (2.12.17, rootJVM)
         uses: actions/download-artifact@v3
         with:
@@ -230,6 +240,11 @@ jobs:
             ~/Library/Caches/Coursier/v1
           key: ${{ runner.os }}-sbt-cache-v2-${{ hashFiles('**/*.sbt') }}-${{ hashFiles('project/build.properties') }}
 
+      - name: Setup protoc
+        uses: arduino/setup-protoc@v1
+        with:
+          repo-token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Generate site
         run: sbt '++ ${{ matrix.scala }}' docs/tlSite
 

diff --git a/.mergify.yml b/.mergify.yml
@@ -120,6 +120,14 @@ pull_request_rules:
       add:
       - kinesis-client
       remove: []
+- name: Label kinesis-client-fs2 PRs
+  conditions:
+  - files~=^kinesis-client-fs2/
+  actions:
+    label:
+      add:
+      - kinesis-client-fs2
+      remove: []
 - name: Label kinesis-client-localstack PRs
   conditions:
   - files~=^kinesis-client-localstack/
@@ -216,6 +224,14 @@ pull_request_rules:
       add:
       - shared-ciris
       remove: []
+- name: Label shared-fs2 PRs
+  conditions:
+  - files~=^shared-fs2/
+  actions:
+    label:
+      add:
+      - shared-fs2
+      remove: []
 - name: Label shared-localstack PRs
   conditions:
   - files~=^shared-localstack/
@@ -240,6 +256,14 @@ pull_request_rules:
       add:
       - smithy4s-client
       remove: []
+- name: Label smithy4s-client-fs2 PRs
+  conditions:
+  - files~=^smithy4s-client-fs2/
+  actions:
+    label:
+      add:
+      - smithy4s-client-fs2
+      remove: []
 - name: Label smithy4s-client-localstack PRs
   conditions:
   - files~=^smithy4s-client-localstack/

diff --git a/build.sbt b/build.sbt
@@ -25,13 +25,23 @@ lazy val shared = projectMatrix
     libraryDependencies ++= Seq(
       Aws.Aggregation.aggregator % Test,
       Aws.Aggregation.deaggregator % Test,
+      Aws.kcl % Test,
       Log4Cats.slf4j % Test
     )
   )
   .jvmPlatform(allScalaVersions)
   .enableIntegrationTests
   .dependsOn(compat)
 
+lazy val `shared-fs2` = projectMatrix
+  .settings(
+    description := "Common code for FS2",
+    libraryDependencies ++= Seq(FS2.core)
+  )
+  .jvmPlatform(allScalaVersions)
+  .enableIntegrationTests
+  .dependsOn(shared)
+
 lazy val `shared-circe` = projectMatrix
   .settings(
     description := "Common shared utilities for Circe",
@@ -69,7 +79,7 @@ lazy val `shared-tests` = projectMatrix
   )
   .jvmPlatform(allScalaVersions)
   .enableIntegrationTests
-  .dependsOn(`shared-localstack`, `kernel-tests`)
+  .dependsOn(`shared-localstack`, `shared-fs2`, `kernel-tests`)
 
 lazy val `aws-v2-localstack` = projectMatrix
   .settings(
@@ -292,6 +302,11 @@ lazy val `kinesis-client` = projectMatrix
   .enableIntegrationTests
   .dependsOn(shared)
 
+lazy val `kinesis-client-fs2` = projectMatrix
+  .jvmPlatform(allScalaVersions)
+  .enableIntegrationTests
+  .dependsOn(`kinesis-client`, `shared-fs2`)
+
 lazy val `kinesis-client-logging-circe` = projectMatrix
   .settings(
     description := "JSON structured logging instances for the Java Kinesis Client, via Circe"
@@ -310,7 +325,7 @@ lazy val `kinesis-client-localstack` = projectMatrix
   )
   .jvmPlatform(allScalaVersions)
   .enableIntegrationTests
-  .dependsOn(`aws-v2-localstack`, `kinesis-client`)
+  .dependsOn(`aws-v2-localstack`, `kinesis-client-fs2`)
 
 lazy val `kinesis-client-tests` = projectMatrix
   .enablePlugins(NoPublishPlugin)
@@ -377,6 +392,11 @@ lazy val `smithy4s-client` = projectMatrix
   .enableIntegrationTests
   .dependsOn(shared)
 
+lazy val `smithy4s-client-fs2` = projectMatrix
+  .jvmPlatform(last2ScalaVersions)
+  .enableIntegrationTests
+  .dependsOn(`smithy4s-client`, `shared-fs2`)
+
 lazy val `smithy4s-client-logging-circe` = projectMatrix
   .enablePlugins(Smithy4sCodegenPlugin)
   .settings(
@@ -392,7 +412,7 @@ lazy val `smithy4s-client-localstack` = projectMatrix
     description := "A test-kit for working with Kinesis and Localstack, via the Smithy4s Client project"
   )
   .jvmPlatform(last2ScalaVersions)
-  .dependsOn(`shared-localstack`, `smithy4s-client`)
+  .dependsOn(`shared-localstack`, `smithy4s-client-fs2`)
 
 lazy val `smithy4s-client-tests` = projectMatrix
   .enablePlugins(NoPublishPlugin)
@@ -472,6 +492,7 @@ lazy val docs = projectMatrix
     compat,
     `kernel-tests`,
     shared,
+    `shared-fs2`,
     `shared-circe`,
     `shared-ciris`,
     `shared-localstack`,
@@ -490,9 +511,11 @@ lazy val docs = projectMatrix
     `kpl-logging-circe`,
     `kpl-localstack`,
     `kinesis-client`,
+    `kinesis-client-fs2`,
     `kinesis-client-logging-circe`,
     `kinesis-client-localstack`,
     `smithy4s-client`,
+    `smithy4s-client-fs2`,
     `smithy4s-client-logging-circe`,
     `smithy4s-client-localstack`
   )
@@ -508,6 +531,7 @@ lazy val unidocs = projectMatrix
         compat,
         `kernel-tests`,
         shared,
+        `shared-fs2`,
         `shared-circe`,
         `shared-ciris`,
         `shared-localstack`,
@@ -526,9 +550,11 @@ lazy val unidocs = projectMatrix
         `kpl-logging-circe`,
         `kpl-localstack`,
         `kinesis-client`,
+        `kinesis-client-fs2`,
         `kinesis-client-logging-circe`,
         `kinesis-client-localstack`,
         `smithy4s-client`,
+        `smithy4s-client-fs2`,
         `smithy4s-client-logging-circe`,
         `smithy4s-client-localstack`
       ).flatMap(_.projectRefs): _*
@@ -539,6 +565,7 @@ lazy val allProjects = Seq(
   compat,
   `kernel-tests`,
   shared,
+  `shared-fs2`,
   `shared-circe`,
   `shared-ciris`,
   `shared-localstack`,
@@ -559,12 +586,14 @@ lazy val allProjects = Seq(
   `kpl-localstack`,
   `kpl-tests`,
   `kinesis-client`,
+  `kinesis-client-fs2`,
   `kinesis-client-logging-circe`,
   `kinesis-client-localstack`,
   `kinesis-client-tests`,
   `kinesis-client-producer-tests`,
   `smithy4s-client-transformers`,
   `smithy4s-client`,
+  `smithy4s-client-fs2`,
   `smithy4s-client-logging-circe`,
   `smithy4s-client-localstack`,
   `smithy4s-client-tests`,

diff --git a/docs/client/directory.conf b/docs/client/directory.conf
@@ -1,6 +1,7 @@
 laika.title = Kinesis Client
 laika.navigationOrder = [
     getting-started.md
+    fs2.md
     circe.md
     localstack.md
 ]