registry

README

registry

Documentation

Index

• func NewGRPCEtcdResolverBuilder(c *clientv3.Client) (gresolver.Builder, error)
• type Endpoint
• type Operation
• type Option
  • func WithAuthOpt(username, password string) Option
  • func WithDialTimeoutOpt(dialTimeout time.Duration) Option
  • func WithTLSOpt(certFile, keyFile, caFile string) Option
• type Registry
  • func NewEtcdRegistry(endpoints []string, ttl int64, opts ...Option) (Registry, error)
  • func NewEtcdRegistryWithClient(etcdClient *clientv3.Client, ttl int64) (Registry, error)
• type Resolver
• type ResolverBuilder
• type Update
• type UpdateFunc
• type WatchChannel
• type WatchResolver
• type WatchResolverBuilder
  • func NewEtcdWatchResolverBuilder(c *clientv3.Client) (WatchResolverBuilder, error)

Functions

func NewGRPCEtcdResolverBuilder

func NewGRPCEtcdResolverBuilder(c *clientv3.Client) (gresolver.Builder, error)

Types

type Endpoint

type Endpoint struct {
	ServiceName string
	Network     string
	Address     string //host
	Port        int
	Weight      int
	Tags        map[string]string
}

type Operation

type Operation uint8

const (
	Add Operation = iota
	Delete
)

type Option

type Option func(c *clientv3.Config)

func WithAuthOpt

func WithAuthOpt(username, password string) Option

WithAuthOpt returns a option that authentication by usernane and password.

func WithDialTimeoutOpt

func WithDialTimeoutOpt(dialTimeout time.Duration) Option

WithDialTimeoutOpt returns a option set dialTimeout

func WithTLSOpt

func WithTLSOpt(certFile, keyFile, caFile string) Option

type Registry

type Registry interface {
	Register(endpoint *Endpoint) error
	Deregister(endpoint *Endpoint) error
}

func NewEtcdRegistry

func NewEtcdRegistry(endpoints []string, ttl int64, opts ...Option) (Registry, error)

func NewEtcdRegistryWithClient

func NewEtcdRegistryWithClient(etcdClient *clientv3.Client, ttl int64) (Registry, error)

type Resolver

type Resolver interface {
}

type ResolverBuilder

type ResolverBuilder interface {
	Build(target string, update UpdateFunc) (Resolver, error)
}

type Update

type Update struct {
	Op       Operation
	Key      string
	Instance discovery.Instance
}

type UpdateFunc

type UpdateFunc func(discovery.Result) error

type WatchChannel

type WatchChannel <-chan []*Update

type WatchResolver

type WatchResolver interface {
}

type WatchResolverBuilder

type WatchResolverBuilder interface {
	Build(target string, update UpdateFunc) (WatchResolver, error)
}

func NewEtcdWatchResolverBuilder

func NewEtcdWatchResolverBuilder(c *clientv3.Client) (WatchResolverBuilder, error)