discovery

Sep 30, 2019

Changes in this version

type EtcdArgs

+ func (args *EtcdArgs) SplitEndPoints()

Sep 30, 2019

Changes in this version

+ type ClientArgs struct

+ func (args *ClientArgs) CreateGRpcClient() (*GRpcClient, error)

+ type EtcdArgs struct

+ Etcd string

+ func (args *EtcdArgs) EndPoints() []string

type GRpcHost

+ func NewGRpcHost(etcd []string, ip string, port uint16) *GRpcHost

+ type HostArgs struct

+ IP string

+ Port uint

+ func (args *HostArgs) CreateGRpcHost() *GRpcHost

+ func (args *HostArgs) SetupFirstLocalIp()

Sep 27, 2019

Changes in this version

+ var ErrInvalidIP = errors.New("invalid ip")

Sep 26, 2019

Changes in this version

+ const ConfigPrefix

+ const NodePrefix

+ const RootPrefix

+ const ServicePrefix

+ var ErrNoAvailableGrpcHostConnected = errors.New("no available grpc host connected")

+ var ErrNoServiceFound = errors.New("no service with specified name found on cluster")

+ var EtcdOpTimeout = time.Duration(5) * time.Second

+ var GRpcTimeout = time.Duration(5) * time.Second

+ var LogRoot = log.NewRoot(log.NewStdOutput())

+ var LogTagPrefix = "discovery"

+ type FPickTTL func(size int, getTTL func(index int) int64) int

+ var PickTTL FPickTTL = etcdDefaultPick

+ type GRpcClient struct

+ func NewGRpcClient(etcd []string) (*GRpcClient, error)

+ func (client *GRpcClient) Close() error

+ func (client *GRpcClient) GetService(name string) (*grpc.ClientConn, error)

+ type GRpcHost struct

+ func NewGRpcService(etcd []string, ip string, port uint16) *GRpcHost

+ func (s *GRpcHost) AddService(desc *grpc.ServiceDesc, impl interface{})

+ func (s *GRpcHost) Serve() error

+ func (s *GRpcHost) SetTimeout(seconds int64)