discover

服务发现

package main

import (
    "github.com/joshqu1985/fireman/configor"
    "github.com/joshqu1985/fireman/discover"
    "github.com/joshqu1985/protos/sdk"
)

type Config struct {
    Name     string
    Port     int
    Discover discover.Config
}

var (
    Conf Config
)

func init() {
    if err := configor.Load("./configs/conf.toml", &Conf); err != nil {
        panic(err)
    }

    if err := discover.Init(Conf.Discover); err != nil {
        panic(err)
    }
}

func main() {
    // 注册自己
    if err := discover.Register(Conf.Name, Conf.Port); err != nil {
        panic(err)
    }

    // Resolver注入到grpc, 通过client调用Services定义的方法[board, uauth, feed]
    client := sdk.NewGrpcClient(discover.Resolver(), Conf.Discover.Resolver.Services)
}

#conf.toml
name = "uauth"
port = 18094

[discover]
    endpoints = ["127.0.0.1:2379"]        #etcd 地址
    [discover.register]
        ttl      = 10000                  # 10s
        interval = 10000                  # 10s
    [discover.resolver]
        services = ["board", "uauth", "feed"]