serverregistrydiscover

Documentation

Index

• Variables
• func EtcdDial(c *clientv3.Client, service string) (*grpc.ClientConn, error)
• func Register(service string, addr string, stop chan error) error

Variables

var (
	DefaultEtcdConfig = clientv3.Config{
		Endpoints:   []string{"localhost:2379"},
		DialTimeout: 5 * time.Second,
	}
)

register 模块提供服务注册至 etcd 的能力

Functions

func EtcdDial

func EtcdDial(c *clientv3.Client, service string) (*grpc.ClientConn, error)

EtcdDial 向 grpc 请求一个服务 通过提供一个 etcd client 和 service name 即可获取连接

func Register

func Register(service string, addr string, stop chan error) error

Register 注册一个服务至 etcd 注意 Register 将不会 return（如果没有 error 的话）