SqlMessageStorage.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 saveRequest: <R extends Any>(
envelope: OutgoingRequest<R>
) => Effect.Effect<MessageStorage.SaveResult<R>, PersistenceError | MalformedMessage>
readonly saveEnvelope: (envelope: OutgoingEnvelope) => Effect.Effect<void, PersistenceError | MalformedMessage>
readonly saveReply: <R extends Any>(
reply: Reply.ReplyWithContext<R>
) => Effect.Effect<void, PersistenceError | MalformedMessage>
readonly repliesFor: <R extends Any>(
requests: Iterable<OutgoingRequest<R>>
) => Effect.Effect<Array<Reply.Reply<R>>, PersistenceError | MalformedMessage>
readonly registerReplyHandler: <R extends Any>(
message: OutgoingRequest<R> | IncomingRequest<R>
) => Effect.Effect<void>
readonly unprocessedMessages: (shardIds: Iterable<ShardId>) => Effect.Effect<Array<Incoming<any>>, PersistenceError>
readonly unprocessedMessagesById: <R extends Any>(
messageIds: Iterable<Snowflake.Snowflake>
) => Effect.Effect<Array<Incoming<R>>, PersistenceError>
readonly resetShards: (shardIds: Iterable<ShardId>) => Effect.Effect<void, PersistenceError>
readonly resetAddress: (address: EntityAddress) => Effect.Effect<void, PersistenceError>
},
SqlError,
SqlClient.SqlClient | Snowflake.Generator
>
Since v1.0.0
Layers
layer
Signature
declare const layer: Layer.Layer<MessageStorage.MessageStorage, SqlError, SqlClient.SqlClient | ShardingConfig>
Since v1.0.0
layerWith
Signature
declare const layerWith: (options: {
readonly prefix?: string | undefined
readonly replyPollInterval?: DurationInput | undefined
}) => Layer.Layer<MessageStorage.MessageStorage, SqlError, SqlClient.SqlClient | ShardingConfig>
Since v1.0.0