Split out StreamContext, implement more shard handling

fsprojects · Jun 20, 2024 · 7d73b82 · 7d73b82
1 parent fc258a4
commit 7d73b82
Show file tree

Hide file tree

Showing 8 changed files with 460 additions and 54 deletions.
diff --git a/paket.dependencies b/paket.dependencies
@@ -4,7 +4,7 @@ storage: none
 framework: net80, netstandard20, netstandard21
 
 nuget Unquote ~> 6.1.0
-nuget FSharp.Core >= 4.7.2 lowest_matching: true
+nuget FSharp.Core >= 6.0.7 lowest_matching: true
 
 nuget AWSSDK.DynamoDBv2 ~> 3.7.5
 nuget DotNet.ReproducibleBuilds

diff --git a/paket.lock b/paket.lock
@@ -2,16 +2,16 @@ STORAGE: NONE
 RESTRICTION: || (== net8.0) (== netstandard2.0) (== netstandard2.1)
 NUGET
   remote: https://api.nuget.org/v3/index.json
-    AWSSDK.Core (3.7.300.11)
+    AWSSDK.Core (3.7.303.5)
       Microsoft.Bcl.AsyncInterfaces (>= 1.1) - restriction: || (&& (== net8.0) (< netcoreapp3.1)) (== netstandard2.0) (== netstandard2.1)
-    AWSSDK.DynamoDBv2 (3.7.300.11)
-      AWSSDK.Core (>= 3.7.300.11 < 4.0)
+    AWSSDK.DynamoDBv2 (3.7.302.6)
+      AWSSDK.Core (>= 3.7.303.5 < 4.0)
     DotNet.ReproducibleBuilds (1.1.1)
       Microsoft.SourceLink.AzureRepos.Git (>= 1.1.1)
       Microsoft.SourceLink.Bitbucket.Git (>= 1.1.1)
       Microsoft.SourceLink.GitHub (>= 1.1.1)
       Microsoft.SourceLink.GitLab (>= 1.1.1)
-    FSharp.Core (4.7.2)
+    FSharp.Core (6.0.7)
     Microsoft.Bcl.AsyncInterfaces (8.0) - restriction: || (&& (== net8.0) (< netcoreapp3.1)) (== netstandard2.0) (== netstandard2.1)
       System.Threading.Tasks.Extensions (>= 4.5.4) - restriction: || (&& (== net8.0) (>= net462)) (&& (== net8.0) (< netstandard2.1)) (== netstandard2.0) (&& (== netstandard2.1) (>= net462))
     Microsoft.Build.Tasks.Git (8.0)
@@ -42,39 +42,32 @@ NUGET
   remote: https://api.nuget.org/v3/index.json
     FsCheck (2.16.6)
       FSharp.Core (>= 4.2.3)
-    FSharp.Core (8.0.100)
-    Microsoft.CodeCoverage (17.8)
-    Microsoft.NET.Test.Sdk (17.8)
-      Microsoft.CodeCoverage (>= 17.8)
-      Microsoft.TestPlatform.TestHost (>= 17.8)
-    Microsoft.NETCore.Platforms (7.0.4)
-    Microsoft.TestPlatform.ObjectModel (17.8)
-      NuGet.Frameworks (>= 6.5)
+    FSharp.Core (8.0.200)
+    Microsoft.CodeCoverage (17.9)
+    Microsoft.NET.Test.Sdk (17.9)
+      Microsoft.CodeCoverage (>= 17.9)
+      Microsoft.TestPlatform.TestHost (>= 17.9)
+    Microsoft.TestPlatform.ObjectModel (17.9)
       System.Reflection.Metadata (>= 1.6)
-    Microsoft.TestPlatform.TestHost (17.8)
-      Microsoft.TestPlatform.ObjectModel (>= 17.8)
+    Microsoft.TestPlatform.TestHost (17.9)
+      Microsoft.TestPlatform.ObjectModel (>= 17.9)
       Newtonsoft.Json (>= 13.0.1)
-    NETStandard.Library (2.0.3)
-      Microsoft.NETCore.Platforms (>= 1.1)
     Newtonsoft.Json (13.0.3)
-    NuGet.Frameworks (6.8)
     System.Collections.Immutable (8.0)
     System.Reflection.Metadata (8.0)
       System.Collections.Immutable (>= 8.0)
-    xunit (2.6.2)
-      xunit.analyzers (>= 1.6)
-      xunit.assert (>= 2.6.2)
-      xunit.core (2.6.2)
+    xunit (2.7)
+      xunit.analyzers (>= 1.11)
+      xunit.assert (>= 2.7)
+      xunit.core (2.7)
     xunit.abstractions (2.0.3)
-    xunit.analyzers (1.6)
-    xunit.assert (2.6.2)
-    xunit.core (2.6.2)
-      xunit.extensibility.core (2.6.2)
-      xunit.extensibility.execution (2.6.2)
-    xunit.extensibility.core (2.6.2)
-      NETStandard.Library (>= 1.6.1)
+    xunit.analyzers (1.11)
+    xunit.assert (2.7)
+    xunit.core (2.7)
+      xunit.extensibility.core (2.7)
+      xunit.extensibility.execution (2.7)
+    xunit.extensibility.core (2.7)
       xunit.abstractions (>= 2.0.3)
-    xunit.extensibility.execution (2.6.2)
-      NETStandard.Library (>= 1.6.1)
-      xunit.extensibility.core (2.6.2)
-    xunit.runner.visualstudio (2.5.4)
+    xunit.extensibility.execution (2.7)
+      xunit.extensibility.core (2.7)
+    xunit.runner.visualstudio (2.5.7)
diff --git a/src/FSharp.AWS.DynamoDB/FSharp.AWS.DynamoDB.fsproj b/src/FSharp.AWS.DynamoDB/FSharp.AWS.DynamoDB.fsproj
@@ -1,4 +1,3 @@
-<?xml version="1.0" encoding="utf-8"?>
 <Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
@@ -37,9 +36,10 @@
     <Compile Include="Expression\ExpressionContainers.fs" />
     <Compile Include="RecordTemplate.fs" />
     <Compile Include="TableContext.fs" />
+    <Compile Include="StreamContext.fs" />
     <Compile Include="Extensions.fs" />
     <None Include="Script.fsx" />
     <None Include="paket.template" />
   </ItemGroup>
   <Import Project="..\..\.paket\Paket.Restore.targets" />
-</Project>
+</Project>