registerdiscovery

README

registerdiscovery

Documentation

Index

• Constants
• func RegisterResolver(client *clientv3.Client)
• func RegisterService(ctx context.Context, service, address string, client *clientv3.Client) error
• func ServiceName2Key(name string) string
• func SetEtcdClient(client *clientv3.Client)
• type EtcdResolverBuilder
  • func (*EtcdResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (*EtcdResolverBuilder) Scheme() string
• type ServiceDiscovery
  • func NewServiceDiscovery(client *clientv3.Client) *ServiceDiscovery
  • func (sd *ServiceDiscovery) DiscoverServices(servicename string) ([]string, error)
  • func (sd *ServiceDiscovery) WatchServices(ctx context.Context, servicename string) <-chan struct{}

Constants

const Version = "v0.0.6"

Functions

func RegisterResolver

func RegisterResolver(client *clientv3.Client)

func RegisterService

func RegisterService(ctx context.Context, service, address string, client *clientv3.Client) error

ctx 可控制租约

func ServiceName2Key

func ServiceName2Key(name string) string

func SetEtcdClient

func SetEtcdClient(client *clientv3.Client)

Types

type EtcdResolverBuilder

type EtcdResolverBuilder struct{}

func (*EtcdResolverBuilder) Build

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

func (*EtcdResolverBuilder) Scheme

func (*EtcdResolverBuilder) Scheme() string

type ServiceDiscovery

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

func NewServiceDiscovery

func NewServiceDiscovery(client *clientv3.Client) *ServiceDiscovery

func (*ServiceDiscovery) DiscoverServices

func (sd *ServiceDiscovery) DiscoverServices(servicename string) ([]string, error)

func (*ServiceDiscovery) WatchServices

func (sd *ServiceDiscovery) WatchServices(ctx context.Context, servicename string) <-chan struct{}