seqlog

bourdon/seqlog

Fork 0

Commit Graph

Author	SHA1	Message	Date
bourdon	bcc328b129	重构：TopicProcessor 状态管理系统与 Reset 方法优化新增功能： - 添加 ProcessorState 状态类型（Idle/Starting/Running/Stopping/Stopped/Resetting/Error） - 添加 ProcessorStatus 结构体和状态管理方法（GetState/GetStatus/setState） - 实现状态转换逻辑和访问控制（CanWrite/CanQuery） - 新增 CanReset() 方法检查是否可执行重置操作 Reset 方法优化： - 重写 Reset() 方法，不再停止 processor - 只有在无待处理记录时才能执行重置 - 进入 Resetting 状态期间阻止所有读写操作 - 重置后自动恢复到之前的运行状态 - 正确关闭并重置 cursor 和 stats 组件 - 调整执行顺序：先关闭组件，再删除文件，后重新初始化错误处理增强： - 添加 ErrProcessorResetting 和 ErrInvalidState 错误类型 - 添加 EventStateChanged 事件类型 - 修复 writer/index 为 nil 时的空指针问题 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>	2025-10-04 18:56:52 +08:00
bourdon	6862de12ff	新增：统一的错误类型系统 (errors.go) 主要功能： - 定义哨兵错误（Sentinel Errors）：ErrNilParameter, ErrInvalidCount, ErrInvalidRange, ErrAlreadyRunning, ErrNotFound, ErrCRCMismatch 等 - 实现结构化错误类型：TopicError, FileError, IndexError, ValidationError - 提供错误检查辅助函数：IsTopicNotFound, IsIndexOutOfRange, IsCRCMismatch - 支持 errors.Is 和 errors.As 进行错误判断更新相关文件使用新错误类型： - cursor.go: 使用 ValidationError 和 ErrCRCMismatch - index.go: 使用 IndexError 处理索引越界 - query.go: 使用 ValidationError 验证参数 - seqlog_manager.go: 使用 TopicError 和 ErrAlreadyRegistered - topic_processor.go: 使用 ErrAlreadyRunning 和 ErrInvalidConfig 测试覆盖： - errors_test.go 提供完整的错误类型测试 - 所有现有测试继续通过使用示例： ```go // 检查 topic 是否存在 if IsTopicNotFound(err) { // 处理 topic 不存在的情况 } // 检查索引越界 if IsIndexOutOfRange(err) { var indexErr *IndexError errors.As(err, &indexErr) fmt.Printf("index %d out of range\n", indexErr.Index) } ``` 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude <noreply@anthropic.com>	2025-10-04 01:56:22 +08:00

Author

SHA1

Message

Date

bourdon

bcc328b129

重构：TopicProcessor 状态管理系统与 Reset 方法优化

新增功能：
- 添加 ProcessorState 状态类型（Idle/Starting/Running/Stopping/Stopped/Resetting/Error）
- 添加 ProcessorStatus 结构体和状态管理方法（GetState/GetStatus/setState）
- 实现状态转换逻辑和访问控制（CanWrite/CanQuery）
- 新增 CanReset() 方法检查是否可执行重置操作

Reset 方法优化：
- 重写 Reset() 方法，不再停止 processor
- 只有在无待处理记录时才能执行重置
- 进入 Resetting 状态期间阻止所有读写操作
- 重置后自动恢复到之前的运行状态
- 正确关闭并重置 cursor 和 stats 组件
- 调整执行顺序：先关闭组件，再删除文件，后重新初始化

错误处理增强：
- 添加 ErrProcessorResetting 和 ErrInvalidState 错误类型
- 添加 EventStateChanged 事件类型
- 修复 writer/index 为 nil 时的空指针问题

🤖 Generated with [Claude Code](https://claude.com/claude-code)

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

2025-10-04 18:56:52 +08:00

bourdon

6862de12ff

新增：统一的错误类型系统 (errors.go)

主要功能：
- 定义哨兵错误（Sentinel Errors）：ErrNilParameter, ErrInvalidCount,
  ErrInvalidRange, ErrAlreadyRunning, ErrNotFound, ErrCRCMismatch 等
- 实现结构化错误类型：TopicError, FileError, IndexError, ValidationError
- 提供错误检查辅助函数：IsTopicNotFound, IsIndexOutOfRange, IsCRCMismatch
- 支持 errors.Is 和 errors.As 进行错误判断

更新相关文件使用新错误类型：
- cursor.go: 使用 ValidationError 和 ErrCRCMismatch
- index.go: 使用 IndexError 处理索引越界
- query.go: 使用 ValidationError 验证参数
- seqlog_manager.go: 使用 TopicError 和 ErrAlreadyRegistered
- topic_processor.go: 使用 ErrAlreadyRunning 和 ErrInvalidConfig

测试覆盖：
- errors_test.go 提供完整的错误类型测试
- 所有现有测试继续通过

使用示例：
```go
// 检查 topic 是否存在
if IsTopicNotFound(err) {
    // 处理 topic 不存在的情况
}

// 检查索引越界
if IsIndexOutOfRange(err) {
    var indexErr *IndexError
    errors.As(err, &indexErr)
    fmt.Printf("index %d out of range\n", indexErr.Index)
}
```

🤖 Generated with [Claude Code](https://claude.com/claude-code)

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

2025-10-04 01:56:22 +08:00

2 Commits