Versions in this module Expand all Collapse all v1 v1.4.4 Nov 9, 2022 v1.4.3 Nov 9, 2022 Changes in this version + 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 + 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
Go to main page