Skip to main content Link Search Menu Expand Document (external link)

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
>

Source

Since v1.0.0

Layers

layer

Signature

declare const layer: Layer.Layer<ShardStorage.ShardStorage, SqlError, SqlClient.SqlClient>

Source

Since v1.0.0

layerWith

Signature

declare const layerWith: (options: {
  readonly prefix?: string | undefined
}) => Layer.Layer<ShardStorage.ShardStorage, SqlError, SqlClient.SqlClient>

Source

Since v1.0.0