discover

Documentation

Overview

Package discover implements the node discovery protocol.

Index

• Constants
• Variables
• type Address
  • func (o *Address) DecodeXDR(r io.Reader) error
  • func (o Address) EncodeXDR(w io.Writer) (int, error)
  • func (o Address) MarshalXDR() []byte
  • func (o *Address) UnmarshalXDR(bs []byte) error
• type AnnounceV1
  • func (o *AnnounceV1) DecodeXDR(r io.Reader) error
  • func (o AnnounceV1) EncodeXDR(w io.Writer) (int, error)
  • func (o AnnounceV1) MarshalXDR() []byte
  • func (o *AnnounceV1) UnmarshalXDR(bs []byte) error
• type AnnounceV2
  • func (o *AnnounceV2) DecodeXDR(r io.Reader) error
  • func (o AnnounceV2) EncodeXDR(w io.Writer) (int, error)
  • func (o AnnounceV2) MarshalXDR() []byte
  • func (o *AnnounceV2) UnmarshalXDR(bs []byte) error
• type Discoverer
  • func NewDiscoverer(id string, addresses []string, extServer string) (*Discoverer, error)
  • func (d *Discoverer) Lookup(node string) []string
• type QueryV1
  • func (o *QueryV1) DecodeXDR(r io.Reader) error
  • func (o QueryV1) EncodeXDR(w io.Writer) (int, error)
  • func (o QueryV1) MarshalXDR() []byte
  • func (o *QueryV1) UnmarshalXDR(bs []byte) error
• type QueryV2
  • func (o *QueryV2) DecodeXDR(r io.Reader) error
  • func (o QueryV2) EncodeXDR(w io.Writer) (int, error)
  • func (o QueryV2) MarshalXDR() []byte
  • func (o *QueryV2) UnmarshalXDR(bs []byte) error

Constants

const (
	AnnouncementMagicV1 = 0x20121025
	QueryMagicV1        = 0x19760309
)

const (
	AnnouncementMagicV2 = 0x029E4C77
	QueryMagicV2        = 0x23D63A9A
)

const (
	AnnouncementPort = 21025
)

Variables

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

Types

type Address

type Address struct {
	IP   []byte // max:16
	Port uint16
}

func (*Address) DecodeXDR

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

func (Address) EncodeXDR

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

func (Address) MarshalXDR

func (o Address) MarshalXDR() []byte

func (*Address) UnmarshalXDR

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

type AnnounceV1

type AnnounceV1 struct {
	Magic  uint32
	Port   uint16
	NodeID string // max:64
	IP     []byte // max:16
}

func (*AnnounceV1) DecodeXDR

func (o *AnnounceV1) DecodeXDR(r io.Reader) error

func (AnnounceV1) EncodeXDR

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

func (AnnounceV1) MarshalXDR

func (o AnnounceV1) MarshalXDR() []byte

func (*AnnounceV1) UnmarshalXDR

func (o *AnnounceV1) UnmarshalXDR(bs []byte) error

type AnnounceV2

type AnnounceV2 struct {
	Magic     uint32
	NodeID    string    // max:64
	Addresses []Address // max:16
}

func (*AnnounceV2) DecodeXDR

func (o *AnnounceV2) DecodeXDR(r io.Reader) error

func (AnnounceV2) EncodeXDR

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

func (AnnounceV2) MarshalXDR

func (o AnnounceV2) MarshalXDR() []byte

func (*AnnounceV2) UnmarshalXDR

func (o *AnnounceV2) UnmarshalXDR(bs []byte) error

type Discoverer

type Discoverer struct {
	MyID             string
	ListenAddresses  []string
	BroadcastIntv    time.Duration
	ExtBroadcastIntv time.Duration
	// contains filtered or unexported fields
}

func NewDiscoverer

func NewDiscoverer(id string, addresses []string, extServer string) (*Discoverer, error)

func (*Discoverer) Lookup

func (d *Discoverer) Lookup(node string) []string

type QueryV1

type QueryV1 struct {
	Magic  uint32
	NodeID string // max:64
}

func (*QueryV1) DecodeXDR

func (o *QueryV1) DecodeXDR(r io.Reader) error

func (QueryV1) EncodeXDR

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

func (QueryV1) MarshalXDR

func (o QueryV1) MarshalXDR() []byte

func (*QueryV1) UnmarshalXDR

func (o *QueryV1) UnmarshalXDR(bs []byte) error

type QueryV2

type QueryV2 struct {
	Magic  uint32
	NodeID string // max:64
}

func (*QueryV2) DecodeXDR

func (o *QueryV2) DecodeXDR(r io.Reader) error

func (QueryV2) EncodeXDR

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

func (QueryV2) MarshalXDR

func (o QueryV2) MarshalXDR() []byte

func (*QueryV2) UnmarshalXDR

func (o *QueryV2) UnmarshalXDR(bs []byte) error