Azure Table Storage¶

The Azure Table Storage module generates complete persistence abstractions from [TableEntity] and [TableStore] attributes — typed entity mappers, store interfaces, store implementations backed by TableServiceClient, effect methods, capability interfaces, and DI registration.

Quick Start¶

Define a table entity:

using Deepstaging.Cloud.Azure.Storage;

[TableEntity("Conversations")]
public partial record Conversation
{
    [PartitionKey] public required string ThreadTs { get; init; }
    [RowKey] public required string PhoneNumber { get; init; }
    public required string DisplayName { get; init; }
    public required int MessageCount { get; init; }
    public required DateTimeOffset CreatedAt { get; init; }
}

This generates:

• ToTableEntity() / FromTableEntity() — mapper methods on the entity
• IConversationStore — async CRUD interface (UpsertAsync, GetAsync, DeleteAsync, QueryByPartitionAsync)
• ConversationStore — implementation backed by TableServiceClient
• AddConversationStore — DI registration extension method

Define a table store for effects composition:

[TableStore]
public static partial class ChatStore;

This generates:

• IHasChatStore — capability interface for runtime access
• ChatStoreService — aggregated service with methods for all entities
• ChatStore.GetConversation<RT>() — Eff<RT, T> effect methods
• AddChatStore — DI registration for the service

Compose with effect pipelines:

var program =
    from conv in ChatStore.GetConversation<AppRuntime>(threadTs, phoneNumber)
    from _ in guard(conv.IsSome, Error.New("Conversation not found"))
              >> ChatStore.UpsertConversation<AppRuntime>(conv.Value! with { DisplayName = "Updated" })
    select unit;

What's Next¶

Diagnostics¶