共享状态 Adapter

这些 Adapter 分别实现不同的一致性领域。应按契约选择后端，而不是把“分布式状态” 当成一个数据库开关。

账户版本

AccountVersionStore 提供用于废止旧会话的 Generation， MutableAccountVersionStore 负责变更。内置实现包括：

• 单进程 MemoryAccountVersionStore；
• redis Feature 的 RedisAccountVersionStore；
• sql Feature、支持 PostgreSQL/MySQL 的 SqlAccountVersionStore。

SQL Adapter 提供 ensure_schema。迁移应由受控启动或部署 Owner 执行，不要让所有 副本无协调地同时迁移。

使用示例

use std::sync::Arc;

use elura::adapters::account_version::RedisAccountVersionStore;
use elura::prelude::*;

let versions = Arc::new(
    RedisAccountVersionStore::connect(redis_url, "game:account-version").await?,
);
let gateway = Gateway::new(gateway_config)
    .account_version_store(versions, AccountVersionSettings::default());

账户状态已位于 SQL 时，可改用 SqlAccountVersionStore::connect_postgres 或 connect_mysql。ensure_schema 应在拥有 Migration 所有权的位置运行一次。

在线目录

OnlineDirectory 管理 Session Lease、查询、分组和重复登录 Fencing。 OnlineStatsReader 返回指定 Region/Realm 的 Session 数和去重用户数。 OnlineBackend 组合两个能力；同时实现两个窄 Trait 的类型会自动实现它。

Lease TTL 需要容忍短暂停顿，又不能让死亡会话长期保持在线。KickExisting 还 需要兼容的会话控制传输。

完整契约、Gateway 注入、在线人数、生命周期 Observer 和自定义 Backend 参见 在线状态 API。

使用示例

use std::{sync::Arc, time::Duration};

use elura::adapters::online::RedisOnlineDirectory;
use elura::prelude::*;

let directory = Arc::new(RedisOnlineDirectory::connect(
    redis_url,
    "game:online",
    Duration::from_secs(60),
).await?);

let online_config = GatewayOnlineConfig::new(
    "gateway-1",
    Duration::from_secs(60),
    Duration::from_secs(20),
    DuplicateLoginMode::AllowMultiple,
);

let gateway = Gateway::new(gateway_config)
    .online_directory(directory, online_config);

Session 查询、在线数、分组、生命周期 Observer 与 KickExisting 配置参见 在线状态。

OTP 存储

OtpStore 原子创建 Challenge 并验证/消费尝试。MemoryOtpStore 是进程内实现； 多个 API 副本共享 Challenge Namespace 时应使用 RedisOtpStore 或自定义共享实现。

Store 负责原子性与 Cooldown，按 IP、接收者和全局限流仍属于应用 API。参见 OTP Provider。

使用示例

use std::time::Duration;

use elura::adapters::otp::RedisOtpStore;
use elura::core::otp::{OtpCreateResult, OtpRecord, OtpStore};

let store = RedisOtpStore::connect(redis_url, "game:otp").await?;
let result = store
    .create(
        OtpRecord {
            subject_key: "email:user@example.com".into(),
            purpose: "login".into(),
            code_digest: digest.to_vec(),
        },
        Duration::from_secs(300),
        Duration::from_secs(60),
    )
    .await?;
assert!(matches!(result, OtpCreateResult::Stored | OtpCreateResult::Cooldown));

只存储密码学 Digest，不要存储明文 OTP。应将同一 Store 传给发放与验证 Challenge 的应用 Provider。

票据防重放

ReplayStore 防止一次性 Gateway 票据被重复接受。只有同一票据 Namespace 的验证 始终落到单进程时，MemoryReplayStore 才正确；多个 Gateway 应使用 RedisReplayStore 或其他共享实现。

使用示例

use std::sync::Arc;

use elura::adapters::replay::RedisReplayStore;
use elura::prelude::*;

let replay = Arc::new(
    RedisReplayStore::connect(redis_url, "game:ticket-replay").await?,
);
let gateway = Gateway::new(gateway_config).replay_store(replay);

只有一个 Gateway 进程时，可使用零依赖的 MemoryReplayStore。多个 Gateway 可能 接受同一 Ticket Namespace 之前，必须切换到 Redis。