discovery

README

自用基于etcd的grpc服务发现

Documentation

Index

• Variables
• func AddServer(info ServiceInfo)
• func BuildPrefixKey(name, version string) string
• func GetLocalIP() (string, error)
• func GetPublicIP() (string, error)
• func Register(ctx context.Context, eCfg EtcdConfig, info *ServiceInfo)
• func RemoveServer(info ServiceInfo)
• func ServerActive(srvID uint32) bool
• func Servers() map[uint32]string
• type EtcdConfig
• type RegistryInfo
• type Resolver
  • func NewResolver(ctx context.Context, eCfg EtcdConfig, prefix string) *Resolver
  • func (r *Resolver) Build(_ resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string
• type ServerManager
  • func NewServerManager() *ServerManager
  • func (mgr *ServerManager) AddServer(srvID uint32, uuid string)
  • func (mgr *ServerManager) RemoveServer(srvID uint32, uuid string)
  • func (mgr *ServerManager) ServerActive(srvID uint32) bool
• type Service
• type ServiceInfo
• type WatchFn
• type Watcher
  • func NewWatcher(ctx context.Context, eCfg EtcdConfig, prefixFn map[string][]WatchFn) *Watcher

Variables

var Log *lg.Logger

Functions

func AddServer

func AddServer(info ServiceInfo)

func BuildPrefixKey

func BuildPrefixKey(name, version string) string

func GetLocalIP

func GetLocalIP() (string, error)

func GetPublicIP

func GetPublicIP() (string, error)

func Register

func Register(ctx context.Context, eCfg EtcdConfig, info *ServiceInfo)

Register 注册服务

func RemoveServer

func RemoveServer(info ServiceInfo)

func ServerActive

func ServerActive(srvID uint32) bool

func Servers

func Servers() map[uint32]string

Types

type EtcdConfig

type EtcdConfig struct {
	Endpoints []string `yaml:"endpoints" toml:"endpoints"`
	Username  string   `yaml:"username" toml:"username"`
	Password  string   `yaml:"password" toml:"password"`
}

type RegistryInfo

type RegistryInfo struct {
	Name         string `yaml:"name" toml:"name"`
	Version      string `yaml:"version" toml:"version"`
	Port         int    `yaml:"port" toml:"port"`
	ExternalAddr string `yaml:"external_addr" toml:"external_addr"` // 对外暴露地址
}

type Resolver

type Resolver struct {
	// contains filtered or unexported fields
}

func NewResolver

func NewResolver(ctx context.Context, eCfg EtcdConfig, prefix string) *Resolver

func (*Resolver) Build

func (r *Resolver) Build(_ resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(resolver.ResolveNowOptions)

func (*Resolver) Scheme

func (r *Resolver) Scheme() string

type ServerManager

type ServerManager struct {
	// contains filtered or unexported fields
}

ServerManager 用于读写极其极端的情况下(10000:1),读基本无锁

func NewServerManager

func NewServerManager() *ServerManager

func (*ServerManager) AddServer

func (mgr *ServerManager) AddServer(srvID uint32, uuid string)

func (*ServerManager) RemoveServer

func (mgr *ServerManager) RemoveServer(srvID uint32, uuid string)

func (*ServerManager) ServerActive

func (mgr *ServerManager) ServerActive(srvID uint32) bool

type Service

type Service struct {
	ServiceInfo *ServiceInfo
	// contains filtered or unexported fields
}

type ServiceInfo

type ServiceInfo struct {
	ID       int64          `json:"id" toml:"id"`
	Type     int64          `json:"type" toml:"type"`
	Name     string         `json:"name" toml:"name"`
	UUID     string         `json:"uuid" toml:"uuid"`
	Version  string         `json:"version" toml:"version"`
	Internal string         `json:"internal" toml:"internal"`
	External string         `json:"external" toml:"external"`
	Ext      map[string]any `json:"ext" toml:"ext"` // 新增扩展信息
}

ServiceInfo 服务信息

type WatchFn

type WatchFn func(bool, []byte)

type Watcher

type Watcher struct {
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(ctx context.Context, eCfg EtcdConfig, prefixFn map[string][]WatchFn) *Watcher