assemble

Documentation

Index

• func NewDialBack() (*DialBack, *XDialBack)
• type Assembler
  • func NewAssembler(addr n.Addr, multicast *net.UDPAddr) *Assembler
  • func (a *Assembler) AssembleClient() n.Addr
  • func (a *Assembler) AssembleServer(joinServer JoinFunc)
• type DialBack
  • func (d *DialBack) ObtainAddr() n.Addr
• type Gather
  • func NewGather(addr *net.UDPAddr) *Gather
  • func (s *Gather) Gather() (xor.Key, []byte)
• type GatherLens
  • func NewGatherLens(addr *net.UDPAddr, focus xor.Key, k int) *GatherLens
  • func (s *GatherLens) Clear()
  • func (s *GatherLens) Gather() []byte
  • func (s *GatherLens) String() string
• type JoinFunc
• type Lens
  • func NewLens(focus xor.Key, k int) *Lens
  • func (f *Lens) Clear()
  • func (f *Lens) Remember(key xor.Key) bool
  • func (f *Lens) String() string
• type Msg
• type Scatter
  • func NewScatter(addr *net.UDPAddr, key xor.Key, payload []byte) *Scatter
  • func (s *Scatter) Scatter()
• type TraceMsg
  • func Decode(p []byte) (*TraceMsg, error)
  • func (m *TraceMsg) Encode() []byte
• type XDialBack
  • func (xd *XDialBack) OfferAddr(addr n.Addr)
• type YDialBack
  • func (y YDialBack) OfferAddr(addr n.Addr)

Functions

func NewDialBack

func NewDialBack() (*DialBack, *XDialBack)

Types

type Assembler

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

func NewAssembler

func NewAssembler(addr n.Addr, multicast *net.UDPAddr) *Assembler

func (*Assembler) AssembleClient

func (a *Assembler) AssembleClient() n.Addr

func (*Assembler) AssembleServer

func (a *Assembler) AssembleServer(joinServer JoinFunc)

type DialBack

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

func (*DialBack) ObtainAddr

func (d *DialBack) ObtainAddr() n.Addr

type Gather

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

func NewGather

func NewGather(addr *net.UDPAddr) *Gather

func (*Gather) Gather

func (s *Gather) Gather() (xor.Key, []byte)

type GatherLens

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

func NewGatherLens

func NewGatherLens(addr *net.UDPAddr, focus xor.Key, k int) *GatherLens

func (*GatherLens) Clear

func (s *GatherLens) Clear()

func (*GatherLens) Gather

func (s *GatherLens) Gather() []byte

func (*GatherLens) String

func (s *GatherLens) String() string

type JoinFunc

type JoinFunc func(n.Addr)

type Lens

type Lens struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLens

func NewLens(focus xor.Key, k int) *Lens

func (*Lens) Clear

func (f *Lens) Clear()

func (*Lens) Remember

func (f *Lens) Remember(key xor.Key) bool

func (*Lens) String

func (f *Lens) String() string

type Msg

type Msg struct {
	Key     xor.Key
	Payload []byte
}

type Scatter

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

func NewScatter

func NewScatter(addr *net.UDPAddr, key xor.Key, payload []byte) *Scatter

addr is a udp multicast address.

func (*Scatter) Scatter

func (s *Scatter) Scatter()

type TraceMsg

type TraceMsg struct {
	Origin string // "server" or "client"
	Addr   string // address of origin
}

func Decode

func Decode(p []byte) (*TraceMsg, error)

func (*TraceMsg) Encode

func (m *TraceMsg) Encode() []byte

type XDialBack

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

func (*XDialBack) OfferAddr

func (xd *XDialBack) OfferAddr(addr n.Addr)

type YDialBack

type YDialBack struct {
	circuit.PermX
}

func (YDialBack) OfferAddr

func (y YDialBack) OfferAddr(addr n.Addr)