Versions in this module Expand all Collapse all v0 v0.4.1 Mar 7, 2022 Changes in this version + const GrpcDiscoveryPrefix + type Config struct + DialTimeout int64 + Endpoints []string + HeartTime int64 + type Discovery struct + Config Config + HeartTime int64 + func New(cfg Config) (*Discovery, error) + func (d *Discovery) Register(ctx context.Context, node Service) error + func (d *Discovery) Resolve(ctx context.Context, handlers []ResolveHandler) error + type EnventType mvccpb.Event_EventType + var DELETE EnventType = EnventType(mvccpb.DELETE) + var PUT EnventType = EnventType(mvccpb.PUT) + type Register interface + Register func(ctx context.Context, node Service) error + type ResolveHandler func(EnventType, Service) + type Resolver interface + Resolve func(ctx context.Context, handlers []ResolveHandler) error + type Service struct + AppID string + Host string + Metadata map[string]string + Name string + Port int + func (s Service) Key() string + func (s Service) Value() string + func (s Service) WatchKey() string + type Watcher interface + Shutdown func() + Watch func(string, bool, func(*clientv3.Event)) + func NewWatcher(ctx context.Context, brokers []string) (Watcher, error) + func NewWatcherWithClient(ctx context.Context, cli *clientv3.Client) Watcher