Documentation ¶
Index ¶
- func JSONDecode(val string) (*registry.ServiceNode, error)
- func JSONEncode(node *registry.ServiceNode) (string, error)
- func NewRegistry(opts ...RegistrarOption) (registry.Registrar, error)
- type DiscoverOption
- type EtcdDiscovery
- func (s *EtcdDiscovery) Close() error
- func (s *EtcdDiscovery) DelServiceList(key string)
- func (s *EtcdDiscovery) GetLoadBalance() string
- func (s *EtcdDiscovery) GetServices() []*registry.ServiceNode
- func (s *EtcdDiscovery) SetServiceList(key string, node *registry.ServiceNode)
- func (s *EtcdDiscovery) WatchService(ctx context.Context) error
- type EtcdRegistrar
- type RegistrarOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JSONDecode ¶
func JSONDecode(val string) (*registry.ServiceNode, error)
func JSONEncode ¶
func JSONEncode(node *registry.ServiceNode) (string, error)
func NewRegistry ¶
func NewRegistry(opts ...RegistrarOption) (registry.Registrar, error)
NewRegistry
Types ¶
type DiscoverOption ¶
type DiscoverOption func(*EtcdDiscovery)
func WithDiscoverClient ¶
func WithDiscoverClient(cli *clientv3.Client) DiscoverOption
func WithDiscoverConfig ¶
func WithDiscoverConfig(config *registry.DiscoveryConfig) DiscoverOption
type EtcdDiscovery ¶
type EtcdDiscovery struct {
// contains filtered or unexported fields
}
EtcdDiscovery 服务发现
func (*EtcdDiscovery) DelServiceList ¶
func (s *EtcdDiscovery) DelServiceList(key string)
DelServiceList
func (*EtcdDiscovery) GetLoadBalance ¶
func (s *EtcdDiscovery) GetLoadBalance() string
GetLoadBalance
func (*EtcdDiscovery) GetServices ¶
func (s *EtcdDiscovery) GetServices() []*registry.ServiceNode
GetServices
func (*EtcdDiscovery) SetServiceList ¶
func (s *EtcdDiscovery) SetServiceList(key string, node *registry.ServiceNode)
SetServiceList
func (*EtcdDiscovery) WatchService ¶
func (s *EtcdDiscovery) WatchService(ctx context.Context) error
WatchService
type EtcdRegistrar ¶
type EtcdRegistrar struct {
// contains filtered or unexported fields
}
EtcdRegistrar
func (*EtcdRegistrar) DeRegister ¶
func (s *EtcdRegistrar) DeRegister(ctx context.Context) error
Close
type RegistrarOption ¶
type RegistrarOption func(*EtcdRegistrar)
func WithRegistarHost ¶
func WithRegistarHost(host string) RegistrarOption
func WithRegistarPort ¶
func WithRegistarPort(port int) RegistrarOption
func WithRegistrarClient ¶
func WithRegistrarClient(cli *clientv3.Client) RegistrarOption
func WithRegistrarLease ¶
func WithRegistrarLease(lease int64) RegistrarOption
func WithRegistrarServiceName ¶
func WithRegistrarServiceName(serviceName string) RegistrarOption
Click to show internal directories.
Click to hide internal directories.