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

peer

package

Go to main page

Versions in this module

v0

v0.0.11

Jun 5, 2024

v0.0.10

Jun 5, 2024

v0.0.9

Jun 5, 2024

v0.0.8

Jun 5, 2024

v0.0.7

Jun 5, 2024

v0.0.6

Jun 4, 2024

v0.0.5

Jun 4, 2024

v0.0.4

Jun 4, 2024

v0.0.3

Jun 4, 2024

v0.0.2

Jun 4, 2024

v0.0.1

Jun 4, 2024

Changes in this version

+ func NewConnectionAlreadyClosed(peer string) error

+ func NewConnectionClosedError(peer string) error

+ func NewConnectionDisconnectedError(peer string) error

+ func NewConnectionTimeoutError(peer string, timeout time.Duration) error

+ type AfterRemovePeerHookFunc func(connID nbnet.ConnectionID) error

+ type BeforeAddPeerHookFunc func(connID nbnet.ConnectionID, IP net.IP) error

+ type Conn struct

+ func NewConn(config ConnConfig, statusRecorder *Status, wgProxyFactory *wgproxy.Factory, ...) (*Conn, error)

+ func (conn *Conn) AddAfterRemovePeerHook(hook AfterRemovePeerHookFunc)

+ func (conn *Conn) AddBeforeAddPeerHook(hook BeforeAddPeerHookFunc)

+ func (conn *Conn) Close() error

+ func (conn *Conn) GetConf() ConnConfig

+ func (conn *Conn) GetKey() string

+ func (conn *Conn) OnRemoteAnswer(answer OfferAnswer) bool

+ func (conn *Conn) OnRemoteCandidate(candidate ice.Candidate, haRoutes route.HAMap)

+ func (conn *Conn) OnRemoteOffer(offer OfferAnswer) bool

+ func (conn *Conn) Open(ctx context.Context) error

+ func (conn *Conn) RegisterProtoSupportMeta(support []uint32)

+ func (conn *Conn) SetOnConnected(...)

+ func (conn *Conn) SetOnDisconnected(handler func(remotePeer string, wgIP string))

+ func (conn *Conn) SetSendSignalMessage(handler func(message *sProto.Message) error)

+ func (conn *Conn) SetSignalAnswer(handler func(answer OfferAnswer) error)

+ func (conn *Conn) SetSignalCandidate(handler func(candidate ice.Candidate) error)

+ func (conn *Conn) SetSignalOffer(handler func(offer OfferAnswer) error)

+ func (conn *Conn) Status() ConnStatus

+ func (conn *Conn) UpdateStunTurn(turnStun []*stun.URI)

+ func (conn *Conn) WgConfig() WgConfig

+ type ConnConfig struct

+ DisableIPv6Discovery bool

+ InterfaceBlackList []string

+ Key string

+ LocalKey string

+ LocalWgPort int

+ NATExternalIPs []string

+ RosenpassAddr string

+ RosenpassPubKey []byte

+ StunTurn []*stun.URI

+ Timeout time.Duration

+ UDPMux ice.UDPMux

+ UDPMuxSrflx ice.UniversalUDPMux

+ UserspaceBind bool

+ WgConfig WgConfig

+ type ConnStatus int

+ const StatusConnected

+ const StatusConnecting

+ const StatusDisconnected

+ func (s ConnStatus) String() string

+ type ConnectionAlreadyClosedError struct

+ func (e *ConnectionAlreadyClosedError) Error() string

+ type ConnectionClosedError struct

+ func (e *ConnectionClosedError) Error() string

+ type ConnectionDisconnectedError struct

+ func (e *ConnectionDisconnectedError) Error() string

+ type ConnectionTimeoutError struct

+ func (e *ConnectionTimeoutError) Error() string

+ type FullStatus struct

+ LocalPeerState LocalPeerState

+ ManagementState ManagementState

+ NSGroupStates []NSGroupState

+ Peers []State

+ Relays []relay.ProbeResult

+ RosenpassState RosenpassState

+ SignalState SignalState

+ type IceCredentials struct

+ Pwd string

+ UFrag string

+ type Listener interface

+ OnAddressChanged func(string, string)

+ OnConnected func()

