registry

Documentation

Index

• func HttpReg(svrName string, ipAddr string, port int) string
• func HttpUnReg(svrID string)
• func InitConsul(consulIp string, consulPort int) (err error)
• func RandomStr(len int) string
• type ConsulRegistry
  • func (cr ConsulRegistry) ServerDiscover(serverName string) (ServerMataInfo, error)
  • func (cr ConsulRegistry) ServerRegistry(ServerMataInfo) error
• type HealthImpl
  • func (h *HealthImpl) Check(ctx context.Context, req *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (h *HealthImpl) Watch(req *grpc_health_v1.HealthCheckRequest, w grpc_health_v1.Health_WatchServer) error
• type Registry
• type ServerMataInfo

Functions

func HttpReg

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

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

func HttpUnReg

func HttpUnReg(svrID string)

HttpUnReg 服务卸载

func InitConsul

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

func RandomStr

func RandomStr(len int) string

Types

type ConsulRegistry

type ConsulRegistry struct {
}

func (ConsulRegistry) ServerDiscover

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

func (ConsulRegistry) ServerRegistry

func (cr ConsulRegistry) ServerRegistry(ServerMataInfo) error

type HealthImpl

type HealthImpl struct{}

HealthImpl 健康检查实现

func (*HealthImpl) Check

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

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

func (*HealthImpl) Watch

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

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

type Registry

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

type ServerMataInfo

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