toolkit

README

toolkit

1. 泛型工具包
2. 各种框架的拓展插件、callback、可观测性等

containerx

描述：拓展的数据容器

1. 缩容机制
2. 小顶堆实现的优先队列
3. TODO：并发安全的优先队列

grpcx

描述：grpc的拓展

1. server端快捷启动封装
2. etcd作为注册中心的注册封装
3. 实现consul的resolver
4. consul作为注册中心的注册封装
5. 基于grpc的接口实现自己的权重负载均衡算法

ginx

描述：：gin中间件、统一处理error日志

1. 日志中间件
   • 记录请求方法、请求路径、请求体、响应体、耗时、响应码
2. 带日志的recovery中间件
3. 限流中间件
   • 使用本库ratelimit的方法封装成gin的中间件
4. prometheus埋点
   • 采集当前活跃请求数
   • 采集http接口响应时间
   • 错误码统计(在第5条的统一处理中埋点)
5. 统一处理请求体bind/错误日志打印/ctx中取值

gormx

1. 使用gorm的callback 采集增删改查的sql响应时间提供给prometheus采集
2. 利用callback实现的gorm plugin ，用来替换gorm自带的logger

ratelimit

1. 使用滑动窗口算法的lua脚本实现限流接口

redisx

实现redis的hook接口

1. prometheus埋点redis命令的响应时间
2. opentelemetry 的 trace 埋点

saramax

实现sarama的ConsumerGroupHandler接口

1. 单个消费就提交：ConsumeClaim中封装解析消息体、记录日志、提交消费
2. 批量消费提交：ConsumeClaim中封装解析消息体、记录日志、提交消费

syncx

1. 泛型封装atomic.Value（load方法性能比原生的差1倍，其他方法只差一点点可忽略不计）

zapx

1. 封装uber的zap库