internal

Nov 10, 2022

Changes in this version

+ func InitLogger()

+ func WithStreamClientInterceptors(interceptors ...grpc.StreamClientInterceptor) grpc.DialOption

+ func WithStreamServerInterceptors(interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption

+ func WithUnaryClientInterceptors(interceptors ...grpc.UnaryClientInterceptor) grpc.DialOption

+ func WithUnaryServerInterceptors(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption

+ type Client interface

+ Conn func() *grpc.ClientConn

+ func NewClient(target string, opts ...ClientOption) (Client, error)

+ type ClientOption func(options *ClientOptions)

+ func WithDialOption(opt grpc.DialOption) ClientOption

+ func WithNonBlock() ClientOption

+ func WithStreamClientInterceptor(interceptor grpc.StreamClientInterceptor) ClientOption

+ func WithTimeout(timeout time.Duration) ClientOption

+ func WithTransportCredentials(creds credentials.TransportCredentials) ClientOption

+ func WithUnaryClientInterceptor(interceptor grpc.UnaryClientInterceptor) ClientOption

+ type ClientOptions struct

+ DialOptions []grpc.DialOption

+ NonBlock bool

+ Secure bool

+ Timeout time.Duration

+ type Logger struct

+ func (l *Logger) Error(args ...interface{})

+ func (l *Logger) Errorf(format string, args ...interface{})

+ func (l *Logger) Errorln(args ...interface{})

+ func (l *Logger) Fatal(args ...interface{})

+ func (l *Logger) Fatalf(format string, args ...interface{})

+ func (l *Logger) Fatalln(args ...interface{})

+ func (l *Logger) Info(args ...interface{})

+ func (l *Logger) Infof(format string, args ...interface{})

+ func (l *Logger) Infoln(args ...interface{})

+ func (l *Logger) V(v int) bool

+ func (l *Logger) Warning(args ...interface{})

+ func (l *Logger) Warningf(format string, args ...interface{})

+ func (l *Logger) Warningln(args ...interface{})

+ type RegisterFn func(*grpc.Server)

+ type Server interface

+ AddOptions func(options ...grpc.ServerOption)

+ AddStreamInterceptors func(interceptors ...grpc.StreamServerInterceptor)

+ AddUnaryInterceptors func(interceptors ...grpc.UnaryServerInterceptor)

+ SetName func(string)

+ Start func(register RegisterFn) error

+ StartWithListener func(ls net.Listener, register RegisterFn) error

+ func NewRpcPubServer(etcd discov.EtcdConf, listenOn string, opts ...ServerOption) (Server, error)

+ func NewRpcServer(address string, opts ...ServerOption) Server

+ type ServerOption func(options *rpcServerOptions)

+ func WithMetrics(metrics *stat.Metrics) ServerOption

+ func WithRpcHealth(health bool) ServerOption