peer

package
v0.59.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 2, 2025 License: BSD-3-Clause Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EnvKeyNBForceRelay = "NB_FORCE_RELAY"
)

Variables

View Source 
var (
	ErrSignalIsNotReady = errors.New("signal is not ready")
)

Functions

func NewConnectionAlreadyClosed 

func NewConnectionAlreadyClosed(peer string) error

NewConnectionAlreadyClosed creates a new ConnectionAlreadyClosedError error

func NewConnectionClosedError 

func NewConnectionClosedError(peer string) error

NewConnectionClosedError creates a new ConnectionClosedError error

func NewConnectionDisconnectedError 

func NewConnectionDisconnectedError(peer string) error

NewConnectionDisconnectedError creates a new ConnectionDisconnectedError error

func NewConnectionTimeoutError 

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

NewConnectionTimeoutError creates a new ConnectionTimeoutError error

Types

type Conn 

type Conn struct {
	Log *log.Entry
	// contains filtered or unexported fields
}

func NewConn 

func NewConn(config ConnConfig, services ServiceDependencies) (*Conn, error)

NewConn creates a new not opened Conn to the remote peer. To establish a connection run Conn.Open

func (*Conn) AgentVersionString added in v0.45.0 

func (conn *Conn) AgentVersionString() string

func (*Conn) AllowedIP added in v0.35.0 

func (conn *Conn) AllowedIP() netip.Addr

AllowedIP returns the allowed IP of the remote peer

func (*Conn) Close 

func (conn *Conn) Close(signalToRemote bool)

Close closes this peer Conn issuing a close event to the Conn closeCh

func (*Conn) ConnID added in v0.45.0 

func (conn *Conn) ConnID() id.ConnID

func (*Conn) GetKey 

func (conn *Conn) GetKey() string

func (*Conn) IsConnected added in v0.45.0 

func (conn *Conn) IsConnected() bool

IsConnected returns true if the peer is connected

func (*Conn) OnRemoteAnswer 

func (conn *Conn) OnRemoteAnswer(answer OfferAnswer)

OnRemoteAnswer handles an offer from the remote peer and returns true if the message was accepted, false otherwise doesn't block, discards the message if connection wasn't ready

func (*Conn) OnRemoteCandidate 

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

OnRemoteCandidate Handles ICE connection Candidate provided by the remote peer.

func (*Conn) OnRemoteOffer 

func (conn *Conn) OnRemoteOffer(offer OfferAnswer)

func (*Conn) Open 

func (conn *Conn) Open(engineCtx context.Context) error

Open opens connection to the remote peer It will try to establish a connection using ICE and in parallel with relay. The higher priority connection type will be used.

func (*Conn) SetOnConnected added in v0.25.4 

func (conn *Conn) SetOnConnected(handler func(remoteWireGuardKey string, remoteRosenpassPubKey []byte, wireGuardIP string, remoteRosenpassAddr string))

SetOnConnected sets a handler function to be triggered by Conn when a new connection to a remote peer established

func (*Conn) SetOnDisconnected added in v0.25.4 

func (conn *Conn) SetOnDisconnected(handler func(remotePeer string))

SetOnDisconnected sets a handler function to be triggered by Conn when a connection to a remote disconnected

func (*Conn) WgConfig added in v0.22.0 

func (conn *Conn) WgConfig() WgConfig

WgConfig returns the WireGuard config

type ConnConfig 

type ConnConfig struct {
	// Key is a public key of a remote peer
	Key string
	// LocalKey is a public key of a local peer
	LocalKey string

	AgentVersion string

	Timeout time.Duration

	WgConfig WgConfig

	LocalWgPort int

	RosenpassConfig RosenpassConfig

	// ICEConfig ICE protocol configuration
	ICEConfig icemaker.Config
}

ConnConfig is a peer Connection configuration

type ConnStatus 

type ConnStatus int32

ConnStatus describe the status of a peer's connection 

const (
	// StatusIdle indicate the peer is in disconnected state
	StatusIdle ConnStatus = iota
	// StatusConnecting indicate the peer is in connecting state
	StatusConnecting
	// StatusConnected indicate the peer is in connected state
	StatusConnected
)

func (ConnStatus) String 

func (s ConnStatus) String() string

