discover

Dec 7, 2014

Changes in this version

+ var DefaultErrorRetryInternval = 60 * time.Second

+ var DefaultGlobalBroadcastInterval = 1800 * time.Second

+ func Register(proto string, factory Factory)

+ type Client interface

+ Address func() string

+ Lookup func(device protocol.DeviceID) []string

+ StatusOK func() bool

+ Stop func()

+ func New(addr string, pkt *Announce) (Client, error)

+ type Factory func(*url.URL, *Announce) (Client, error)

+ type UDPClient struct

+ func (d *UDPClient) Address() string

+ func (d *UDPClient) Lookup(device protocol.DeviceID) []string

+ func (d *UDPClient) Start(uri *url.URL, pkt *Announce) error

+ func (d *UDPClient) StatusOK() bool

+ func (d *UDPClient) Stop()

Oct 24, 2014

Changes in this version

type Address

+ func (o Address) MustMarshalXDR() []byte

type Announce

+ func (o Announce) MustMarshalXDR() []byte

type Device

+ func (o Device) MustMarshalXDR() []byte

type Query

+ func (o Query) MustMarshalXDR() []byte

Oct 18, 2014

Changes in this version

+ type CacheEntry struct

+ Address string

+ Seen time.Time

Oct 8, 2014

Changes in this version

+ type Device struct

+ Addresses []Address

+ ID []byte

+ func (o *Device) DecodeXDR(r io.Reader) error

+ func (o *Device) UnmarshalXDR(bs []byte) error

+ func (o Device) AppendXDR(bs []byte) []byte

+ func (o Device) EncodeXDR(w io.Writer) (int, error)

+ func (o Device) MarshalXDR() []byte

type Query

+ DeviceID []byte

Sep 28, 2014

Changes in this version

+ const AnnouncementMagic

+ const QueryMagic

+ var ErrIncorrectMagic = errors.New("incorrect magic number")

+ type Address struct

+ IP []byte

+ Port uint16

+ func (o *Address) DecodeXDR(r io.Reader) error

+ func (o *Address) UnmarshalXDR(bs []byte) error

+ func (o Address) AppendXDR(bs []byte) []byte

+ func (o Address) EncodeXDR(w io.Writer) (int, error)

+ func (o Address) MarshalXDR() []byte

+ type Announce struct

+ Extra []Node

+ Magic uint32

+ This Node

+ func (o *Announce) DecodeXDR(r io.Reader) error

+ func (o *Announce) UnmarshalXDR(bs []byte) error

+ func (o Announce) AppendXDR(bs []byte) []byte

+ func (o Announce) EncodeXDR(w io.Writer) (int, error)

+ func (o Announce) MarshalXDR() []byte

+ type Discoverer struct

+ func NewDiscoverer(id protocol.NodeID, addresses []string) *Discoverer

+ func (d *Discoverer) All() map[protocol.NodeID][]cacheEntry

+ func (d *Discoverer) ExtAnnounceOK() bool

+ func (d *Discoverer) Hint(node string, addrs []string)

+ func (d *Discoverer) Lookup(node protocol.NodeID) []string

+ func (d *Discoverer) StartGlobal(server string, extPort uint16)

+ func (d *Discoverer) StartLocal(localPort int, localMCAddr string)

+ func (d *Discoverer) StopGlobal()

+ type Node struct

+ Addresses []Address

+ ID []byte

+ func (o *Node) DecodeXDR(r io.Reader) error

+ func (o *Node) UnmarshalXDR(bs []byte) error

+ func (o Node) AppendXDR(bs []byte) []byte

+ func (o Node) EncodeXDR(w io.Writer) (int, error)

+ func (o Node) MarshalXDR() []byte

+ type Query struct

+ Magic uint32

+ NodeID []byte

+ func (o *Query) DecodeXDR(r io.Reader) error

+ func (o *Query) UnmarshalXDR(bs []byte) error

+ func (o Query) AppendXDR(bs []byte) []byte

+ func (o Query) EncodeXDR(w io.Writer) (int, error)

+ func (o Query) MarshalXDR() []byte