xgrpc

Documentation

Index

• Variables
• func GrpcMessageProducer(ctx context.Context, msg string, level zapcore.Level, err error, ...)
• func GrpcRecoveryHandlerFunc(ctx context.Context, p interface{}) (err error)
• func PayloadStreamClientInterceptor(zapLogger *bzap.ZapLogger) grpc.StreamClientInterceptor
• func PayloadStreamServerInterceptor(zapLogger *bzap.ZapLogger) grpc.StreamServerInterceptor
• func PayloadUnaryClientInterceptor(zapLogger *bzap.ZapLogger) grpc.UnaryClientInterceptor
• func PayloadUnaryServerInterceptor(zapLogger *bzap.ZapLogger) grpc.UnaryServerInterceptor

Variables

var (
	SystemField                           = zap.String("system", "grpc")
	ServerField                           = zap.String("span.kind", "server")
	ClientField                           = zap.String("span.kind", "client")
	JsonPbMarshaller blog.JsonPbMarshaler = &jsonpb.Marshaler{}
)

Functions

func GrpcMessageProducer

func GrpcMessageProducer(ctx context.Context, msg string, level zapcore.Level, err error, fields []zapcore.Field)

func GrpcRecoveryHandlerFunc

func GrpcRecoveryHandlerFunc(ctx context.Context, p interface{}) (err error)

func PayloadStreamClientInterceptor

func PayloadStreamClientInterceptor(zapLogger *bzap.ZapLogger) grpc.StreamClientInterceptor

PayloadStreamClientInterceptor 流拦截器，用于记录客户端请求和响应

func PayloadStreamServerInterceptor

func PayloadStreamServerInterceptor(zapLogger *bzap.ZapLogger) grpc.StreamServerInterceptor

PayloadStreamServerInterceptor 流拦截器，用于记录服务端请求和响应

func PayloadUnaryClientInterceptor

func PayloadUnaryClientInterceptor(zapLogger *bzap.ZapLogger) grpc.UnaryClientInterceptor

PayloadUnaryClientInterceptor 一元拦截器，用于记录客户端端请求和响应

func PayloadUnaryServerInterceptor

func PayloadUnaryServerInterceptor(zapLogger *bzap.ZapLogger) grpc.UnaryServerInterceptor

PayloadUnaryServerInterceptor 一元服务器拦截器，用于记录服务端请求和响应