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

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
>

Source

Since v1.0.0

Layers

layer

Signature

declare const layer: Layer.Layer<MessageStorage.MessageStorage, SqlError, SqlClient.SqlClient | ShardingConfig>

Source

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>

Source

Since v1.0.0