multicast

Documentation

Index

• Variables
• type Multicast
  • func (m *Multicast) Done() <-chan struct{}
  • func (m *Multicast) Listen(ctx context.Context) (<-chan Response, error)
  • func (m *Multicast) Send(ctx context.Context, payload []byte) error
  • func (m *Multicast) SendErr() error
  • func (m *Multicast) Stop()
• type Response

Variables

var ErrNoIPv6 = errors.New("Couldn't find any IPv6 network intefaces")

ErrNoIPv6 error if no IPv6 interfaces were found

Types

type Multicast

type Multicast struct {
	Address string
	// contains filtered or unexported fields
}

Multicast struct

func (*Multicast) Done

func (m *Multicast) Done() <-chan struct{}

Done returns a channel that can be used to wait till send is stopped

func (*Multicast) Listen

func (m *Multicast) Listen(ctx context.Context) (<-chan Response, error)

Listen when a multicast is received we serve it

func (*Multicast) Send

func (m *Multicast) Send(ctx context.Context, payload []byte) error

Send out to try to find others listening

func (*Multicast) SendErr

func (m *Multicast) SendErr() error

SendErr returns any send errors TODO: Verify this is needed

func (*Multicast) Stop

func (m *Multicast) Stop()

Stop quits sending over multicast

type Response

type Response struct {
	Payload []byte
	SrcIP   net.IP
}

Response struct is sent over a channel when a pong is successful