impl

package

v1.1.22 Latest Latest Go to latest Published: May 19, 2026 License: MIT Imports: 12 Imported by: 0

Details

Package impl 实现 gRPC CommonWorker：P=0 明文；s=SHA256(规范字段)；e=ML-DSA.Sign(SHA256(规范字段))；Cipher 为 *crypto.MLDSA87Object。

This section is empty.

This section is empty.

func ClearAllHandlers()

ClearAllHandlers 清空所有已注册的业务处理器注意: 此方法主要用于测试场景，在生产环境中应谨慎使用

func GetAllHandlers() map[string]HandlerEntry

GetAllHandlers 获取所有已注册的业务处理器返回: 包含所有路由和对应处理器映射的map副本，防止外部修改原始数据

func GetHandler(router string) (RequestHandler, RequestConstructor)

GetHandler 根据路由获取对应的业务处理器 router: 路由标识符，用于匹配具体的业务处理逻辑返回: 如果找到对应的处理器则返回，否则返回nil GetHandler 获取：返回处理器 + 构造函数（确保非 nil）

func PackAny(data proto.Message) (*anypb.Any, error)

func RPCXRequestDigestS(d, n []byte, t, p int64, r string, u int64) []byte

func RPCXResponseDigestS(d, n []byte, t, p int64, r string, u, c int64, m string) []byte

RPCXResponseDigestS 响应体摘要：SHA256( r|base64(d)|base64(n)|t|p|u|c|m )；e 对该摘要做 ML-DSA 签名。

func SetHandler(router string, handler RequestHandler, constructor RequestConstructor)

SetHandler 注册：同时传入处理器 + 构造函数

func UnpackAny(anyData *anypb.Any, target proto.Message) error

type CommonWorker struct {
	pb.UnimplementedCommonWorkerServer
	ConfigProvider ConfigProvider // 配置提供者接口
}

func (self *CommonWorker) Do(ctx context.Context, req *pb.CommonRequest) (*pb.CommonResponse, error)

func (self *CommonWorker) GetCipher() map[int64]fgocrypto.Cipher

func (self *CommonWorker) GetLocalCache() cache.Cache

func (self *CommonWorker) GetRedisCache() cache.Cache

type ConfigProvider interface {
	GetCipher() map[int64]fgocrypto.Cipher
	GetLocalCache() cache.Cache
	GetRedisCache() cache.Cache
}

ConfigProvider 配置提供者接口

type HandlerEntry struct {
	Handler     RequestHandler     // 原业务处理器
	Constructor RequestConstructor // 请求对象构造函数（new object 方法）
}

2. 定义路由项：绑定处理器 + 构造函数

type RequestConstructor func() proto.Message

1. 定义请求对象构造函数：负责返回非 nil 的业务请求实例（核心）替代原来的 RequestType()，编译期保证返回非 nil

type RequestHandler func(ctx context.Context, req proto.Message) (proto.Message, error)