Versions in this module Expand all Collapse all v1 v1.7.7 Dec 24, 2024 v1.7.6 Dec 24, 2024 Changes in this version + type Client interface + Conn func() *grpc.ClientConn + func NewClient(target string, middlewares ClientMiddlewaresConf, opts ...ClientOption) (Client, error) + type ClientMiddlewaresConf struct + Breaker bool + Duration bool + Prometheus bool + Timeout bool + Trace bool + 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 ...any) + func (l *Logger) Errorf(format string, args ...any) + func (l *Logger) Errorln(args ...any) + func (l *Logger) Fatal(args ...any) + func (l *Logger) Fatalf(format string, args ...any) + func (l *Logger) Fatalln(args ...any) + func (l *Logger) Info(_ ...any) + func (l *Logger) Infof(_ string, _ ...any) + func (l *Logger) Infoln(_ ...any) + func (l *Logger) V(v int) bool + func (l *Logger) Warning(_ ...any) + func (l *Logger) Warningf(_ string, _ ...any) + func (l *Logger) Warningln(_ ...any) + type MethodTimeoutConf = serverinterceptors.MethodTimeoutConf + 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 + func NewRpcPubServer(etcd discov.EtcdConf, listenOn string, opts ...ServerOption) (Server, error) + func NewRpcServer(addr string, opts ...ServerOption) Server + type ServerMiddlewaresConf struct + Breaker bool + Prometheus bool + Recover bool + Stat bool + StatConf StatConf + Trace bool + type ServerOption func(options *rpcServerOptions) + func WithRpcHealth(health bool) ServerOption + type StatConf = serverinterceptors.StatConf