internal

Index ¶

• type Client
• • func NewClient(target string, middlewares ClientMiddlewaresConf, opts ...ClientOption) (Client, error)
• type ClientMiddlewaresConf
• type ClientOption
• • 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
• type Logger
• • 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(args ...any)
  • func (l *Logger) Infof(format string, args ...any)
  • func (l *Logger) Infoln(args ...any)
  • func (l *Logger) V(v int) bool
  • func (l *Logger) Warning(args ...any)
  • func (l *Logger) Warningf(format string, args ...any)
  • func (l *Logger) Warningln(args ...any)
• type RegisterFn
• type Server
• • func NewRpcPubServer(etcd discov.EtcdConf, listenOn string, middlewares ServerMiddlewaresConf, ...) (Server, error)
  • func NewRpcServer(addr string, middlewares ServerMiddlewaresConf, opts ...ServerOption) Server
• type ServerMiddlewaresConf
• type ServerOption
• • func WithMetrics(metrics *stat.Metrics) ServerOption
  • func WithRpcHealth(health bool) ServerOption
• type StatConf