registry

Documentation

Index

• type Driver
  • func RegisterDriver(resolverData map[string]*registry.ServiceInfo) *Driver
  • func (d *Driver) CreateRegistry(cnf *conf.Configuration) (registry.Registry, error)
  • func (d *Driver) GetRegistry(name string) (registry.Registry, error)
  • func (d *Driver) ResolverBuilder(cnf *conf.Configuration) (resolver.Builder, error)
  • func (d *Driver) WithDialOptions(registryOpts registry.DialOptions) ([]grpc.DialOption, error)
• type Registry
  • func (r *Registry) Close()
  • func (r *Registry) GetServiceInfos(s string) ([]*registry.ServiceInfo, error)
  • func (r *Registry) Register(info *registry.ServiceInfo) error
  • func (r *Registry) TTL() time.Duration
  • func (r *Registry) Unregister(info *registry.ServiceInfo) error
• type Resolver
  • func (r *Resolver) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(options resolver.ResolveNowOptions)
  • func (r *Resolver) Scheme() string

Types

type Driver

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

func RegisterDriver

func RegisterDriver(resolverData map[string]*registry.ServiceInfo) *Driver

func (*Driver) CreateRegistry

func (d *Driver) CreateRegistry(cnf *conf.Configuration) (registry.Registry, error)

func (*Driver) GetRegistry

func (d *Driver) GetRegistry(name string) (registry.Registry, error)

func (*Driver) ResolverBuilder

func (d *Driver) ResolverBuilder(cnf *conf.Configuration) (resolver.Builder, error)

func (*Driver) WithDialOptions

func (d *Driver) WithDialOptions(registryOpts registry.DialOptions) ([]grpc.DialOption, error)

type Registry

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

func (*Registry) Close

func (r *Registry) Close()

func (*Registry) GetServiceInfos

func (r *Registry) GetServiceInfos(s string) ([]*registry.ServiceInfo, error)

func (*Registry) Register

func (r *Registry) Register(info *registry.ServiceInfo) error

func (*Registry) TTL

func (r *Registry) TTL() time.Duration

func (*Registry) Unregister

func (r *Registry) Unregister(info *registry.ServiceInfo) error

type Resolver

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

func (*Resolver) Build

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(options resolver.ResolveNowOptions)

func (*Resolver) Scheme

func (r *Resolver) Scheme() string