conn.go 825 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package udp
  2. import (
  3. "net/netip"
  4. "github.com/slackhq/nebula/config"
  5. )
  6. const MTU = 9001
  7. type EncReader func(
  8. addr netip.AddrPort,
  9. payload []byte,
  10. )
  11. type Conn interface {
  12. Rebind() error
  13. LocalAddr() (netip.AddrPort, error)
  14. ListenOut(r EncReader)
  15. WriteTo(b []byte, addr netip.AddrPort) error
  16. ReloadConfig(c *config.C)
  17. SupportsMultipleReaders() bool
  18. Close() error
  19. }
  20. type NoopConn struct{}
  21. func (NoopConn) Rebind() error {
  22. return nil
  23. }
  24. func (NoopConn) LocalAddr() (netip.AddrPort, error) {
  25. return netip.AddrPort{}, nil
  26. }
  27. func (NoopConn) ListenOut(_ EncReader) {
  28. return
  29. }
  30. func (NoopConn) SupportsMultipleReaders() bool {
  31. return false
  32. }
  33. func (NoopConn) WriteTo(_ []byte, _ netip.AddrPort) error {
  34. return nil
  35. }
  36. func (NoopConn) ReloadConfig(_ *config.C) {
  37. return
  38. }
  39. func (NoopConn) Close() error {
  40. return nil
  41. }