registries

Documentation

Index

• Constants
• type CachedRegistry
  • func NewCached(c *etcd.Config) *CachedRegistry
  • func (r *CachedRegistry) Close() error
  • func (r *CachedRegistry) Lookup(k EndpointName) (string, error)
  • func (r *CachedRegistry) Start() error
  • func (r *CachedRegistry) Started() bool
• type EndpointName
• type LB
  • func FirstLB() LB
  • func RandLB() LB
• type NodeAddr
• type NodeList
• type Registry
  • func New(c *etcd.Config) *Registry
  • func (r *Registry) Close() error
  • func (r *Registry) Register(addr string, eps []*endpoints.Endpoint) error

Constants

const DefaultPrefix = "gbio-"

Types

type CachedRegistry

type CachedRegistry struct {
	*Registry

	Lb LB
	// contains filtered or unexported fields
}

func NewCached

func NewCached(c *etcd.Config) *CachedRegistry

func (*CachedRegistry) Close

func (r *CachedRegistry) Close() error

func (*CachedRegistry) Lookup

func (r *CachedRegistry) Lookup(k EndpointName) (string, error)

func (*CachedRegistry) Start

func (r *CachedRegistry) Start() error

func (*CachedRegistry) Started

func (r *CachedRegistry) Started() bool

type EndpointName

type EndpointName string

type LB

type LB interface {
	Pick(endpoints []string) string
}

func FirstLB

func FirstLB() LB

func RandLB

func RandLB() LB

type NodeAddr

type NodeAddr string

type NodeList

type NodeList []string

type Registry

type Registry struct {
	C      *etcd.Config
	Ctx    context.Context
	Prefix string
	Tick   time.Duration
	// contains filtered or unexported fields
}

func New

func New(c *etcd.Config) *Registry

func (*Registry) Close

func (r *Registry) Close() error

func (*Registry) Register

func (r *Registry) Register(addr string, eps []*endpoints.Endpoint) error