service

Oct 22, 2022

Changes in this version

+ type AuthStatus struct

+ func NewAuthStatus(p2pService P2p, conf *config.Config, eventbus awlevent.Bus) *AuthStatus

+ func (s *AuthStatus) AddPeer(ctx context.Context, peerID peer.ID, name, alias string, confirmed bool)

+ func (s *AuthStatus) AuthStreamHandler(stream network.Stream)

+ func (s *AuthStatus) BackgroundExchangeStatusInfo(ctx context.Context)

+ func (s *AuthStatus) BackgroundRetryAuthRequests(ctx context.Context)

+ func (s *AuthStatus) BlockPeer(peerID peer.ID, name string)

+ func (s *AuthStatus) ExchangeNewStatusInfo(ctx context.Context, remotePeerID peer.ID, knownPeer config.KnownPeer) error

+ func (s *AuthStatus) ExchangeStatusInfoWithAllKnownPeers(ctx context.Context)

+ func (s *AuthStatus) GetIngoingAuthRequests() map[string]protocol.AuthPeer

+ func (s *AuthStatus) SendAuthRequest(ctx context.Context, peerID peer.ID, req protocol.AuthPeer) error

+ func (s *AuthStatus) StatusStreamHandler(stream network.Stream)

+ type P2p interface

+ ConnectPeer func(ctx context.Context, peerID peer.ID) error

+ NewStream func(ctx context.Context, id peer.ID, proto libp2pProtocol.ID) (network.Stream, error)

+ ProtectPeer func(id peer.ID)

+ SubscribeConnectionEvents func(onConnected, onDisconnected func(network.Network, network.Conn))

+ type Tunnel struct

+ func NewTunnel(p2pService P2p, device *vpn.Device, conf *config.Config) *Tunnel

+ func (t *Tunnel) Close()

+ func (t *Tunnel) RefreshPeersList()

+ func (t *Tunnel) StreamHandler(stream network.Stream)

+ type VpnPeer struct

+ func (vp *VpnPeer) Close(t *Tunnel)

+ func (vp *VpnPeer) Start(t *Tunnel)