nameserver

Jun 20, 2016

Changes in this version

+ type Upstream interface

+ Config func() *dns.ClientConfig

+ func NewUpstream(resolvConf, filterAddress string) Upstream

Apr 19, 2016

Changes in this version

type Nameserver

+ func (n *Nameserver) ContainerDestroyed(ident string)

Dec 17, 2015

Changes in this version

type Status

+ Upstream []string

Nov 5, 2015

Changes in this version

type GossipData

+ func (g *GossipData) Decode(msg []byte) error

Oct 22, 2015

Changes in this version

+ type CaseInsensitive Entries

+ func (es CaseInsensitive) Get(i int) Entry

+ func (es CaseInsensitive) Len() int

+ func (es CaseInsensitive) Less(i, j int) bool

+ func (es CaseInsensitive) Swap(i, j int)

+ type CaseSensitive Entries

+ func (es CaseSensitive) Get(i int) Entry

+ func (es CaseSensitive) Len() int

+ func (es CaseSensitive) Less(i, j int) bool

+ func (es CaseSensitive) Swap(i, j int)

type Nameserver

+ func (n *Nameserver) ContainerStarted(ident string)

+ type SortableEntries interface

+ Get func(i int) Entry

Sep 7, 2015

Changes in this version

+ const DefaultClientTimeout

+ const DefaultDomain

+ const DefaultListenAddress

+ const DefaultTTL

type DNSServer

+ func (d *DNSServer) String() string

+ type Entries []Entry

+ func (es Entries) Len() int

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

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

+ type Entry struct

+ Addr address.Address

+ ContainerID string

+ Hostname string

+ Origin router.PeerName

+ Tombstone int64

+ Version int

+ func (e1 *Entry) String() string

+ type EntryStatus struct

+ Address string

+ ContainerID string

+ Hostname string

+ Origin string

+ Tombstone int64

+ Version int

+ type GossipData struct

+ Timestamp int64

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

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

+ type Nameserver struct

+ 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 struct

+ Address string

+ Domain string

+ Entries []EntryStatus

+ TTL uint32

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

Jun 18, 2015

Changes in this version

+ const DefaultHTTPPort

+ const DefaultLocalTTL

+ const DefaultMaxAnswers

+ const DefaultRefreshInterval

+ const DefaultRelevantTime

+ func ServeHTTP(listener net.Listener, version string, server *DNSServer, ...)

+ type DNSResponseBuilder func(r *dns.Msg, q *dns.Question, addrs []ZoneRecord, ttl int) *dns.Msg

type DNSServer

+ func (s *DNSServer) ActivateAndServe()

+ func (s *DNSServer) GetPort() (int, error)

type DNSServerConfig

+ Cache ZoneCache

+ CacheDisabled bool

+ CacheNegLocalTTL int

+ Clock clock.Clock

+ ListenReadTimeout int

+ LocalTTL int

+ MaxAnswers int

+ Zone Zone

type Zone

+ DeleteRecords func(ident string, name string, ip net.IP) (count int)

+ DomainLookupInaddr func(inaddr string) ([]ZoneRecord, error)

+ DomainLookupName func(name string) ([]ZoneRecord, error)

+ Status func() string

+ type ZoneConfig struct

+ Clock clock.Clock

+ Domain string

+ Iface *net.Interface

+ LocalTTL int

+ MDNSClient ZoneMDNSClient

+ MDNSServer ZoneMDNSServer

+ RefreshInterval int

+ RelevantTime int

type ZoneDb

+ func (zone *ZoneDb) DeleteRecords(ident string, name string, ip net.IP) int

+ func (zone *ZoneDb) DomainLookupInaddr(inaddr string) (res []ZoneRecord, err error)

+ func (zone *ZoneDb) DomainLookupName(name string) (res []ZoneRecord, err error)

+ func (zone *ZoneDb) HasNameLocalInfo(n string) bool

+ func (zone *ZoneDb) HasNameRemoteInfo(n string) bool

+ func (zone *ZoneDb) IsNameExpired(n string) bool

+ func (zone *ZoneDb) IsNameRelevant(n string) bool

