discovery

Documentation

Index

• type Broadcaster
  • func NewBroadcaster(identity *protocol.Packet, interval time.Duration, logger *zap.Logger) *Broadcaster
  • func (b *Broadcaster) Run(ctx context.Context, shouldReduce func() bool)
• type BroadcasterController
  • func NewBroadcasterController(identity *protocol.Packet, interval time.Duration, logger *zap.Logger, ...) *BroadcasterController
  • func (bc *BroadcasterController) IsRunning() bool
  • func (bc *BroadcasterController) Start(parentCtx context.Context)
  • func (bc *BroadcasterController) Stop()
• type Listener
  • func NewListener(port int, localDeviceID string, ...) *Listener
  • func (l *Listener) Run(ctx context.Context)

Types

type Broadcaster

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

Broadcaster sends identity packets over UDP to advertise the local device.

func NewBroadcaster

func NewBroadcaster(identity *protocol.Packet, interval time.Duration, logger *zap.Logger) *Broadcaster

NewBroadcaster creates a UDP discovery broadcaster.

func (*Broadcaster) Run

func (b *Broadcaster) Run(ctx context.Context, shouldReduce func() bool)

Run periodically sends the identity packet to 255.255.255.255:1716. If shouldReduce is provided and returns true, the broadcast frequency is reduced to 60 seconds to save CPU and network resources while idle.

type BroadcasterController

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

BroadcasterController manages the broadcast lifecycle — start/stop on demand. Starts in stopped state. Broadcast is only active while Start() is in effect.

func NewBroadcasterController

func NewBroadcasterController(identity *protocol.Packet, interval time.Duration, logger *zap.Logger, shouldReduce func() bool) *BroadcasterController

NewBroadcasterController creates a controller that starts in stopped state.

func (*BroadcasterController) IsRunning

func (bc *BroadcasterController) IsRunning() bool

IsRunning reports whether the broadcast loop is currently active.

func (*BroadcasterController) Start

func (bc *BroadcasterController) Start(parentCtx context.Context)

Start launches the UDP broadcaster loop in a background goroutine using a child of parentCtx. No-op if already running.

func (*BroadcasterController) Stop

func (bc *BroadcasterController) Stop()

Stop cancels the broadcast loop. No-op if not running.

type Listener

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

Listener listens for UDP identity packets from other devices.

func NewListener

func NewListener(port int, localDeviceID string, callback func(ip net.IP, tcpPort int, identity *protocol.Packet), logger *zap.Logger) *Listener

NewListener creates a UDP discovery listener.

func (*Listener) Run

func (l *Listener) Run(ctx context.Context)

Run starts the UDP listener loop to parse incoming discovery broadcasts.