grpc

func Init ¶

func Init() error

func LoggingStreamInterceptor ¶

func LoggingStreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

LoggingStreamInterceptor 用于记录流式RPC调用的日志

func LoggingUnaryInterceptor ¶

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

LoggingUnaryInterceptor 用于记录一元RPC调用的日志

func RecoveryStreamInterceptor ¶

func RecoveryStreamInterceptor(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)

RecoveryStreamInterceptor 处理流式RPC调用中的panic

func RecoveryUnaryInterceptor ¶

func RecoveryUnaryInterceptor(ctx context.Context, req any, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)

RecoveryUnaryInterceptor 处理一元RPC调用中的panic

func RegisterService ¶

func RegisterService(registrar RegisterServiceFunc)

RegisterService 添加一个服务注册函数，用于在服务器启动时注册服务

func RegisterStatsHandler ¶

func RegisterStatsHandler(handler stats.Handler)

RegisterStatsHandler 注册统计处理器

func Run ¶

func Run() error

Run 启动 gRPC 服务器并阻塞直到收到终止信号

func Stop ¶

func Stop()