service

Documentation

Index

• type AuthStatus
  • func NewAuthStatus(p2pService P2p, conf *config.Config, eventbus awlevent.Bus) *AuthStatus
  • func (s *AuthStatus) AddPeer(ctx context.Context, peerID peer.ID, name, uniqAlias 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
• type Tunnel
  • 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
  • func (vp *VpnPeer) Close(t *Tunnel)
  • func (vp *VpnPeer) Start(t *Tunnel)

Types

type AuthStatus

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

func NewAuthStatus

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

func (*AuthStatus) AddPeer

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

func (*AuthStatus) AuthStreamHandler

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

func (*AuthStatus) BackgroundExchangeStatusInfo

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

func (*AuthStatus) BackgroundRetryAuthRequests

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

func (*AuthStatus) BlockPeer

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

func (*AuthStatus) ExchangeNewStatusInfo

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

func (*AuthStatus) ExchangeStatusInfoWithAllKnownPeers

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

func (*AuthStatus) GetIngoingAuthRequests

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

func (*AuthStatus) SendAuthRequest

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

func (*AuthStatus) StatusStreamHandler

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

type P2p

type P2p interface {
	ConnectPeer(ctx context.Context, peerID peer.ID) error
	NewStream(ctx context.Context, id peer.ID, proto libp2pProtocol.ID) (network.Stream, error)
	NewStreamWithDedicatedConn(ctx context.Context, id peer.ID, proto libp2pProtocol.ID) (network.Stream, error)
	SubscribeConnectionEvents(onConnected, onDisconnected func(network.Network, network.Conn))
	ProtectPeer(id peer.ID)
}

type Tunnel

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

func NewTunnel

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

func (*Tunnel) Close

func (t *Tunnel) Close()

func (*Tunnel) RefreshPeersList

func (t *Tunnel) RefreshPeersList()

func (*Tunnel) StreamHandler

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

type VpnPeer

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

func (*VpnPeer) Close

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

func (*VpnPeer) Start

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

TODO: remove Tunnel from VpnPeer dependencies