micro

Jun 16, 2021

Changes in this version

+ func RecoveryInterceptor() grpc_recovery.Option

Apr 14, 2021

Changes in this version

type NacosConsumer

+ func (nc *NacosConsumer) GetBaseConsumer() *Consumer

type NacosProvider

+ func (np *NacosProvider) GetBaseProvider() *Provider

Apr 14, 2021

Changes in this version

type Consumer

+ func CreateNacosConsumerWithProvider(ServiceName string, timeoutSeconds int, np *NacosProvider) *Consumer

type Provider

+ func CreateNacosProviderWithConsumer(foo GrpcRegisterFunc, ServiceName string, serviceIp string, ...) (*Provider, error)

Apr 14, 2021

Changes in this version

+ func CircuitBreakerIncr(circuitController *CircuitController) grpc_zap.Option

+ type CircuitConfig struct

+ CircuitBaseCount int64

+ CircuitDuration time.Duration

+ RetryDuration time.Duration

+ TimeoutDuration time.Duration

+ TimeoutThresholdRate float64

+ type CircuitController struct

+ CircuitConfig CircuitConfig

+ func (c *CircuitController) AddReq(num int64) int64

+ func (c *CircuitController) AddTimeout(num int64) int64

+ func (c *CircuitController) Limit() bool

type Consumer

+ func CreateConsumer(iConsumer IConsumer) (*Consumer, error)

+ func (c *Consumer) GetNewTimeoutContext() (ctx context.Context, cancel context.CancelFunc)

+ type IConsumer interface

+ GetServiceConnection func() (conn *grpc.ClientConn, err error)

+ GetServiceName func() (serviceName string, err error)

+ Stop func() (err error)

+ type IProvider interface

+ DeregisterServices func() (err error)

+ GetServiceName func() (serviceName string)

+ RegisterServices func(s *grpc.Server, port string) (err error)

type Provider

+ Logger *zap.Logger

+ func CreateNacosCircuitProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, ...) (*Provider, error)

+ func CreateProvider(iProvider IProvider, CircuitConfig CircuitConfig, Logger *zap.Logger) (*Provider, error)

+ func (p *Provider) GetCircuitController() *CircuitController

Feb 7, 2021

Changes in this version

type ServiceConnection

+ func (s *ServiceConnection) GetConn() *grpc.ClientConn

+ func (s *ServiceConnection) SetConn(conn *grpc.ClientConn)

Jan 9, 2021

Changes in this version

type NacosConsumer

+ func (nc *NacosConsumer) GetNewTimeoutContext() (ctx context.Context, cancel context.CancelFunc)

+ type ServiceConnection struct

Dec 27, 2020

Changes in this version

type NacosConsumer

+ func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc) (provider *NacosProvider, err error)

type NacosProvider

+ func (np *NacosProvider) CreateNacosConsumer() (consumer *NacosConsumer)

Dec 27, 2020

Changes in this version

+ func AddConsumer(consumer Consumer) (err error)

+ func DeleteConsumer(serviceName string)

+ func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)

+ func StartProvide(provider Provider, port string) (err error)

+ func Stop()

+ type Consumer interface

+ GetServiceConnection func(serviceName string) (conn *grpc.ClientConn, err error)

+ GetServiceName func() (serviceName string, err error)

+ Stop func() (err error)

+ type GrpcRegisterFunc func(s *grpc.Server)

+ type NacosConsumer struct

+ func CreateNacosConsumer(clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ...) (consumer *NacosConsumer, err error)

+ func (nc *NacosConsumer) GetServiceConnection(serviceName string) (conn *grpc.ClientConn, err error)

+ func (nc *NacosConsumer) GetServiceName() (serviceName string, err error)

+ func (nc *NacosConsumer) Stop() (err error)

+ type NacosProvider struct

+ func CreateNacosProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, ...) (provider *NacosProvider, err error)

+ func (np *NacosProvider) DeregisterServices() (err error)

+ func (np *NacosProvider) GetServiceName() (serviceName string)

+ func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)

+ type Provider interface

+ DeregisterServices func() (err error)

+ GetServiceName func() (serviceName string)

+ RegisterServices func(s *grpc.Server, port string) (err error)