registry

Documentation

Index

• Variables
• func HandleHTTP()
• func Heartbeat(registry, addr string, duration time.Duration)
• type DrpcRegistry
  • func New(timeout time.Duration) *DrpcRegistry
  • func (r *DrpcRegistry) HandleHTTP(registryPath string)
  • func (r *DrpcRegistry) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type ServerItem

Variables

var DefaultDrpcRegister = New(defaultTimeOut)

Functions

func HandleHTTP

func HandleHTTP()

func Heartbeat

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

Heartbeat 提供 HeartBeat 方法，便于服务启动时定时向注册中心发送心跳，默认周期比注册中心设置过期的时间少1min

Types

type DrpcRegistry

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

func New

func New(timeout time.Duration) *DrpcRegistry

func (*DrpcRegistry) HandleHTTP

func (r *DrpcRegistry) HandleHTTP(registryPath string)

HandleHTTP registers a HTTP handler for DrpcRegistry messages on registryPath

func (*DrpcRegistry) ServeHTTP

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

run at /_drpc_/registry

type ServerItem

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