middleware

Documentation

Index

• Constants
• Variables
• func InitLogger() error
• func StreamServerLogInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
• func StreamServerOpentraceInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
• func StreamServerRecoveryInterceptor(srv interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo, ...) (err error)
• func UnaryClientOpentraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func UnaryServerLogInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func UnaryServerOpentraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• func UnaryServerRecoveryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
• type StringAble

Constants

const (
	GRPCStatusCodeKey = attribute.Key("rpc.grpc.status_code")
)

Variables

var (
	LogDir = "../log"
)

Functions

func InitLogger

func InitLogger() error

func StreamServerLogInterceptor

func StreamServerLogInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)

StreamServerRecoveryInterceptor recover

func StreamServerOpentraceInterceptor

func StreamServerOpentraceInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)

StreamServerRecoveryInterceptor recover

func StreamServerRecoveryInterceptor

func StreamServerRecoveryInterceptor(srv interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)

StreamServerRecoveryInterceptor recover

func UnaryClientOpentraceInterceptor

func UnaryClientOpentraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

func UnaryServerLogInterceptor

func UnaryServerLogInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

UnaryServerLogInterceptor log 拦截

func UnaryServerOpentraceInterceptor

func UnaryServerOpentraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

UnaryServerRecoveryInterceptor recover

func UnaryServerRecoveryInterceptor

func UnaryServerRecoveryInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

UnaryServerRecoveryInterceptor recover

Types

type StringAble

type StringAble interface {
	String() string
}

StringAble string