Trimmed down Infrastructure.fs for only one client with log emission.

jet · Jul 22, 2021 · d7b271d · d7b271d
1 parent 67c040f
commit d7b271d
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/propulsion-cosmos-reactor/Infrastructure.fs b/propulsion-cosmos-reactor/Infrastructure.fs
@@ -94,12 +94,5 @@ module ConnectorExtensions =
  Equinox.CosmosStore.CosmosStoreClient.Connect(x.CreateAndInitialize, databaseId, containerId)
 
  /// Creates a CosmosClient suitable for running a CFP via CosmosStoreSource
- member x.ConnectMonitored(databaseId, containerId, ?connectionName) =
- x.LogConfiguration(defaultArg connectionName "Source", databaseId, containerId)
+ member x.ConnectMonitored(databaseId, containerId) =
  x.CreateUninitialized(databaseId, containerId)
-
- /// Connects to a Store as both a ChangeFeedProcessor Monitored Container and a CosmosStoreClient
- member x.ConnectStoreAndMonitored(databaseId, containerId) =
- let monitored = x.ConnectMonitored(databaseId, containerId, "Main")
- let storeClient = Equinox.CosmosStore.CosmosStoreClient(monitored.Database.Client, databaseId, containerId)
- storeClient, monitored