discovery

Documentation

Index

• Constants
• Variables
• func BuildCtxFilter(ctx context.Context, data map[string]string) context.Context
• 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
  • func SetVersion(version 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 CustomizeLB = "customize"

Variables

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

var ErrNoMatchFoundConn = errors.New("no match found conn")

var ErrNotGetRightConn = errors.New("did not get the right conn")

Functions

func BuildCtxFilter

func BuildCtxFilter(ctx context.Context, data map[string]string) context.Context

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

func SetVersion

func SetVersion(version 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
	Version             string
}