type ConnectionAlreadyClosedError 

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

ConnectionAlreadyClosedError is an error indicating that a peer Conn has been already closed and the invocation of the Close() method has been performed over a closed connection

func (*ConnectionAlreadyClosedError) Error 

func (e *ConnectionAlreadyClosedError) Error() string

type ConnectionClosedError 

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

ConnectionClosedError is an error indicating that a peer Conn has been forcefully closed

func (*ConnectionClosedError) Error 

func (e *ConnectionClosedError) Error() string

type ConnectionDisconnectedError 

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

ConnectionDisconnectedError is an error indicating that a peer Conn has ctx from the remote

func (*ConnectionDisconnectedError) Error 

func (e *ConnectionDisconnectedError) Error() string

type ConnectionTimeoutError 

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

ConnectionTimeoutError is an error indicating that a peer Conn has been timed out

func (*ConnectionTimeoutError) Error 

func (e *ConnectionTimeoutError) Error() string

type EndpointUpdater added in v0.59.1 

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

func NewEndpointUpdater added in v0.59.1 

func NewEndpointUpdater(log *logrus.Entry, wgConfig WgConfig, initiator bool) *EndpointUpdater

func (*EndpointUpdater) ConfigureWGEndpoint added in v0.59.1 

func (e *EndpointUpdater) ConfigureWGEndpoint(addr *net.UDPAddr, presharedKey *wgtypes.Key) error

ConfigureWGEndpoint sets up the WireGuard endpoint configuration. The initiator immediately configures the endpoint, while the non-initiator waits for a fallback period before configuring to avoid handshake congestion.

func (*EndpointUpdater) RemoveWgPeer added in v0.59.1 

func (e *EndpointUpdater) RemoveWgPeer() error

type EventListener added in v0.37.0 

type EventListener interface {
	OnEvent(event *proto.SystemEvent)
}

type EventQueue added in v0.37.0 

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

func NewEventQueue added in v0.37.0 

func NewEventQueue(size int) *EventQueue

func (*EventQueue) Add added in v0.37.0 

func (q *EventQueue) Add(event *proto.SystemEvent)

func (*EventQueue) GetAll added in v0.37.0 

func (q *EventQueue) GetAll() []*proto.SystemEvent

type EventSubscription added in v0.37.0 

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

func (*EventSubscription) Events added in v0.37.0 

func (s *EventSubscription) Events() <-chan *proto.SystemEvent

type FullStatus added in v0.14.3 

type FullStatus struct {
	Peers                 []State
	ManagementState       ManagementState
	SignalState           SignalState
	LocalPeerState        LocalPeerState
	RosenpassState        RosenpassState
	Relays                []relay.ProbeResult
	NSGroupStates         []NSGroupState
	NumOfForwardingRules  int
	LazyConnectionEnabled bool
}

FullStatus contains the full state held by the Status instance

type Handshaker added in v0.29.0 

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

func NewHandshaker added in v0.29.0 

func NewHandshaker(log *log.Entry, config ConnConfig, signaler *Signaler, ice *WorkerICE, relay *WorkerRelay) *Handshaker

func (*Handshaker) AddOnNewOfferListener added in v0.29.0 

func (h *Handshaker) AddOnNewOfferListener(offer func(remoteOfferAnswer *OfferAnswer))

func (*Handshaker) Listen added in v0.29.0 

func (h *Handshaker) Listen(ctx context.Context)

func (*Handshaker) OnRemoteAnswer added in v0.29.0 

func (h *Handshaker) OnRemoteAnswer(answer OfferAnswer)

OnRemoteAnswer handles an offer from the remote peer and returns true if the message was accepted, false otherwise doesn't block, discards the message if connection wasn't ready

func (*Handshaker) OnRemoteOffer added in v0.29.0 

func (h *Handshaker) OnRemoteOffer(offer OfferAnswer)

OnRemoteOffer handles an offer from the remote peer and returns true if the message was accepted, false otherwise doesn't block, discards the message if connection wasn't ready

func (*Handshaker) SendOffer added in v0.29.0 

func (h *Handshaker) SendOffer() error

type ICEConnInfo added in v0.29.0 

