registry

Documentation

Index

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

Variables

var DefaultGeeRegistry = NewGeeRegistry(defaultAlive)

Functions

func HandleHTTP

func HandleHTTP()

default HandleHTTP

func HeartBeat

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

Heartbeat send a heartbeat message every once in a while it's a helper function for a server to register or send heartbeat

Types

type GeeRegistry

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

GeeRegistry is a simple register center, provide following functions. add a server and receive heartbeat to keep it alive. returns all alive servers and delete dead servers sync simultaneously.

func NewGeeRegistry

func NewGeeRegistry(timeout time.Duration) *GeeRegistry

func (*GeeRegistry) HandleHTTP

func (r *GeeRegistry) HandleHTTP(registryPath string)

func (*GeeRegistry) ServeHTTP

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

run at /geerpc/registry all info is in httpHead

type ServerItem

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

means a server