Add cosmos mode switch

Author: bartelink

tools/Propulsion.Tool/Propulsion.Tool.fsproj

@@ -31,7 +31,7 @@
     <PackageReference Include="MinVer" Version="5.0.0" PrivateAssets="All" />
 
     <!-- The tool should use a relatively fresh Cosmos lib; Equinox.CosmosStore has a conservative dependency-->
-    <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.46.0" />
+    <PackageReference Include="Microsoft.Azure.Cosmos" Version="3.49.0" />
 
 	<PackageReference Include="Argu" Version="6.2.2" />
     <!-- Required or there'll be an exception at runtime re missing support DLLs when using RBAC -->

tools/Propulsion.Tool/Sync.fs

@@ -106,6 +106,7 @@ and KafkaArguments(c: Args.Configuration, p: ParseResults<KafkaParameters>) =
     member val Topic =                      p.GetResult(Topic, fun () -> c.KafkaTopic)
     member val Source =                     SourceArguments(c, p.GetResult KafkaParameters.From)
 and [<NoEquality; NoComparison; RequireSubcommand>] CosmosParameters =
+    | [<AltCommandLine "-m">]               ConnectionMode of Microsoft.Azure.Cosmos.ConnectionMode
     | [<AltCommandLine "-s">]               Connection of string
     | [<AltCommandLine "-d">]               Database of string
     | [<AltCommandLine "-c"; Mandatory>]    Container of string
@@ -117,6 +118,7 @@ and [<NoEquality; NoComparison; RequireSubcommand>] CosmosParameters =
     | [<CliPrefix(CliPrefix.None); Last>]   From of ParseResults<SourceParameters>
     interface IArgParserTemplate with
         member a.Usage = a |> function
+            | ConnectionMode _ ->           "override the connection mode. Default: Direct."
             | Connection _ ->               $"""specify a connection string for the destination Cosmos account.
                                             Default (From Cosmos): Same as Source.
                                             Default (From Json): optional if environment variable {Args.Configuration.Cosmos.CONNECTION} specified"""
@@ -138,8 +140,9 @@ and CosmosArguments(c: Args.Configuration, p: ParseResults<CosmosParameters>) =
                                             | x -> p.Raise $"unexpected subcommand %A{x}"
     let connector =
         let retries =                       p.GetResult(Retries, 2)
+        let mode =                          p.TryGetResult ConnectionMode
         let maxRetryWaitTime =              p.GetResult(RetriesWaitTime, 5) |> TimeSpan.seconds
-        Equinox.CosmosStore.CosmosStoreConnector(Equinox.CosmosStore.Discovery.ConnectionString connection, retries, maxRetryWaitTime)
+        Equinox.CosmosStore.CosmosStoreConnector(Equinox.CosmosStore.Discovery.ConnectionString connection, retries, maxRetryWaitTime, ?mode = mode)
     let database =                          match source.Store with
                                             | Cosmos c -> p.GetResult(Database, fun () -> c.Database)
                                             | Json _ -> p.GetResult(Database, fun () -> c.CosmosDatabase)