type ICEConnInfo struct {
	RemoteConn                 net.Conn
	RosenpassPubKey            []byte
	RosenpassAddr              string
	LocalIceCandidateType      string
	RemoteIceCandidateType     string
	RemoteIceCandidateEndpoint string
	LocalIceCandidateEndpoint  string
	Relayed                    bool
	RelayedOnLocal             bool
}

type ICESessionID added in v0.55.0 

type ICESessionID string

func ICESessionIDFromBytes added in v0.55.0 

func ICESessionIDFromBytes(b []byte) (ICESessionID, error)

func NewICESessionID added in v0.55.0 

func NewICESessionID() (ICESessionID, error)

NewICESessionID generates a new session ID for distinguishing sessions

func (ICESessionID) Bytes added in v0.55.0 

func (id ICESessionID) Bytes() ([]byte, error)

Bytes returns the raw bytes of the session ID for protobuf serialization

func (ICESessionID) String added in v0.55.0 

func (id ICESessionID) String() string

type IceCredentials 

type IceCredentials struct {
	UFrag string
	Pwd   string
}

IceCredentials ICE protocol credentials struct

type Listener added in v0.14.5 

type Listener interface {
	OnConnected()
	OnDisconnected()
	OnConnecting()
	OnDisconnecting()
	OnAddressChanged(string, string)
	OnPeersListChanged(int)
}

Listener is a callback type about the NetBird network connection state

type LocalPeerState added in v0.14.3 

type LocalPeerState struct {
	IP              string
	PubKey          string
	KernelInterface bool
	FQDN            string
	Routes          map[string]struct{}
}

LocalPeerState contains the latest state of the local peer

func (LocalPeerState) Clone added in v0.36.0 

func (l LocalPeerState) Clone() LocalPeerState

Clone returns a copy of the LocalPeerState

type ManagementState added in v0.14.3 

type ManagementState struct {
	URL       string
	Connected bool
	Error     error
}

ManagementState contains the latest state of a management connection

type NSGroupState added in v0.26.3 

type NSGroupState struct {
	ID      string
	Servers []netip.AddrPort
	Domains []string
	Enabled bool
	Error   error
}

NSGroupState represents the status of a DNS server group, including associated domains, whether it's enabled, and the last error message encountered during probing.

type OfferAnswer added in v0.8.12 

type OfferAnswer struct {
	IceCredentials IceCredentials
	// WgListenPort is a remote WireGuard listen port.
	// This field is used when establishing a direct WireGuard connection without any proxy.
	// We can set the remote peer's endpoint with this port.
	WgListenPort int

	// Version of NetBird Agent
	Version string
	// RosenpassPubKey is the Rosenpass public key of the remote peer when receiving this message
	// This value is the local Rosenpass server public key when sending the message
	RosenpassPubKey []byte
	// RosenpassAddr is the Rosenpass server address (IP:port) of the remote peer when receiving this message
	// This value is the local Rosenpass server address when sending the message
	RosenpassAddr string

	// relay server address
	RelaySrvAddress string
	// SessionID is the unique identifier of the session, used to discard old messages
	SessionID *ICESessionID
}

OfferAnswer represents a session establishment offer or answer

func (*OfferAnswer) SessionIDString added in v0.55.0 

func (oa *OfferAnswer) SessionIDString() string

type OfferListener added in v0.56.1 

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

func NewOfferListener added in v0.56.1 

func NewOfferListener(fn callbackFunc) *OfferListener

func (*OfferListener) Notify added in v0.56.1 

func (o *OfferListener) Notify(remoteOfferAnswer *OfferAnswer)

type RelayConnInfo added in v0.29.0 

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

type ResolvedDomainInfo added in v0.35.0 

type ResolvedDomainInfo struct {
	Prefixes     []netip.Prefix
	ParentDomain domain.Domain
}

type RosenpassConfig added in v0.41.3 

type RosenpassConfig struct {
	// RosenpassPubKey is this peer's Rosenpass public key
	PubKey []byte
	// RosenpassPubKey is this peer's RosenpassAddr server address (IP:port)
	Addr string

	PermissiveMode bool
}

type RosenpassState added in v0.26.1 

type RosenpassState struct {
	Enabled    bool
	Permissive bool
}

RosenpassState contains the latest state of the Rosenpass configuration

type RouterState added in v0.47.0 

