natdiscovery

type Config struct {
	LocalEndpoint *endpoint.Local

	// These are hooks to allow unit tests to mock behavior.
	CreateServerConnection CreateServerConnectionFn
	FindSourceIP           FindSrcIPFunction
	RunLoop                func(stopCh <-chan struct{}, doCheck func())
}

type CreateServerConnectionFn func(port int32, family k8snet.IPFamily) (ServerConnection, error)

type FindSrcIPFunction func(destinationIP string, family k8snet.IPFamily) string

type Interface interface {
	Run(stopCh <-chan struct{}) error
	AddEndpoint(endpoint *v1.Endpoint, family k8snet.IPFamily)
	RemoveEndpoint(endpointName string)
	GetReadyChannel() chan *NATEndpointInfo
}

type NATEndpointInfo struct {
	Endpoint  v1.Endpoint
	UseNAT    bool
	UseIP     string
	UseFamily k8snet.IPFamily
}

type ServerConnection interface {
	Close() error
	ReadFromUDP(b []byte) (int, *net.UDPAddr, error)
	WriteToUDP(b []byte, addr *net.UDPAddr) (int, error)
}