Versions in this module Expand all Collapse all v0 v0.1.0 Aug 22, 2023 Changes in this version + const UnaryClientMiddlewarePayloadLogger + const UnaryClientMiddlewareRetry + const UnaryClientMiddlewareTag + const UnaryClientMiddlewareTracer + const UnaryClientMiddlewareZaplog + const UnaryServerMiddlewareEventLogger + const UnaryServerMiddlewareMetrics + const UnaryServerMiddlewarePayloadLogger + const UnaryServerMiddlewareRecovery + const UnaryServerMiddlewareTag + const UnaryServerMiddlewareTracer + const UnaryServerMiddlewareZapLog + var DefaultOptions = Options + func EventLoggingUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func MetricsUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func New(spf ServerProviderFunc) service.ModuleProvider + func PayloadUnaryClientInterceptor(options map[string]interface{}) grpc.UnaryClientInterceptor + func PayloadUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func PayloadUnaryServerInterceptorWithUUID(options map[string]interface{}) grpc.UnaryServerInterceptor + func RecoveryUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func RetryClientInterceptor(options map[string]interface{}) grpc.UnaryClientInterceptor + func TagUnaryClientInterceptor(options map[string]interface{}) grpc.UnaryClientInterceptor + func TagUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func TracerClientInterceptor(options map[string]interface{}) grpc.UnaryClientInterceptor + func TracerUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + func ZapUnaryClientInterceptor(options map[string]interface{}) grpc.UnaryClientInterceptor + func ZapUnaryServerInterceptor(options map[string]interface{}) grpc.UnaryServerInterceptor + type ConnManager struct + func NewConnManager(dialer *Dialer) *ConnManager + func (cm *ConnManager) Dial(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error) + func (cm *ConnManager) DialWithSelector(ctx context.Context, serviceName string, selector resolver.Selector, ...) (*grpc.ClientConn, error) + type Dialer struct + CAFile string + CertFile string + EnableClientAuth bool + EnableTLS bool + EtcdClient *etcd.Client + HostName string + KeyFile string + Logger *zap.Logger + ServerName string + Tracer opentracing.Tracer + UnaryClientMiddlewares []UnaryClientMiddleware + func NewDialer(opts DialerOptions) (*Dialer, error) + func (d *Dialer) DialService(ctx context.Context, servicePath string, opts ...grpc.DialOption) (*grpc.ClientConn, error) + func (d *Dialer) DialWithSelector(ctx context.Context, target string, selector resolver.Selector, ...) (*grpc.ClientConn, error) + type DialerOptions struct + CAFile string + CertFile string + EnableClientAuth bool + EnableTLS bool + EtcdClient *etcd.Client + KeyFile string + Logger *zap.Logger + ServerName string + Tracer opentracing.Tracer + UnaryClientMiddlewares []UnaryClientMiddleware + type GRPCServer interface + Register func(*grpc.Server) + type ModuleConfig struct + CloseTimeout int64 + type Options struct + UnaryClientMiddlewares []UnaryClientMiddleware + UnaryServerMiddlewares []UnaryServerMiddleware + func (o *Options) AddUnaryClientMiddlewareBefore(name UnaryClientMiddlewareName, middleware UnaryClientMiddleware) + func (o *Options) AddUnaryServerMiddlewareBefore(name UnaryServerMiddlewareName, middleware UnaryServerMiddleware) + type ServerProviderFunc func(driver service.ModuleDriver) (GRPCServer, error) + type ServiceDialer interface + DialService func(ctx context.Context, serviceName string, opts ...grpc.DialOption) (*grpc.ClientConn, error) + DialWithSelector func(ctx context.Context, target string, selector resolver.Selector, ...) (*grpc.ClientConn, error) + type UnaryClientInterceptor func(options map[string]interface{}) grpc.UnaryClientInterceptor + type UnaryClientMiddleware struct + Interceptor UnaryClientInterceptor + Name UnaryClientMiddlewareName + type UnaryClientMiddlewareName string + type UnaryServerInterceptor func(options map[string]interface{}) grpc.UnaryServerInterceptor + type UnaryServerMiddleware struct + Interceptor UnaryServerInterceptor + Name UnaryServerMiddlewareName + type UnaryServerMiddlewareName string + type UnaryServerMiddlewares []UnaryServerMiddleware
Go to main page