nameserver

Documentation

Index

• Constants
• type DNSServer
  • func NewDNSServer(ns *Nameserver, domain, address, effectiveAddress string, ttl uint32, ...) (*DNSServer, error)
  • func (d *DNSServer) ActivateAndServe()
  • func (d *DNSServer) Stop() error
  • func (d *DNSServer) String() string
• type Entries
  • func (es Entries) Len() int
  • func (es Entries) Less(i, j int) bool
  • func (es Entries) Swap(i, j int)
• type Entry
  • func (e1 *Entry) String() string
• type EntryStatus
• type GossipData
  • func (g *GossipData) Encode() [][]byte
  • func (g *GossipData) Merge(o router.GossipData)
• type Nameserver
  • func New(ourName router.PeerName, peers *router.Peers, docker *docker.Client, ...) *Nameserver
  • func (n *Nameserver) AddEntry(hostname, containerid string, origin router.PeerName, addr address.Address) error
  • func (n *Nameserver) ContainerDied(ident string)
  • func (n *Nameserver) Delete(hostname, containerid, ipStr string, ip address.Address) error
  • func (n *Nameserver) Gossip() router.GossipData
  • func (n *Nameserver) HandleHTTP(router *mux.Router)
  • func (n *Nameserver) Lookup(hostname string) []address.Address
  • func (n *Nameserver) OnGossip(msg []byte) (router.GossipData, error)
  • func (n *Nameserver) OnGossipBroadcast(_ router.PeerName, msg []byte) (router.GossipData, error)
  • func (n *Nameserver) OnGossipUnicast(sender router.PeerName, msg []byte) error
  • func (n *Nameserver) PeerGone(peer *router.Peer)
  • func (n *Nameserver) ReverseLookup(ip address.Address) (string, error)
  • func (n *Nameserver) SetGossip(gossip router.Gossip)
  • func (n *Nameserver) Start()
  • func (n *Nameserver) Stop()
• type Status
  • func NewStatus(ns *Nameserver, dnsServer *DNSServer) *Status

Constants

const (
	DefaultListenAddress = "0.0.0.0:53"
	DefaultTTL           = 1
	DefaultClientTimeout = 5 * time.Second
)

const (

	// Used by prog/weaver/main.go and proxy/create_container_interceptor.go
	DefaultDomain = "weave.local."
)

Types

type DNSServer

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

func NewDNSServer

func NewDNSServer(ns *Nameserver, domain, address, effectiveAddress string, ttl uint32, clientTimeout time.Duration) (*DNSServer, error)

func (*DNSServer) ActivateAndServe

func (d *DNSServer) ActivateAndServe()

func (*DNSServer) Stop

func (d *DNSServer) Stop() error

func (*DNSServer) String

func (d *DNSServer) String() string

type Entries

type Entries []Entry

func (Entries) Len

func (es Entries) Len() int

func (Entries) Less

func (es Entries) Less(i, j int) bool

func (Entries) Swap

func (es Entries) Swap(i, j int)

type Entry

type Entry struct {
	ContainerID string
	Origin      router.PeerName
	Addr        address.Address
	Hostname    string
	Version     int
	Tombstone   int64 // timestamp of when it was deleted
}

func (*Entry) String

func (e1 *Entry) String() string

type EntryStatus

type EntryStatus struct {
	Hostname    string
	Origin      string
	ContainerID string
	Address     string
	Version     int
	Tombstone   int64
}

type GossipData

type GossipData struct {
	Timestamp int64
	Entries
}

func (*GossipData) Encode

func (g *GossipData) Encode() [][]byte

func (*GossipData) Merge

func (g *GossipData) Merge(o router.GossipData)

type Nameserver

type Nameserver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Nameserver: gossip-based, in memory nameserver. - Holds a sorted list of (hostname, peer, container id, ip) tuples for the whole cluster. - This list is gossiped & merged around the cluser. - Lookup-by-hostname are O(nlogn), and return a (copy of a) slice of the entries - Update is O(n) for now

func New

func New(ourName router.PeerName, peers *router.Peers, docker *docker.Client, domain string) *Nameserver

func (*Nameserver) AddEntry

func (n *Nameserver) AddEntry(hostname, containerid string, origin router.PeerName, addr address.Address) error

func (*Nameserver) ContainerDied

func (n *Nameserver) ContainerDied(ident string)

func (*Nameserver) Delete

func (n *Nameserver) Delete(hostname, containerid, ipStr string, ip address.Address) error

func (*Nameserver) Gossip

func (n *Nameserver) Gossip() router.GossipData

func (*Nameserver) HandleHTTP

func (n *Nameserver) HandleHTTP(router *mux.Router)

func (*Nameserver) Lookup

func (n *Nameserver) Lookup(hostname string) []address.Address

func (*Nameserver) OnGossip

func (n *Nameserver) OnGossip(msg []byte) (router.GossipData, error)

merge received data into state and return "everything new I've just learnt", or nil if nothing in the received data was new

func (*Nameserver) OnGossipBroadcast

func (n *Nameserver) OnGossipBroadcast(_ router.PeerName, msg []byte) (router.GossipData, error)

merge received data into state and return a representation of the received data, for further propagation

func (*Nameserver) OnGossipUnicast

func (n *Nameserver) OnGossipUnicast(sender router.PeerName, msg []byte) error

func (*Nameserver) PeerGone

func (n *Nameserver) PeerGone(peer *router.Peer)

func (*Nameserver) ReverseLookup

func (n *Nameserver) ReverseLookup(ip address.Address) (string, error)

func (*Nameserver) SetGossip

func (n *Nameserver) SetGossip(gossip router.Gossip)

func (*Nameserver) Start

func (n *Nameserver) Start()

func (*Nameserver) Stop

func (n *Nameserver) Stop()

type Status

type Status struct {
	Domain  string
	Address string
	TTL     uint32
	Entries []EntryStatus
}

func NewStatus

func NewStatus(ns *Nameserver, dnsServer *DNSServer) *Status