guard

type ConnStatus ¶ added in v0.70.0

type ConnStatus int

ConnStatus represents the connection state as seen by the guard.

const (
	// ConnStatusDisconnected means neither ICE nor Relay is connected.
	ConnStatusDisconnected ConnStatus = iota
	// ConnStatusPartiallyConnected means Relay is connected but ICE is not.
	ConnStatusPartiallyConnected
	// ConnStatusConnected means all required connections are established.
	ConnStatusConnected
)

type Guard ¶

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

Guard is responsible for the reconnection logic. It will trigger to send an offer to the peer then has connection issues. Watch these events: - Relay client reconnected to home server - Signal server connection state changed - ICE connection disconnected - Relayed connection disconnected - ICE candidate changes

func NewGuard(log *log.Entry, isConnectedFn connStatusFunc, timeout time.Duration, srWatcher *SRWatcher) *Guard

func (g *Guard) SetICEConnDisconnected()

func (g *Guard) SetRelayedConnDisconnected()

func (g *Guard) Start(ctx context.Context, eventCallback func())

type ICEMonitor ¶

type ICEMonitor struct {
	ReconnectCh chan struct{}
	// contains filtered or unexported fields
}

func NewICEMonitor(iFaceDiscover stdnet.ExternalIFaceDiscover, config icemaker.Config, period time.Duration) *ICEMonitor

func (cm *ICEMonitor) Start(ctx context.Context, onChanged func())

type SRWatcher ¶

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

func NewSRWatcher(signalClient chNotifier, relayManager chNotifier, iFaceDiscover stdnet.ExternalIFaceDiscover, iceConfig ice.Config) *SRWatcher

func (w *SRWatcher) Close()

func (w *SRWatcher) NewListener() chan struct{}

func (w *SRWatcher) RemoveListener(listenerChan chan struct{})

func (w *SRWatcher) Start(disableICEMonitor bool)