👁 Image
Mostlylucid.Ephemeral.Atoms.Data 2.6.3

Mostlylucid.Ephemeral.Atoms.Data

Core data storage abstractions for signal-driven persistence. This package provides the base interfaces and configuration used by storage-specific implementations.

Installation

dotnet add package Mostlylucid.Ephemeral.Atoms.Data

For actual storage, install one of:

• Mostlylucid.Ephemeral.Atoms.Data.File - JSON file storage
• Mostlylucid.Ephemeral.Atoms.Data.Sqlite - SQLite database
• Mostlylucid.Ephemeral.Atoms.Data.Postgres - PostgreSQL database

Configuration

All storage atoms share common configuration:

var config = new DataStorageConfig
{
 DatabaseName = "orders", // Used in signal patterns
 SignalPrefix = "save.data", // save.data.orders
 LoadSignalPrefix = "load.data", // load.data.orders
 DeleteSignalPrefix = "delete.data", // delete.data.orders
 MaxConcurrency = 1, // Sequential writes (recommended)
 EmitCompletionSignals = true // Emit saved.data.orders on success
};

Signal Patterns

Usage

Direct API (Atom Style)

var signals = new SignalSink();
var config = new DataStorageConfig { DatabaseName = "orders" };

await using var storage = new FileDataStorageAtom<string, Order>(signals, config, "./data");

// Save directly
await storage.SaveAsync("order-123", new Order { Id = "order-123", Total = 99.99m });

// Load
var order = await storage.LoadAsync("order-123");

// Fire-and-forget via signal
storage.EnqueueSave("order-456", new Order { Id = "order-456", Total = 50.00m });

Signal-Driven (Attribute Style)

[EphemeralJobs]
public class OrderService
{
 private readonly IDataStorageAtom<string, Order> _storage;

 public OrderService(IDataStorageAtom<string, Order> storage)
 {
 _storage = storage;
 }

 [EphemeralJob("order.created")]
 public async Task OnOrderCreated(SignalEvent signal, Order order)
 {
 // Storage listens for save.data.orders automatically
 await _storage.SaveAsync(order.Id, order);
 }

 [EphemeralJob("saved.data.orders")]
 public Task OnOrderSaved(SignalEvent signal)
 {
 Console.WriteLine($"Order {signal.Key} saved successfully");
 return Task.CompletedTask;
 }
}

Interfaces

IDataStorageAtom<TKey, TValue>

public interface IDataStorageAtom<TKey, TValue> : IAsyncDisposable
{
 DataStorageConfig Config { get; }
 Task SaveAsync(TKey key, TValue value, CancellationToken ct = default);
 Task<TValue?> LoadAsync(TKey key, CancellationToken ct = default);
 Task DeleteAsync(TKey key, CancellationToken ct = default);
 Task<bool> ExistsAsync(TKey key, CancellationToken ct = default);
}