middleware

Documentation

Index

• Constants
• func InitLogger(c *zlog.Config) (func() error, error)
• func StreamClientCircuitbreakerInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, 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 UnaryClientCircuitbreakerInterceptor(ctx context.Context, method string, req, reply interface{}, ...) 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")
)

Functions

func InitLogger

func InitLogger(c *zlog.Config) (func() error, error)

func StreamClientCircuitbreakerInterceptor

func StreamClientCircuitbreakerInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

StreamServerRecoveryInterceptor recover

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 UnaryClientCircuitbreakerInterceptor

func UnaryClientCircuitbreakerInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

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