type RouterState struct {
	Status  ConnStatus
	Relayed bool
	Latency time.Duration
}

RouterState status for router peers. This contains relevant fields for route manager

type ServiceDependencies added in v0.45.0 

type ServiceDependencies struct {
	StatusRecorder     *Status
	Signaler           *Signaler
	IFaceDiscover      stdnet.ExternalIFaceDiscover
	RelayManager       *relayClient.Manager
	SrWatcher          *guard.SRWatcher
	Semaphore          *semaphoregroup.SemaphoreGroup
	PeerConnDispatcher *dispatcher.ConnectionDispatcher
}

type SignalState added in v0.14.3 

type SignalState struct {
	URL       string
	Connected bool
	Error     error
}

SignalState contains the latest state of a signal connection

type Signaler added in v0.29.0 

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

func NewSignaler added in v0.29.0 

func NewSignaler(signal signal.Client, wgPrivateKey wgtypes.Key) *Signaler

func (*Signaler) Ready added in v0.29.0 

func (s *Signaler) Ready() bool

func (*Signaler) SignalAnswer added in v0.29.0 

func (s *Signaler) SignalAnswer(offer OfferAnswer, remoteKey string) error

func (*Signaler) SignalICECandidate added in v0.29.0 

func (s *Signaler) SignalICECandidate(candidate ice.Candidate, remoteKey string) error

func (*Signaler) SignalIdle added in v0.50.0 

func (s *Signaler) SignalIdle(remoteKey string) error

func (*Signaler) SignalOffer added in v0.29.0 

func (s *Signaler) SignalOffer(offer OfferAnswer, remoteKey string) error

type State added in v0.14.3 

type State struct {
	Mux                        *sync.RWMutex
	IP                         string
	PubKey                     string
	FQDN                       string
	ConnStatus                 ConnStatus
	ConnStatusUpdate           time.Time
	Relayed                    bool
	LocalIceCandidateType      string
	RemoteIceCandidateType     string
	LocalIceCandidateEndpoint  string
	RemoteIceCandidateEndpoint string
	RelayServerAddress         string
	LastWireguardHandshake     time.Time
	BytesTx                    int64
	BytesRx                    int64
	Latency                    time.Duration
	RosenpassEnabled           bool
	// contains filtered or unexported fields
}

State contains the latest state of a peer

func (*State) AddRoute added in v0.27.3 

func (s *State) AddRoute(network string)

AddRoute add a single route to routes map

func (*State) DeleteRoute added in v0.27.3 

func (s *State) DeleteRoute(network string)

DeleteRoute removes a route from the network amp

func (*State) GetRoutes added in v0.27.3 

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

GetRoutes return routes map

func (*State) SetRoutes added in v0.27.3 

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

SetRoutes set state routes

type Status added in v0.14.3 

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

Status holds a state of peers, signal, management connections and relays

func NewRecorder added in v0.14.3 

func NewRecorder(mgmAddress string) *Status

NewRecorder returns a new Status instance

func (*Status) AddLocalPeerStateRoute added in v0.39.0 

func (d *Status) AddLocalPeerStateRoute(route string, resourceId route.ResID)

AddLocalPeerStateRoute adds a route to the local peer state

func (*Status) AddPeer added in v0.14.3 

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

AddPeer adds peer to Daemon status map

func (*Status) AddPeerStateRoute added in v0.31.1 

func (d *Status) AddPeerStateRoute(peer string, route string, resourceId route.ResID) error

func (*Status) AddResolvedIPLookupEntry added in v0.40.0 

func (d *Status) AddResolvedIPLookupEntry(prefix netip.Prefix, resourceId route.ResID)

AddResolvedIPLookupEntry adds a resolved IP lookup entry

func (*Status) CheckRoutes added in v0.39.0 

func (d *Status) CheckRoutes(ip netip.Addr) ([]byte, bool)

CheckRoutes checks if the source and destination addresses are within the same route and returns the resource ID of the route that contains the addresses

func (*Status) CleanLocalPeerState added in v0.14.3 

func (d *Status) CleanLocalPeerState()

CleanLocalPeerState cleans local peer status

func (*Status) CleanLocalPeerStateRoutes added in v0.39.0 

func (d *Status) CleanLocalPeerStateRoutes()

CleanLocalPeerStateRoutes cleans all routes from the local peer state

