discovery

Documentation

Index

• func ParsePeer(raw string) raft.Server
• func ParsePeers(raw string) []raft.Server
• type DNSDiscovery
  • func NewDNSDiscovery(l log.Logger, addr string, p *dns.Provider) *DNSDiscovery
  • func (d *DNSDiscovery) Close()
  • func (d *DNSDiscovery) Rediscover()
  • func (d *DNSDiscovery) Subscribe(updates Updates)
• type Discovery
  • func NewDiscovery(l log.Logger, address string, reg prometheus.Registerer) (Discovery, error)
• type KubeDiscovery
  • func NewKubeResolverDiscovery(l log.Logger, target string, client kuberesolver2.K8sClient) (*KubeDiscovery, error)
  • func (g *KubeDiscovery) Close()
  • func (g *KubeDiscovery) Rediscover()
  • func (g *KubeDiscovery) Subscribe(upd Updates)
• type Server
  • func (s *Server) String() string
• type StaticDiscovery
  • func NewStaticDiscovery(servers []Server) *StaticDiscovery
  • func (s *StaticDiscovery) Close()
  • func (s *StaticDiscovery) Rediscover()
  • func (s *StaticDiscovery) Subscribe(updates Updates)
• type UpdateFunc
  • func (f UpdateFunc) Servers(servers []Server)
• type Updates

Functions

func ParsePeer

func ParsePeer(raw string) raft.Server

func ParsePeers

func ParsePeers(raw string) []raft.Server

Types

type DNSDiscovery

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

func NewDNSDiscovery

func NewDNSDiscovery(l log.Logger, addr string, p *dns.Provider) *DNSDiscovery

func (*DNSDiscovery) Close

func (d *DNSDiscovery) Close()

func (*DNSDiscovery) Rediscover

func (d *DNSDiscovery) Rediscover()

func (*DNSDiscovery) Subscribe

func (d *DNSDiscovery) Subscribe(updates Updates)

type Discovery

type Discovery interface {
	Subscribe(updates Updates)
	Rediscover()
	Close()
}

func NewDiscovery

func NewDiscovery(l log.Logger, address string, reg prometheus.Registerer) (Discovery, error)

type KubeDiscovery

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

func NewKubeResolverDiscovery

func NewKubeResolverDiscovery(l log.Logger, target string, client kuberesolver2.K8sClient) (*KubeDiscovery, error)

func (*KubeDiscovery) Close

func (g *KubeDiscovery) Close()

func (*KubeDiscovery) Rediscover

func (g *KubeDiscovery) Rediscover()

func (*KubeDiscovery) Subscribe

func (g *KubeDiscovery) Subscribe(upd Updates)

type Server

type Server struct {
	Raft            raft.Server
	ResolvedAddress string
}

func (*Server) String

func (s *Server) String() string

type StaticDiscovery

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

func NewStaticDiscovery

func NewStaticDiscovery(servers []Server) *StaticDiscovery

func (*StaticDiscovery) Close

func (s *StaticDiscovery) Close()

func (*StaticDiscovery) Rediscover

func (s *StaticDiscovery) Rediscover()

func (*StaticDiscovery) Subscribe

func (s *StaticDiscovery) Subscribe(updates Updates)

type UpdateFunc

type UpdateFunc func(servers []Server)

func (UpdateFunc) Servers

func (f UpdateFunc) Servers(servers []Server)

type Updates

type Updates interface {
	Servers(servers []Server)
}