xgrpc

Documentation

Index

• func AdditionalUnaryServerOptWithBase(item ...grpc.UnaryServerInterceptor) []grpc.UnaryServerInterceptor
• func ClientUnaryInvokerLog() grpc.UnaryClientInterceptor
• func ClientUnaryOpentracingAndTimeOut(servername string, timeout time.Duration) grpc.UnaryClientInterceptor
• func Close()
• func CreateWithStreamServerChain(item ...grpc.StreamServerInterceptor) grpc.ServerOption
• func CreateWithUnaryServerChain(item ...grpc.UnaryServerInterceptor) grpc.ServerOption
• func GrpcConn(addr string) (*grpc.ClientConn, error)
• func ServerUnaryInvokerLog() grpc.UnaryServerInterceptor
• func ServerUnaryOpentracing(tracer opentracing.Tracer) grpc.UnaryServerInterceptor
• func ServerUnaryRecoveryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func TLSServerOpt(tlsCert, tlsKey, caCert string) grpc.ServerOption

Functions

func AdditionalUnaryServerOptWithBase

func AdditionalUnaryServerOptWithBase(item ...grpc.UnaryServerInterceptor) []grpc.UnaryServerInterceptor

func ClientUnaryInvokerLog

func ClientUnaryInvokerLog() grpc.UnaryClientInterceptor

GetInvokerLog grpc client call log

func ClientUnaryOpentracingAndTimeOut

func ClientUnaryOpentracingAndTimeOut(servername string, timeout time.Duration) grpc.UnaryClientInterceptor

GetUnaryTimeOut

func Close

func Close()

func CreateWithStreamServerChain

func CreateWithStreamServerChain(item ...grpc.StreamServerInterceptor) grpc.ServerOption

CreateWithStreamServerChain WithStreamServerChain

func CreateWithUnaryServerChain

func CreateWithUnaryServerChain(item ...grpc.UnaryServerInterceptor) grpc.ServerOption

CreateWithUnaryServerChain WithUnaryServerChain

func GrpcConn

func GrpcConn(addr string) (*grpc.ClientConn, error)

func ServerUnaryInvokerLog

func ServerUnaryInvokerLog() grpc.UnaryServerInterceptor

GetServerUnaryInvokerLog grpc server call log

func ServerUnaryOpentracing

func ServerUnaryOpentracing(tracer opentracing.Tracer) grpc.UnaryServerInterceptor

ServerUnaryOpentracing rewrite server's interceptor with open tracing

func ServerUnaryRecoveryInterceptor

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

ServerUnaryRecoveryInterceptor RecoveryInterceptor,

func TLSServerOpt

func TLSServerOpt(tlsCert, tlsKey, caCert string) grpc.ServerOption

TLSServerOpt TLSServerOpt