Skip to content

SqlPersistedQueue

2 exports Added in v1.0.0 Source

Constructors

make

Added in v1.0.0 Source

Signature

declare const make: (options?: {
  readonly lockExpiration?: Duration.DurationInput;
  readonly lockRefreshInterval?: Duration.DurationInput;
  readonly pollInterval?: Duration.DurationInput;
  readonly tableName?: string;
}) => Effect.Effect<
  PersistedQueue.PersistedQueueStore["Type"],
  SqlError,
  SqlClient.SqlClient | Scope.Scope
>;

Layers

layerStore

Added in v1.0.0 Source

Signature

declare function layerStore(options?: {
  readonly lockExpiration?: any;
  readonly lockRefreshInterval?: any;
  readonly pollInterval?: any;
  readonly tableName?: string;
}): Layer<PersistedQueueStore, SqlError, SqlClient>;