pangolin

wangjia/pangolin

Fork 0

Commit Graph

Author	SHA1	Message	Date
wangjia	86b67c557b	feat(server/db): 多库(3/4)— Dialect 抽象(upsert/锁)+ 合并 directory_version - db.Dialect:LockForUpdate(mysql "FOR UPDATE" / sqlite "")、Upsert(中性 EXCLUDED.col → mysql VALUES()/ sqlite excluded.);DialectForDB 从连接驱动推导 - 9 处 ON DUPLICATE KEY、11 处 FOR UPDATE 全走 dialect;sqlite 靠 _txlock= immediate 取得 BEGIN IMMEDIATE 悲观锁等价语义 - directory_version 三处重复合并为 store.BumpDirectoryVersion(dialect 感知) - 这些文件同时含(2/4)的 UTC→Go 改动(与 upsert/锁同语句交错,无法拆分) - 顺带:usage 的 FIELD()、codes 的 DATE_ADD/GREATEST 续期、nodes 的 UNIX_TIMESTAMP、NULLIF 等 MySQL 专属构造一并退回 Go/可移植写法 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>	2026-06-18 00:01:26 +08:00
wangjia	4783f3e32e	feat(nodes): 节点生命周期状态机 [tsk_aG4yOS90inF_] 实现 Lifecycle 类型及其全部公开方法，覆盖 6 个状态迁移动作： MarkProbing / MarkUp / MarkDraining / MarkDown / MarkDestroyed / MarkBlockedSuspect。每次合法迁移在同一个 SQL 事务中原子执行 UPDATE nodes + INSERT node_events + BumpVersion；MarkDestroyed 事务提交后异步调用 mtls.CRL.Revoke() 并清除 Redis 负载缓存与命令队列键。配套集成测试覆盖 5 类场景（合法迁移、非法迁移、并发写、后置钩子、blocked_suspect 幂等），全部通过。 Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>	2026-06-15 23:49:45 +08:00

Author

SHA1

Message

Date

wangjia

86b67c557b

feat(server/db): 多库(3/4)— Dialect 抽象(upsert/锁)+ 合并 directory_version

- db.Dialect:LockForUpdate(mysql "FOR UPDATE" / sqlite "")、Upsert(中性
  EXCLUDED.col → mysql VALUES()/ sqlite excluded.);DialectForDB 从连接驱动推导
- 9 处 ON DUPLICATE KEY、11 处 FOR UPDATE 全走 dialect;sqlite 靠 _txlock=
  immediate 取得 BEGIN IMMEDIATE 悲观锁等价语义
- directory_version 三处重复合并为 store.BumpDirectoryVersion(dialect 感知)
- 这些文件同时含(2/4)的 UTC→Go 改动(与 upsert/锁同语句交错,无法拆分)
- 顺带:usage 的 FIELD()、codes 的 DATE_ADD/GREATEST 续期、nodes 的
  UNIX_TIMESTAMP、NULLIF 等 MySQL 专属构造一并退回 Go/可移植写法

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

2026-06-18 00:01:26 +08:00

wangjia

4783f3e32e

feat(nodes): 节点生命周期状态机 [tsk_aG4yOS90inF_]

实现 Lifecycle 类型及其全部公开方法，覆盖 6 个状态迁移动作：
MarkProbing / MarkUp / MarkDraining / MarkDown / MarkDestroyed /
MarkBlockedSuspect。每次合法迁移在同一个 SQL 事务中原子执行
UPDATE nodes + INSERT node_events + BumpVersion；MarkDestroyed
事务提交后异步调用 mtls.CRL.Revoke() 并清除 Redis 负载缓存与
命令队列键。配套集成测试覆盖 5 类场景（合法迁移、非法迁移、
并发写、后置钩子、blocked_suspect 幂等），全部通过。

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

2026-06-15 23:49:45 +08:00

2 Commits