discovery

Documentation

Index

• Constants
• func DataSource() *clientv3.Client
• func NewRegistry() *etcdv3Registry
• type Discovery
• type Etcdv3ResolverBuilder
  • func (*Etcdv3ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (*Etcdv3ResolverBuilder) Scheme() string
• type Instance
  • func NewInstance(addr string) *Instance
• type InstanceEvent
• type InstanceEventType
• type RandomBalancer
  • func (b *RandomBalancer) Close()
  • func (b *RandomBalancer) ResolverError(err error)
  • func (b *RandomBalancer) UpdateClientConnState(cs balancer.ClientConnState) error
  • func (b *RandomBalancer) UpdateSubConnState(sc balancer.SubConn, s balancer.SubConnState)
• type RandomBuilder
  • func (*RandomBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer
  • func (*RandomBuilder) Name() string

Constants

const InstanceEventAsAdd = InstanceEventType(1)

const InstanceEventAsDelete = InstanceEventType(2)

const InstanceEventAsUpdate = InstanceEventType(3)

Functions

func DataSource

func DataSource() *clientv3.Client

func NewRegistry

func NewRegistry() *etcdv3Registry

Types

type Discovery

type Discovery interface {
	RegisterService(context.Context, *Instance) error
	UnregisterService(context.Context, string) error
	ListServices(context.Context, string) ([]*Instance, error)
	WatchServices(ctx context.Context, name string) (err error)
}

type Etcdv3ResolverBuilder

type Etcdv3ResolverBuilder struct {
}

func (*Etcdv3ResolverBuilder) Build

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

func (*Etcdv3ResolverBuilder) Scheme

func (*Etcdv3ResolverBuilder) Scheme() string

type Instance

type Instance struct {
	Namespace string            `json:"namespace" `
	Name      string            `json:"name"`
	Id        string            `json:"id"`
	Address   string            `json:"address"`
	Weight    float64           `json:"weight"`
	Enable    bool              `json:"enable"`
	Metadata  map[string]string `json:"metadata"`
	Region    string            `json:"region"`
	Zone      string            `json:"zone"`
	Methods   []string          `json:"methods" `
}

func NewInstance

func NewInstance(addr string) *Instance

type InstanceEvent

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

type InstanceEventType

type InstanceEventType int

type RandomBalancer

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

func (*RandomBalancer) Close

func (b *RandomBalancer) Close()

func (*RandomBalancer) ResolverError

func (b *RandomBalancer) ResolverError(err error)

func (*RandomBalancer) UpdateClientConnState

func (b *RandomBalancer) UpdateClientConnState(cs balancer.ClientConnState) error

func (*RandomBalancer) UpdateSubConnState

func (b *RandomBalancer) UpdateSubConnState(sc balancer.SubConn, s balancer.SubConnState)

type RandomBuilder

type RandomBuilder struct{}

func (*RandomBuilder) Build

func (*RandomBuilder) Build(cc balancer.ClientConn, opt balancer.BuildOptions) balancer.Balancer

func (*RandomBuilder) Name

func (*RandomBuilder) Name() string