func (*Status) ClientStart added in v0.14.5 

func (d *Status) ClientStart()

ClientStart will notify all listeners about the new service state

func (*Status) ClientStop added in v0.14.5 

func (d *Status) ClientStop()

ClientStop will notify all listeners about the new service state

func (*Status) ClientTeardown added in v0.14.6 

func (d *Status) ClientTeardown()

ClientTeardown will notify all listeners about the service is under teardown

func (*Status) DeleteResolvedDomainsStates added in v0.28.0 

func (d *Status) DeleteResolvedDomainsStates(domain domain.Domain)

func (*Status) FinishPeerListModifications added in v0.21.5 

func (d *Status) FinishPeerListModifications()

FinishPeerListModifications this event invoke the notification

func (*Status) ForwardingRules added in v0.38.0 

func (d *Status) ForwardingRules() []firewall.ForwardRule

func (*Status) GetDNSStates added in v0.26.3 

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

func (*Status) GetEventHistory added in v0.37.0 

func (d *Status) GetEventHistory() []*proto.SystemEvent

GetEventHistory returns all events in the queue

func (*Status) GetFullStatus added in v0.14.3 

func (d *Status) GetFullStatus() FullStatus

GetFullStatus gets full status

func (*Status) GetLazyConnection added in v0.45.0 

func (d *Status) GetLazyConnection() bool

func (*Status) GetLocalPeerState added in v0.26.3 

func (d *Status) GetLocalPeerState() LocalPeerState

GetLocalPeerState returns the local peer state

func (*Status) GetManagementState added in v0.25.5 

func (d *Status) GetManagementState() ManagementState

func (*Status) GetPeer added in v0.14.3 

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

GetPeer adds peer to Daemon status map

func (*Status) GetRelayStates added in v0.25.5 

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

GetRelayStates returns the stun/turn/permanent relay states

func (*Status) GetResolvedDomainsStates added in v0.28.0 

func (d *Status) GetResolvedDomainsStates() map[domain.Domain]ResolvedDomainInfo

func (*Status) GetRosenpassState added in v0.26.1 

func (d *Status) GetRosenpassState() RosenpassState

func (*Status) GetSignalState added in v0.25.5 

func (d *Status) GetSignalState() SignalState

func (*Status) IsLoginRequired added in v0.26.3 

func (d *Status) IsLoginRequired() bool

IsLoginRequired determines if a peer's login has expired.

func (*Status) MarkManagementConnected added in v0.14.3 

func (d *Status) MarkManagementConnected()

MarkManagementConnected sets ManagementState to connected

func (*Status) MarkManagementDisconnected added in v0.14.3 

func (d *Status) MarkManagementDisconnected(err error)

MarkManagementDisconnected sets ManagementState to disconnected

func (*Status) MarkSignalConnected added in v0.14.3 

func (d *Status) MarkSignalConnected()

MarkSignalConnected sets SignalState to connected

func (*Status) MarkSignalDisconnected added in v0.14.3 

func (d *Status) MarkSignalDisconnected(err error)

MarkSignalDisconnected sets SignalState to disconnected

func (*Status) PeerByIP added in v0.38.0 

func (d *Status) PeerByIP(ip string) (string, bool)

func (*Status) PeersStatus added in v0.46.0 

func (d *Status) PeersStatus() (*configurer.Stats, error)

func (*Status) PublishEvent added in v0.37.0 

func (d *Status) PublishEvent(
	severity proto.SystemEvent_Severity,
	category proto.SystemEvent_Category,
	msg string,
	userMsg string,
	metadata map[string]string,
)

PublishEvent adds an event to the queue and distributes it to all subscribers

func (*Status) RemoveConnectionListener added in v0.14.5 

func (d *Status) RemoveConnectionListener()

RemoveConnectionListener remove the listener from the notifier

func (*Status) RemoveLocalPeerStateRoute added in v0.39.0 

func (d *Status) RemoveLocalPeerStateRoute(route string)

RemoveLocalPeerStateRoute removes a route from the local peer state

func (*Status) RemovePeer added in v0.14.3 

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

RemovePeer removes peer from Daemon status map

func (*Status) RemovePeerStateRoute added in v0.31.1 

func (d *Status) RemovePeerStateRoute(peer string, route string) error

