SqlShardStorage.ts overview
Since v1.0.0
Exports Grouped by Category
Constructors
make
Signature
declare const make: (
options?: { readonly prefix?: string | undefined } | undefined
) => Effect.Effect<
{
readonly getAssignments: Effect.Effect<ReadonlyMap<ShardId, Option<RunnerAddress>>, PersistenceError>
readonly saveAssignments: (
assignments: Iterable<readonly [ShardId, Option<RunnerAddress>]>
) => Effect.Effect<void, PersistenceError>
readonly getRunners: Effect.Effect<Array<[RunnerAddress, Runner]>, PersistenceError>
readonly saveRunners: (runners: Iterable<readonly [RunnerAddress, Runner]>) => Effect.Effect<void, PersistenceError>
readonly acquire: (
address: RunnerAddress,
shardIds: Iterable<ShardId>
) => Effect.Effect<Array<ShardId>, PersistenceError>
readonly refresh: (
address: RunnerAddress,
shardIds: Iterable<ShardId>
) => Effect.Effect<Array<ShardId>, PersistenceError>
readonly release: (address: RunnerAddress, shardId: ShardId) => Effect.Effect<void, PersistenceError>
readonly releaseAll: (address: RunnerAddress) => Effect.Effect<void, PersistenceError>
},
SqlError,
SqlClient.SqlClient
>
Since v1.0.0
Layers
layer
Signature
declare const layer: Layer.Layer<ShardStorage.ShardStorage, SqlError, SqlClient.SqlClient>
Since v1.0.0
layerWith
Signature
declare const layerWith: (options: {
readonly prefix?: string | undefined
}) => Layer.Layer<ShardStorage.ShardStorage, SqlError, SqlClient.SqlClient>
Since v1.0.0