Documentation ¶
Index ¶
- 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
- type GrpcRegisterFunc
- type NacosConsumer
- func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string, serviceIp string, ...) (provider *NacosProvider, err error)
- func (nc *NacosConsumer) GetNewTimeoutContext() (ctx context.Context, cancel context.CancelFunc)
- 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) (consumer *NacosConsumer)
- 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
- type ServiceConnection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddConsumer ¶
func DeleteConsumer ¶
func DeleteConsumer(serviceName string)
func GetServiceConn ¶
func GetServiceConn(serviceName string) (conn *grpc.ClientConn, err error)
func StartProvide ¶
在指定端口监听微服务,并将端口注册给注册中心
Types ¶
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) (consumer *NacosConsumer, err error)
func (*NacosConsumer) CreateNacosProvider ¶ added in v0.0.4
func (nc *NacosConsumer) CreateNacosProvider(foo GrpcRegisterFunc, ServiceName string, serviceIp string, metadata *map[string]string) (provider *NacosProvider, err error)
使用consumer的namingClient构建provider
func (*NacosConsumer) GetNewTimeoutContext ¶ added in v0.0.7
func (nc *NacosConsumer) GetNewTimeoutContext() (ctx context.Context, cancel context.CancelFunc)
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 CreateNacosProvider ¶
func CreateNacosProvider(foo GrpcRegisterFunc, clientConfig *constant.ClientConfig, serverConfigs *[]constant.ServerConfig, ServiceName string, serviceIp string, clusterName string, groupName string, metadata *map[string]string) (provider *NacosProvider, err error)
func (*NacosProvider) CreateNacosConsumer ¶ added in v0.0.4
func (np *NacosProvider) CreateNacosConsumer(ServiceName string, timeoutSeconds int) (consumer *NacosConsumer)
使用provider的namingClient构建consumer
func (*NacosProvider) DeregisterServices ¶
func (np *NacosProvider) DeregisterServices() (err error)
func (*NacosProvider) GetServiceName ¶
func (np *NacosProvider) GetServiceName() (serviceName string)
func (*NacosProvider) RegisterServices ¶
func (np *NacosProvider) RegisterServices(s *grpc.Server, port string) (err error)
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.