discovery

Documentation

Index

• Constants
• Variables
• func GetNodeInfo(attr resolver.Address) *register.Options
• func NewDiscovery(opt ...ClientOptions) (resolver.Builder, error)
• func SetNodeInfo(addr resolver.Address, hInfo *register.Options) resolver.Address
• type ClientOptions
  • func SetEtcdConf(conf clientv3.Config) ClientOptions
  • func SetLoadBalancingPolicy(name string) ClientOptions
  • func SetName(name string) ClientOptions
• type Discovery
  • func (d *Discovery) AddNode(key, val []byte) error
  • func (d *Discovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (s *Discovery) Close()
  • func (d *Discovery) DelNode(key []byte) error
  • func (d *Discovery) GetAddress() []resolver.Address
  • func (s *Discovery) ResolveNow(rn resolver.ResolveNowOptions)
  • func (d *Discovery) Scheme() string
• type NodeArray
• type Options

Constants

const VersionLB = "version"

Variables

var ErrLoadBalancingPolicy = errors.New("LoadBalancingPolicy is empty or not apply")

Functions

func GetNodeInfo

func GetNodeInfo(attr resolver.Address) *register.Options

func NewDiscovery

func NewDiscovery(opt ...ClientOptions) (resolver.Builder, error)

func SetNodeInfo

func SetNodeInfo(addr resolver.Address, hInfo *register.Options) resolver.Address

Types

type ClientOptions

type ClientOptions func(*Options)

func SetEtcdConf

func SetEtcdConf(conf clientv3.Config) ClientOptions

func SetLoadBalancingPolicy

func SetLoadBalancingPolicy(name string) ClientOptions

func SetName

func SetName(name string) ClientOptions

type Discovery

type Discovery struct {
	Node sync.Map
	// contains filtered or unexported fields
}

func (*Discovery) AddNode

func (d *Discovery) AddNode(key, val []byte) error

func (*Discovery) Build

func (d *Discovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

Build 当调用`grpc.Dial()`时执行

func (*Discovery) Close

func (s *Discovery) Close()

func (*Discovery) DelNode

func (d *Discovery) DelNode(key []byte) error

func (*Discovery) GetAddress

func (d *Discovery) GetAddress() []resolver.Address

func (*Discovery) ResolveNow

func (s *Discovery) ResolveNow(rn resolver.ResolveNowOptions)

func (*Discovery) Scheme

func (d *Discovery) Scheme() string

type NodeArray

type NodeArray struct {
	Node []register.Options `json:"node"`
}

type Options

type Options struct {
	EtcdConf            clientv3.Config `json:"-"`
	SrvName             string
	LoadBalancingPolicy string
}