registry

Documentation

Index

• func SendHeartbeat(registry, addr string, duration time.Duration)
• type ServerItem
• type XzRegistry
  • func NewRegistry(timeout time.Duration) *XzRegistry
  • func (r *XzRegistry) HandleHTTP(registryPath string)
  • func (r *XzRegistry) ServeHTTP(w http.ResponseWriter, req *http.Request)

Functions

func SendHeartbeat

func SendHeartbeat(registry, addr string, duration time.Duration)

SendHeartbeat 每隔一段时间发送心跳 发送心跳的间隔时间应该小于注册中心将服务移除的时间

Types

type ServerItem

type ServerItem struct {
	Addr string
	// contains filtered or unexported fields
}

type XzRegistry

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

func NewRegistry

func NewRegistry(timeout time.Duration) *XzRegistry

func (*XzRegistry) HandleHTTP

func (r *XzRegistry) HandleHTTP(registryPath string)

func (*XzRegistry) ServeHTTP

func (r *XzRegistry) ServeHTTP(w http.ResponseWriter, req *http.Request)

简单实现 GET：返回可用的服务列表 POST：添加服务实例或者发送心跳