registry

package

v0.0.0-...-854a178 Latest Latest Go to latest Published: Mar 20, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func HttpReg(svrName string, ipAddr string, port int) string

HttpReg 服务注册时候提供一个健康检查地址，支持http，grpc

func HttpUnReg(svrID string)

HttpUnReg 服务卸载

func InitConsul(consulIp string, consulPort int) (err error)

func RandomStr(len int) string

type ConsulRegistry struct {
}

func (cr ConsulRegistry) ServerDiscover(serverName string) (ServerMataInfo, error)

func (cr ConsulRegistry) ServerRegistry(ServerMataInfo) error

type HealthImpl struct{}

HealthImpl 健康检查实现

func (h *HealthImpl) Check(
	ctx context.Context,
	req *grpc_health_v1.HealthCheckRequest,
) (*grpc_health_v1.HealthCheckResponse, error)

Check 实现健康检查接口，这里直接返回健康状态

func (h *HealthImpl) Watch(req *grpc_health_v1.HealthCheckRequest, w grpc_health_v1.Health_WatchServer) error

Watch 让HealthImpl实现RegisterHealthServer内部的interface接口

type Registry interface {
	ServerRegistry(ServerMataInfo) error
	ServerDiscover(serverName string) (ServerMataInfo, error)
}

type ServerMataInfo struct {
	// contains filtered or unexported fields
}