Documentation ¶
Index ¶
- func AddConsumer(consumer *Consumer) (err error)
- func CircuitBreakerIncr(circuitController *CircuitController) grpc_zap.Option
- func DeleteConsumer(serviceName string)
- func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)
- func RecoveryInterceptor() grpc_recovery.Option
- func StartProvide(provider *Provider, port string) (err error)
- func Stop()
- type CircuitConfig
- type CircuitController
- type Consumer
- type GrpcRegisterFunc
- type IConsumer
- type IProvider
- type NacosConsumer
- func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string, serviceIp string, ...) (*NacosProvider, error)
- func (nc *NacosConsumer) GetBaseConsumer() *Consumer
- func (nc *NacosConsumer) GetServiceConnection() (conn *grpc.ClientConn, err error)
- func (nc *NacosConsumer) GetServiceName() (serviceName string, err error)
- func (nc *NacosConsumer) Stop() (err error)
- type NacosProvider
- func (np *NacosProvider) CreateNacosConsumer(ServiceName string, timeoutSeconds int) *NacosConsumer
- func (np *NacosProvider) DeregisterServices() (err error)
- func (np *NacosProvider) GetBaseProvider() *Provider
- func (np *NacosProvider) GetServiceName() (serviceName string)
- func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)
- type Provider
- type ServiceConnection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddConsumer ¶
func CircuitBreakerIncr ¶ added in v0.1.1
func CircuitBreakerIncr(circuitController *CircuitController) grpc_zap.Option
超时计数器
func DeleteConsumer ¶
func DeleteConsumer(serviceName string)
func GetServiceConn ¶
func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)
func RecoveryInterceptor ¶ added in v0.2.0
func RecoveryInterceptor() grpc_recovery.Option
func StartProvide ¶
在指定端口监听微服务,并将端口注册给注册中心
Types ¶
type CircuitConfig ¶ added in v0.1.1
type CircuitController ¶ added in v0.1.1
type CircuitController struct { CircuitConfig CircuitConfig // contains filtered or unexported fields }
func (*CircuitController) AddReq ¶ added in v0.1.1
func (c *CircuitController) AddReq(num int64) int64
func (*CircuitController) AddTimeout ¶ added in v0.1.1
func (c *CircuitController) AddTimeout(num int64) int64
func (*CircuitController) Limit ¶ added in v0.1.1
func (c *CircuitController) Limit() bool
type Consumer ¶
type Consumer struct { IConsumer // contains filtered or unexported fields }
func CreateConsumer ¶ added in v0.1.1
func (*Consumer) GetNewTimeoutContext ¶ added in v0.1.1
func (c *Consumer) GetNewTimeoutContext() (ctx context.Context, cancel context.CancelFunc)
type GrpcRegisterFunc ¶
type NacosConsumer ¶
type NacosConsumer struct {
// contains filtered or unexported fields
}
func CreateNacosConsumer ¶
func CreateNacosConsumer(clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string, clusterName string, groupName string, timeoutSeconds int) (*NacosConsumer, error)
func (*NacosConsumer) CreateNacosProvider ¶ added in v0.0.4
func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string, serviceIp string, metadata *map[string]string, Logger *zap.Logger) (*NacosProvider, error)
使用consumer的namingClient构建provider
func (*NacosConsumer) GetBaseConsumer ¶ added in v0.1.5
func (nc *NacosConsumer) GetBaseConsumer() *Consumer
func (*NacosConsumer) GetServiceConnection ¶
func (nc *NacosConsumer) GetServiceConnection() (conn *grpc.ClientConn, err error)
func (*NacosConsumer) GetServiceName ¶
func (nc *NacosConsumer) GetServiceName() (serviceName string, err error)
func (*NacosConsumer) Stop ¶
func (nc *NacosConsumer) Stop() (err error)
type NacosProvider ¶
type NacosProvider struct {
// contains filtered or unexported fields
}
func CreateNacosCircuitProvider ¶ added in v0.1.1
func CreateNacosCircuitProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string, serviceIp string, clusterName string, groupName string, metadata *map[string]string, circuitConfig CircuitConfig, Logger *zap.Logger) (*NacosProvider, error)
func CreateNacosProvider ¶
func CreateNacosProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string, serviceIp string, clusterName string, groupName string, metadata *map[string]string, Logger *zap.Logger) (*NacosProvider, error)
func (*NacosProvider) CreateNacosConsumer ¶ added in v0.0.4
func (np *NacosProvider) CreateNacosConsumer(ServiceName string, timeoutSeconds int) *NacosConsumer
使用provider的namingClient构建consumer
func (*NacosProvider) DeregisterServices ¶
func (np *NacosProvider) DeregisterServices() (err error)
func (*NacosProvider) GetBaseProvider ¶ added in v0.1.5
func (np *NacosProvider) GetBaseProvider() *Provider
func (*NacosProvider) GetServiceName ¶
func (np *NacosProvider) GetServiceName() (serviceName string)
func (*NacosProvider) RegisterServices ¶
func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)
type Provider ¶
func CreateProvider ¶ added in v0.1.1
func (*Provider) GetCircuitController ¶ added in v0.1.1
func (p *Provider) GetCircuitController() *CircuitController
type ServiceConnection ¶ added in v0.0.7
type ServiceConnection struct {
// contains filtered or unexported fields
}
func (*ServiceConnection) GetConn ¶ added in v0.0.8
func (s *ServiceConnection) GetConn() *grpc.ClientConn
func (*ServiceConnection) SetConn ¶ added in v0.0.8
func (s *ServiceConnection) SetConn(conn *grpc.ClientConn)
Click to show internal directories.
Click to hide internal directories.