export declare const AtLeastOnceStorage: Tag<AtLeastOnceStorage, AtLeastOnceStorage>

export declare const layer: (
  options: AtLeastOnceStorage.MakeOptions
) => Layer<AtLeastOnceStorage, SqlError, SqlClient | Serialization>

export interface AtLeastOnceStorage extends AtLeastOnceStorage.Proto {
  /**
   * Upserts a message into the storage, eventually returning the already
   * existing message state as result in the storage.
   */
  upsert<Msg extends Message.Any>(
    recipientType: RecipientType<Msg>,
    shardId: ShardId,
    entityId: string,
    message: Msg
  ): Effect<void>

  /**
   * Marks the specified message as processed to prevent additional attempts to
   * send the message.
   */
  markAsProcessed<Msg extends Message.Any>(
    recipientType: RecipientType<Msg>,
    shardId: ShardId,
    entityId: string,
    message: Msg
  ): Effect<void>

  /**
   * Returns a stream of messages that will be sent to the local pod as a second
   * attempt.
   */
  sweepPending(shardIds: Iterable<ShardId>): Stream<SerializedEnvelope>
}

export declare const TypeId: typeof TypeId

export type TypeId = typeof TypeId

export interface MakeOptions {
  readonly table: string
}

export interface Proto {
  readonly [TypeId]: TypeId
}