func (*Status) RemoveResolvedIPLookupEntry added in v0.40.0 

func (d *Status) RemoveResolvedIPLookupEntry(route string)

RemoveResolvedIPLookupEntry removes a resolved IP lookup entry

func (*Status) ReplaceOfflinePeers added in v0.14.3 

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

ReplaceOfflinePeers replaces

func (*Status) SetConnectionListener added in v0.15.0 

func (d *Status) SetConnectionListener(listener Listener)

SetConnectionListener set a listener to the notifier

func (*Status) SetIngressGwMgr added in v0.38.0 

func (d *Status) SetIngressGwMgr(ingressGwMgr *ingressgw.Manager)

func (*Status) SetRelayMgr added in v0.29.0 

func (d *Status) SetRelayMgr(manager *relayClient.Manager)

func (*Status) SetWgIface added in v0.46.0 

func (d *Status) SetWgIface(wgInterface WGIfaceStatus)

func (*Status) SubscribeToEvents added in v0.37.0 

func (d *Status) SubscribeToEvents() *EventSubscription

SubscribeToEvents returns a new event subscription

func (*Status) SubscribeToPeerStateChanges added in v0.46.0 

func (d *Status) SubscribeToPeerStateChanges(ctx context.Context, peerID string) *StatusChangeSubscription

func (*Status) UnsubscribeFromEvents added in v0.37.0 

func (d *Status) UnsubscribeFromEvents(sub *EventSubscription)

UnsubscribeFromEvents removes an event subscription

func (*Status) UnsubscribePeerStateChanges added in v0.46.0 

func (d *Status) UnsubscribePeerStateChanges(subscription *StatusChangeSubscription)

func (*Status) UpdateDNSStates added in v0.26.3 

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

func (*Status) UpdateLatency added in v0.26.4 

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

func (*Status) UpdateLazyConnection added in v0.45.0 

func (d *Status) UpdateLazyConnection(enabled bool)

func (*Status) UpdateLocalPeerState added in v0.14.3 

func (d *Status) UpdateLocalPeerState(localPeerState LocalPeerState)

UpdateLocalPeerState updates local peer status

func (*Status) UpdateManagementAddress added in v0.14.5 

func (d *Status) UpdateManagementAddress(mgmAddress string)

UpdateManagementAddress update the address of the management server

func (*Status) UpdatePeerFQDN added in v0.14.3 

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

UpdatePeerFQDN update peer's state fqdn only

func (*Status) UpdatePeerICEState added in v0.29.0 

func (d *Status) UpdatePeerICEState(receivedState State) error

func (*Status) UpdatePeerICEStateToDisconnected added in v0.29.0 

func (d *Status) UpdatePeerICEStateToDisconnected(receivedState State) error

func (*Status) UpdatePeerRelayedState added in v0.29.0 

func (d *Status) UpdatePeerRelayedState(receivedState State) error

func (*Status) UpdatePeerRelayedStateToDisconnected added in v0.29.0 

func (d *Status) UpdatePeerRelayedStateToDisconnected(receivedState State) error

func (*Status) UpdatePeerState added in v0.14.3 

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

UpdatePeerState updates peer status

func (*Status) UpdateRelayStates added in v0.25.5 

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

func (*Status) UpdateResolvedDomainsStates added in v0.28.0 

func (d *Status) UpdateResolvedDomainsStates(originalDomain domain.Domain, resolvedDomain domain.Domain, prefixes []netip.Prefix, resourceId route.ResID)

func (*Status) UpdateRosenpass added in v0.26.1 

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

UpdateRosenpass update the Rosenpass configuration

func (*Status) UpdateSignalAddress added in v0.14.5 

func (d *Status) UpdateSignalAddress(signalURL string)

UpdateSignalAddress update the address of the signal server

func (*Status) UpdateWireGuardPeerState added in v0.26.1 

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

UpdateWireGuardPeerState updates the WireGuard bits of the peer state

type StatusChangeSubscription added in v0.46.0 

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

func (*StatusChangeSubscription) Events added in v0.46.0 

func (s *StatusChangeSubscription) Events() chan map[string]RouterState

type WGIface added in v0.37.0 