+ func (zone *ZoneDb) ObserveInaddr(inaddr string, observer ZoneRecordObserver) (err error)

+ func (zone *ZoneDb) ObserveName(name string, observer ZoneRecordObserver) (err error)

+ func (zone *ZoneDb) Start() (err error)

+ func (zone *ZoneDb) Status() string

+ func (zone *ZoneDb) Stop() error

+ type ZoneLookupFunc func(target string) ([]ZoneRecord, error)

+ type ZoneMDNS interface

+ Start func(*net.Interface) error

+ Stop func() error

+ type ZoneMDNSClient interface

+ InsistentLookupInaddr func(inaddr string) ([]ZoneRecord, error)

+ InsistentLookupName func(name string) ([]ZoneRecord, error)

+ type ZoneMDNSServer interface

+ Zone func() Zone

+ type ZoneObservable interface

+ ObserveInaddr func(inaddr string, observer ZoneRecordObserver) error

+ ObserveName func(name string, observer ZoneRecordObserver) error

+ type ZoneObserverFunc func(string, ZoneRecordObserver) error

May 26, 2015

Changes in this version

type Cache

+ func (c *Cache) String() string

+ type IPv4 [4]byte

+ func (ip IPv4) String() string

type MDNSClient

+ func (c *MDNSClient) Stop() error

+ func (client *MDNSClient) InsistentLookupInaddr(inaddr string) ([]ZoneRecord, error)

+ func (client *MDNSClient) InsistentLookupName(name string) ([]ZoneRecord, error)

type MDNSServer

+ func (s *MDNSServer) Zone() Zone

type Record

+ func (r Record) Priority() int

+ func (r Record) String() string

+ func (r Record) TTL() int

+ func (r Record) Weight() int

type Response

+ func (r Response) Equal(r2 *Response) bool

+ func (r Response) IP() net.IP

+ func (r Response) Priority() int

+ func (r Response) String() string

+ func (r Response) TTL() int

+ func (r Response) Weight() int

type Zone

+ Domain func() string

+ type ZoneCache interface

+ Capacity func() int

+ Clear func()

+ Get func(request *dns.Msg, maxLen int) (reply *dns.Msg, err error)

+ Len func() int

+ Purge func()

+ Put func(request *dns.Msg, reply *dns.Msg, ttl int, flags uint8) int

+ Remove func(question *dns.Question)

type ZoneDb

+ func NewZoneDb(domain string) *ZoneDb

+ func (zone *ZoneDb) Domain() string

+ type ZoneLookup interface

+ LookupInaddr func(inaddr string) ([]ZoneRecord, error)

+ LookupName func(name string) ([]ZoneRecord, error)

+ type ZoneObserver interface

+ ObserveInaddr func(inaddr string, observer ZoneRecordObserver) error

+ ObserveName func(name string, observer ZoneRecordObserver) error

+ type ZoneRecord interface

+ IP func() net.IP

+ Name func() string

+ Priority func() int

+ TTL func() int

+ Weight func() int

+ type ZoneRecordObserver func()

Apr 21, 2015

Changes in this version

+ const CacheNoLocalReplies

+ const DefaultCLICfgFile

+ const DefaultCacheLen

+ const DefaultLocalDomain

+ const DefaultResolvWorkers

+ const DefaultServerPort

+ const DefaultTimeout

+ const DefaultUDPBuflen

+ const RDNSDomain

+ func ListenHTTP(version string, server *DNSServer, domain string, db Zone, port int)

+ type Cache struct

+ Capacity int

+ func NewCache(capacity int) (*Cache, error)

+ func (c *Cache) Clear()

+ func (c *Cache) Get(request *dns.Msg, maxLen int, now time.Time) (reply *dns.Msg, err error)

+ func (c *Cache) Len() int

+ func (c *Cache) Purge(now time.Time)

+ func (c *Cache) Put(request *dns.Msg, reply *dns.Msg, ttl int, flags uint8, now time.Time) int

+ func (c *Cache) Remove(question *dns.Question)

+ type DNSServer struct

