Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

epdisc

package

Go to main page

Versions in this module

v0

v0.4.6

Dec 4, 2023

v0.4.5

Oct 10, 2023

v0.4.4

Aug 14, 2023

v0.4.3

Aug 14, 2023

Changes in this version

+ const ConnectionStateChecking

+ const ConnectionStateClosed

+ const ConnectionStateCompleted

+ const ConnectionStateConnected

+ const ConnectionStateDisconnected

+ const ConnectionStateFailed

+ const ConnectionStateNew

+ const StunMagicCookie

+ var Get = daemon.RegisterFeature(New, 50)

+ func CandidatePairCanBeNATted(cp *ice.CandidatePair) bool

+ func NftablesUserDataGet(udata []byte, styp NftablesUserDataType) []byte — linux/amd64

+ func NftablesUserDataGetInt(udata []byte, typ NftablesUserDataType) (uint32, bool) — linux/amd64

+ func NftablesUserDataGetString(udata []byte, typ NftablesUserDataType) (string, bool) — linux/amd64

+ func NftablesUserDataPut(udata []byte, typ NftablesUserDataType, data []byte) []byte — linux/amd64

+ func NftablesUserDataPutInt(udata []byte, typ NftablesUserDataType, num uint32) []byte — linux/amd64

+ func NftablesUserDataPutString(udata []byte, typ NftablesUserDataType, str string) []byte — linux/amd64

+ type BindProxy struct

+ func NewBindProxy(bind *wg.Bind, cp *ice.CandidatePair, conn *ice.Conn, logger *log.Logger) (*BindProxy, *net.UDPAddr, error)

+ func (p *BindProxy) BindClose() error

+ func (p *BindProxy) Close() error

+ func (p *BindProxy) ListenPort() (uint16, bool)

+ func (p *BindProxy) Receive(buf []byte) (int, wgconn.Endpoint, error)

+ func (p *BindProxy) Send(buf []byte, ep wgconn.Endpoint) (int, error)

+ func (p *BindProxy) SetMark(_ uint32) error

+ type ConnectionState = epdiscproto.ConnectionState

+ const ConnectionStateClosing

+ const ConnectionStateConnecting

+ const ConnectionStateCreating

+ const ConnectionStateGathering

+ const ConnectionStateGatheringLocal

+ const ConnectionStateGatheringRemote

+ const ConnectionStateIdle

+ const ConnectionStateRestarting

+ type Interface struct

+ Peers map[*daemon.Peer]*Peer

+ func New(di *daemon.Interface) (*Interface, error)

+ func (i *Interface) Close() error

+ func (i *Interface) Endpoint() (*net.UDPAddr, error)

+ func (i *Interface) Marshal() *epdiscproto.Interface

+ func (i *Interface) OnBindOpen(b *wg.Bind, _ uint16)

+ func (i *Interface) OnInterfaceModified(_ *daemon.Interface, _ *wg.Interface, m daemon.InterfaceModifier)

+ func (i *Interface) OnPeerAdded(cp *daemon.Peer)

+ func (i *Interface) OnPeerModified(cp *daemon.Peer, _ *wgtypes.Peer, m daemon.PeerModifier, _, _ []net.IPNet)

+ func (i *Interface) OnPeerRemoved(cp *daemon.Peer)

+ func (i *Interface) PeerByPublicKey(pk crypto.Key) *Peer

+ func (i *Interface) Start() error

+ type KernelConnProxy struct

+ func NewKernelConnProxy(bind *wg.Bind, cp *ice.CandidatePair, conn *ice.Conn, listenPort int, ...) (*KernelConnProxy, *net.UDPAddr, error)

+ func (p *KernelConnProxy) Close() error

+ func (p *KernelConnProxy) WriteKernel(b []byte) (int, error)

+ type KernelNATProxy struct

+ func NewKernelNATProxy(cp *ice.CandidatePair, nat *NAT, listenPort int, logger *log.Logger) (*KernelNATProxy, *net.UDPAddr, error)

+ func (p *KernelNATProxy) Close() error

+ type NAT struct

+ func NewNAT(_ string) (*NAT, error)

+ func NewNAT(ident string) (*NAT, error)

+ func (n *NAT) AddRule(r *nftables.Rule, comment string) (*NATRule, error)

+ func (n *NAT) Close() error

+ func (n *NAT) MasqueradeSourcePort(_, _ int, _ *net.UDPAddr) (*NATRule, error)

+ func (n *NAT) MasqueradeSourcePort(fromPort, toPort int, dest *net.UDPAddr) (*NATRule, error)

+ func (n *NAT) RedirectNonSTUN(_, _ int) (*NATRule, error)

+ func (n *NAT) RedirectNonSTUN(origPort, newPort int) (*NATRule, error)

+ type NATRule struct — darwin/amd64, js/wasm, windows/amd64

+ func (nr *NATRule) Delete() error

+ type NATRule struct — linux/amd64

+ type NftablesUserDataType byte — linux/amd64

+ const NftablesUserDataTypeComment

+ const NftablesUserDataTypeRuleID

+ type Peer struct

+ Interface *Interface

+ func NewPeer(cp *daemon.Peer, e *Interface) (*Peer, error)

+ func (p *Peer) Close() error

+ func (p *Peer) ConnectionState() ConnectionState

+ func (p *Peer) Marshal() *epdiscproto.Peer

+ func (p *Peer) OnBindOpen(b *wg.Bind, _ uint16)

+ func (p *Peer) OnSignalingMessage(_ *crypto.PublicKeyPair, msg *signaling.Message)

+ func (p *Peer) Reachability() coreproto.ReachabilityType

+ func (p *Peer) Restart() error

+ func (p *Peer) Resubscribe(ctx context.Context, skOld crypto.Key) error

+ type Proxy interface

+ type ProxyConn struct