File tree Expand file tree Collapse file tree 1 file changed +12
-14
lines changed
Expand file tree Collapse file tree 1 file changed +12
-14
lines changed Original file line number Diff line number Diff line change @@ -8,19 +8,17 @@ type PostgresConfig =
88 database: string }
99
1010module Postgres =
11- let createStore : PostgresConfig -> SqlStreamStore.PostgresStreamStore =
12- fun config ->
11+ let createStore ( config : PostgresConfig ): SqlStreamStore.PostgresStreamStore =
12+ let storeSettings : string =
13+ sprintf
14+ " Host=%s ;Port=%s ;User Id=%s ;Password=%s ;Database=%s "
15+ config.host
16+ config.port
17+ config.username
18+ config.password
19+ config.database
1320
14- let storeSettings : string =
15- sprintf
16- " Host=%s ;Port=%s ;User Id=%s ;Password=%s ;Database=%s "
17- config.host
18- config.port
19- config.username
20- config.password
21- config.database
21+ new SqlStreamStore.PostgresStreamStore( SqlStreamStore.PostgresStreamStoreSettings( storeSettings))
2222
23- new SqlStreamStore.PostgresStreamStore( SqlStreamStore.PostgresStreamStoreSettings( storeSettings))
24-
25- let createSchema : SqlStreamStore.PostgresStreamStore -> Async < unit > =
26- fun conn -> conn.CreateSchemaIfNotExists() |> Async.AwaitTask
23+ let createSchema ( store : SqlStreamStore.PostgresStreamStore ): Async < unit > =
24+ store.CreateSchemaIfNotExists() |> Async.AwaitTask
You can’t perform that action at this time.
0 commit comments