+ OnConnecting func()

+ OnDisconnected func()

+ OnDisconnecting func()

+ OnPeersListChanged func(int)

+ type LocalPeerState struct

+ FQDN string

+ IP string

+ KernelInterface bool

+ PubKey string

+ Routes map[string]struct{}

+ type ManagementState struct

+ Connected bool

+ Error error

+ URL string

+ type ModeMessage struct

+ Direct bool

+ type NSGroupState struct

+ Domains []string

+ Enabled bool

+ Error error

+ ID string

+ Servers []string

+ type OfferAnswer struct

+ IceCredentials IceCredentials

+ RosenpassAddr string

+ RosenpassPubKey []byte

+ Version string

+ WgListenPort int

+ type RosenpassState struct

+ Enabled bool

+ Permissive bool

+ type SignalState struct

+ Connected bool

+ Error error

+ URL string

+ type State struct

+ BytesRx int64

+ BytesTx int64

+ ConnStatus ConnStatus

+ ConnStatusUpdate time.Time

+ Direct bool

+ FQDN string

+ IP string

+ LastWireguardHandshake time.Time

+ Latency time.Duration

+ LocalIceCandidateEndpoint string

+ LocalIceCandidateType string

+ Mux *sync.RWMutex

+ PubKey string

+ Relayed bool

+ RemoteIceCandidateEndpoint string

+ RemoteIceCandidateType string

+ RosenpassEnabled bool

+ func (s *State) AddRoute(network string)

+ func (s *State) DeleteRoute(network string)

+ func (s *State) GetRoutes() map[string]struct{}

+ func (s *State) SetRoutes(routes map[string]struct{})

+ type Status struct

+ func NewRecorder(mgmAddress string) *Status

+ func (d *Status) AddPeer(peerPubKey string, fqdn string) error

+ func (d *Status) CleanLocalPeerState()

+ func (d *Status) ClientStart()

+ func (d *Status) ClientStop()

+ func (d *Status) ClientTeardown()

+ func (d *Status) FinishPeerListModifications()

+ func (d *Status) GetDNSStates() []NSGroupState

+ func (d *Status) GetFullStatus() FullStatus

+ func (d *Status) GetLocalPeerState() LocalPeerState

+ func (d *Status) GetManagementState() ManagementState

+ func (d *Status) GetPeer(peerPubKey string) (State, error)

+ func (d *Status) GetPeerStateChangeNotifier(peer string) <-chan struct{}

+ func (d *Status) GetRelayStates() []relay.ProbeResult

+ func (d *Status) GetRosenpassState() RosenpassState

+ func (d *Status) GetSignalState() SignalState

+ func (d *Status) IsLoginRequired() bool

+ func (d *Status) MarkManagementConnected()

+ func (d *Status) MarkManagementDisconnected(err error)

+ func (d *Status) MarkSignalConnected()

+ func (d *Status) MarkSignalDisconnected(err error)

+ func (d *Status) RemoveConnectionListener()

+ func (d *Status) RemovePeer(peerPubKey string) error

+ func (d *Status) ReplaceOfflinePeers(replacement []State)

+ func (d *Status) SetConnectionListener(listener Listener)

+ func (d *Status) UpdateDNSStates(dnsStates []NSGroupState)

+ func (d *Status) UpdateLatency(pubKey string, latency time.Duration) error

+ func (d *Status) UpdateLocalPeerState(localPeerState LocalPeerState)

+ func (d *Status) UpdateManagementAddress(mgmAddress string)

+ func (d *Status) UpdatePeerFQDN(peerPubKey, fqdn string) error

+ func (d *Status) UpdatePeerState(receivedState State) error

+ func (d *Status) UpdateRelayStates(relayResults []relay.ProbeResult)

+ func (d *Status) UpdateRosenpass(rosenpassEnabled, rosenpassPermissive bool)

+ func (d *Status) UpdateSignalAddress(signalURL string)

+ func (d *Status) UpdateWireGuardPeerState(pubKey string, wgStats iface.WGStats) error

+ type WgConfig struct

+ AllowedIps string

+ PreSharedKey *wgtypes.Key

+ RemoteKey string

+ WgInterface *iface.WGIface

+ WgListenPort int