+ Domain string

+ Iface *net.Interface

+ ListenAddr string

+ Upstream *dns.ClientConfig

+ Zone Zone

+ func NewDNSServer(config DNSServerConfig, zone Zone, iface *net.Interface) (s *DNSServer, err error)

+ func (s *DNSServer) Start() error

+ func (s *DNSServer) Status() string

+ func (s *DNSServer) Stop() error

+ type DNSServerConfig struct

+ CacheLen int

+ LocalDomain string

+ Port int

+ Timeout int

+ UDPBufLen int

+ UpstreamCfg *dns.ClientConfig

+ UpstreamCfgFile string

+ type MDNSAction func()

type MDNSServer

+ func (s *MDNSServer) Stop() error

type ZoneDb

+ func (zone *ZoneDb) ContainerDied(ident string) error

+ func (zone *ZoneDb) String() string

Feb 3, 2015

Changes in this version

+ type Lookup interface

+ LookupInaddr func(inaddr string) (string, error)

+ LookupName func(name string) (net.IP, error)

+ type LookupFunc func(Lookup, *dns.Msg, *dns.Question) *dns.Msg

type MDNSClient

+ func (client *MDNSClient) LookupInaddr(inaddr string) (string, error)

+ func (client *MDNSClient) LookupName(name string) (net.IP, error)

+ type Response struct

+ Addr net.IP

+ Err error

+ Name string

type ZoneDb

+ func (zone *ZoneDb) LookupInaddr(inaddr string) (string, error)

+ func (zone *ZoneDb) LookupName(name string) (net.IP, error)

Dec 30, 2014

Changes in this version

+ const CMessageReceived

+ const CSendQuery

+ const CShutdown

+ const LOCAL_DOMAIN

+ const MailboxSize

+ const MaxDuration

+ const RDNS_DOMAIN

+ var Debug *log.Logger

+ var Error *log.Logger

+ var Info *log.Logger

+ var Warning *log.Logger

+ func InitLogging(debugHandle io.Writer, infoHandle io.Writer, warningHandle io.Writer, ...)

+ func LinkLocalMulticastListener(ifi *net.Interface) (net.PacketConn, error)

+ func ListenHttp(domain string, db Zone, port int)

+ func StartServer(zone Zone, iface *net.Interface, dnsPort int, httpPort int, wait int) error

+ func StartUpdater(apiPath string, zone Zone) error

+ type DuplicateError struct

+ func (dup DuplicateError) Error() string

+ type LookupError string

+ func (ops LookupError) Error() string

+ type MDNSClient struct

+ func NewMDNSClient() (*MDNSClient, error)

+ func (c *MDNSClient) ResponseCallback(r *dns.Msg)

+ func (c *MDNSClient) SendQuery(name string, querytype uint16, responseCh chan<- *ResponseA)

+ func (c *MDNSClient) Shutdown()

+ func (c *MDNSClient) Start(ifi *net.Interface) error

+ type MDNSInteraction struct

+ type MDNSServer struct

+ func NewMDNSServer(zone Zone) (*MDNSServer, error)

+ func (s *MDNSServer) Start(ifi *net.Interface) error

+ type Record struct

+ IP net.IP

+ Ident string

+ Name string

+ type ResponseA struct

+ Addr net.IP

+ Err error

+ Name string

+ type Zone interface

+ AddRecord func(ident string, name string, ip net.IP) error

+ DeleteRecord func(ident string, ip net.IP) error

+ DeleteRecordsFor func(ident string) error

+ LookupLocal func(name string) (net.IP, error)

+ ReverseLookupLocal func(ip net.IP) (string, error)

+ type ZoneDb struct

+ func (zone *ZoneDb) AddRecord(ident string, name string, ip net.IP) error

+ func (zone *ZoneDb) DeleteRecord(ident string, ip net.IP) error

+ func (zone *ZoneDb) DeleteRecordsFor(ident string) error

+ func (zone *ZoneDb) LookupLocal(name string) (net.IP, error)

+ func (zone *ZoneDb) ReverseLookupLocal(ip net.IP) (string, error)