type WGIface interface {
	UpdatePeer(peerKey string, allowedIps []netip.Prefix, keepAlive time.Duration, endpoint *net.UDPAddr, preSharedKey *wgtypes.Key) error
	RemovePeer(peerKey string) error
	GetStats() (map[string]configurer.WGStats, error)
	GetProxy() wgproxy.Proxy
	Address() wgaddr.Address
}

type WGIfaceStatus added in v0.46.0 

type WGIfaceStatus interface {
	FullStats() (*configurer.Stats, error)
}

type WGInterfaceStater added in v0.36.6 

type WGInterfaceStater interface {
	GetStats() (map[string]configurer.WGStats, error)
}

type WGWatcher added in v0.36.6 

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

func NewWGWatcher added in v0.36.6 

func NewWGWatcher(log *log.Entry, wgIfaceStater WGInterfaceStater, peerKey string, stateDump *stateDump) *WGWatcher

func (*WGWatcher) DisableWgWatcher added in v0.36.6 

func (w *WGWatcher) DisableWgWatcher()

DisableWgWatcher stops the WireGuard watcher and wait for the watcher to exit

func (*WGWatcher) EnableWgWatcher added in v0.36.6 

func (w *WGWatcher) EnableWgWatcher(parentCtx context.Context, onDisconnectedFn func())

EnableWgWatcher starts the WireGuard watcher. If it is already enabled, it will return immediately and do nothing.

type WgConfig added in v0.22.0 

type WgConfig struct {
	WgListenPort int
	RemoteKey    string
	WgInterface  WGIface
	AllowedIps   []netip.Prefix
	PreSharedKey *wgtypes.Key
}

type WorkerICE added in v0.29.0 

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

func NewWorkerICE added in v0.29.0 

func NewWorkerICE(ctx context.Context, log *log.Entry, config ConnConfig, conn *Conn, signaler *Signaler, ifaceDiscover stdnet.ExternalIFaceDiscover, statusRecorder *Status, hasRelayOnLocally bool) (*WorkerICE, error)

func (*WorkerICE) Close added in v0.29.0 

func (w *WorkerICE) Close()

func (*WorkerICE) GetLocalUserCredentials added in v0.29.0 

func (w *WorkerICE) GetLocalUserCredentials() (frag string, pwd string)

func (*WorkerICE) InProgress added in v0.55.0 

func (w *WorkerICE) InProgress() bool

func (*WorkerICE) OnNewOffer added in v0.29.0 

func (w *WorkerICE) OnNewOffer(remoteOfferAnswer *OfferAnswer)

func (*WorkerICE) OnRemoteCandidate added in v0.29.0 

func (w *WorkerICE) OnRemoteCandidate(candidate ice.Candidate, haRoutes route.HAMap)

OnRemoteCandidate Handles ICE connection Candidate provided by the remote peer.

func (*WorkerICE) SessionID added in v0.55.0 

func (w *WorkerICE) SessionID() ICESessionID

type WorkerRelay added in v0.29.0 

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

func NewWorkerRelay added in v0.29.0 

func NewWorkerRelay(ctx context.Context, log *log.Entry, ctrl bool, config ConnConfig, conn *Conn, relayManager *relayClient.Manager, stateDump *stateDump) *WorkerRelay

func (*WorkerRelay) CloseConn added in v0.29.0 

func (w *WorkerRelay) CloseConn()

func (*WorkerRelay) DisableWgWatcher added in v0.29.0 

func (w *WorkerRelay) DisableWgWatcher()

func (*WorkerRelay) EnableWgWatcher added in v0.29.0 

func (w *WorkerRelay) EnableWgWatcher(ctx context.Context)

func (*WorkerRelay) IsRelayConnectionSupportedWithPeer added in v0.29.0 

func (w *WorkerRelay) IsRelayConnectionSupportedWithPeer() bool

func (*WorkerRelay) OnNewOffer added in v0.29.0 

func (w *WorkerRelay) OnNewOffer(remoteOfferAnswer *OfferAnswer)

func (*WorkerRelay) RelayInstanceAddress added in v0.29.0 

func (w *WorkerRelay) RelayInstanceAddress() (string, error)

func (*WorkerRelay) RelayIsSupportedLocally added in v0.29.0 

func (w *WorkerRelay) RelayIsSupportedLocally() bool

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.