errors

func GRPCStreamServerInterceptor ¶

func GRPCStreamServerInterceptor(srv any, ss grpc.ServerStream, _ *grpc.StreamServerInfo, handler grpc.StreamHandler) error

GRPCStreamServerInterceptor 与 GRPCUnaryServerInterceptor 对应的 stream 版本。

func GRPCUnaryServerInterceptor ¶

func GRPCUnaryServerInterceptor(ctx context.Context, req any, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (any, error)

GRPCUnaryServerInterceptor 将 handler 返回的 *Status 自动转换为 gRPC status error。 业务代码直接 return errors.NotFound("user not found")，无需手动调 ToGRPC。

func HTTPMiddlewareErrorHandler ¶

func HTTPMiddlewareErrorHandler(next http.Handler) http.Handler

HTTPMiddlewareErrorHandler 返回一个 HTTP 中间件，将 handler 产生的 *Status 错误 转换为结构化 JSON 响应。handler 通过 ctx 中的 errorSink 写入错误。

使用场景：handler 无法直接返回 error（net/http 签名限制）， 可通过 SetError(ctx, err) 写入，中间件统一处理。

func MyHandler(w http.ResponseWriter, r *http.Request) {
    user, err := svc.GetUser(r.Context(), id)
    if err != nil {
        errors.SetError(r.Context(), err)
        return
    }
    json.NewEncoder(w).Encode(user)
}

func Register ¶

func Register(code Code, httpStatus int, grpcCode uint32, defaultMsg string)

Register 注册一个业务码的映射关系。 框架内置码在 predefined.go 中通过 init() 注册；业务方在自己的 init() 中调用。 重复注册同一个 Code 会 panic，防止无声覆盖。

func SetError ¶

func SetError(ctx context.Context, err error)

SetError 将错误写入 ctx 的 errorSink，供 HTTPMiddlewareErrorHandler 读取。 若 ctx 没有 sink（未经过 HTTPMiddlewareErrorHandler 包装），调用是无操作。

func ToGRPC ¶

func ToGRPC(s *Status) error

ToGRPC 将 *Status 转换为 gRPC status error，供 gRPC handler 直接返回。

func WriteHTTP ¶

func WriteHTTP(w http.ResponseWriter, s *Status)

WriteHTTP 将 *Status 序列化为 JSON 写入 http.ResponseWriter。 Content-Type 固定为 application/json。