services

README

#services a drop-in services discovery library based on etcd

pb.go产生方式

protoc ./*.proto --go_out=plugins=grpc:./

#etcd目录结构 etcd目录结构采用 http://gliderlabs.com/registrator/latest/ 提供的结构:

/backends/service_xxx/service_id ---> ip:port

调用 Init(..) 将服务发现限定在给定范围

Documentation

Index

• Constants
• func AllService(path string) map[string]*grpc.ClientConn
• func GetService(path string) (*grpc.ClientConn, string)
• func GetServiceWithHash(path string, value int) (*grpc.ClientConn, string)
• func GetServiceWithId(path string, id string) *grpc.ClientConn
• func Init(root string, hosts, names []string)
• func RegisterCallback(path string, callback chan string)

Constants

const (
	DEFAULT_TIMEOUT = 5 * time.Second
	DEFAULT_RETRIES = 6 // failed connection retries (for every ten seconds)
)

Functions

func AllService

func AllService(path string) map[string]*grpc.ClientConn

func GetService

func GetService(path string) (*grpc.ClientConn, string)

/////////////////////////////////////////////////////////////// Wrappers

func GetServiceWithHash

func GetServiceWithHash(path string, value int) (*grpc.ClientConn, string)

func GetServiceWithId

func GetServiceWithId(path string, id string) *grpc.ClientConn

func Init

func Init(root string, hosts, names []string)

Init() ***MUST*** be called before using

func RegisterCallback

func RegisterCallback(path string, callback chan string)