tunnel

Jan 9, 2024

Changes in this version

type EdgeTunnel

+ func (t *EdgeTunnel) CNIAdapterStreamHandler(stream network.Stream)

+ func (t *EdgeTunnel) GetCNIAdapterStream(opts ProxyOptions) (*StreamConn, error)

Mar 22, 2023

Changes in this version

+ func GetIPsFromInterfaces(listenInterfaces string) (ips []string, err error)

Mar 2, 2023

Changes in this version

type EdgeTunnel

+ func (t *EdgeTunnel) Shutdown()

type RelayMap

+ func (r RelayMap) ContainsPublicIP() bool

Jan 19, 2023

Changes in this version

+ func CreateLimitOpt(config *v1alpha1.TunnelLimitConfig) (libp2p.Option, error)

Oct 1, 2022

Changes in this version

+ const DailRetryTime

+ const DailSleepTime

+ const MaxReadSize

+ const Quic

+ const RetryInterval

+ const RetryTime

+ const TCP

+ const UDP

+ const Websocket

+ func AddCircuitAddrsToPeer(peer *peer.AddrInfo, relayPeers RelayMap) error

+ func AppendMultiaddrs(maddrs []ma.Multiaddr, dest ma.Multiaddr) []ma.Multiaddr

+ func BootstrapConnect(ctx context.Context, ph p2phost.Host, bootstrapPeers RelayMap) error

+ func FilterCircuitMaddr(maddrs []ma.Multiaddr) []ma.Multiaddr

+ func FilterPrivateMaddr(maddrs []ma.Multiaddr) []ma.Multiaddr

+ func GenerateKeyPairWithString(s string) (crypto.PrivKey, error)

+ func GenerateMultiAddrString(protocol, ip string, port int) string

+ func GeneratePSKReader(path string) (io.Reader, error)

+ func GeneratePeerInfo(hostname string, addrs []string) (*peer.AddrInfo, error)

+ func GenerateTransportOption(protocol string) libp2p.Option

+ func IsNoFindPeerError(err error) bool

+ func PeerIDFromString(s string) (peer.ID, error)

+ func Register(c *v1alpha1.EdgeTunnelConfig) error

+ func StringsToMaddrs(addrStrings []string) (mas []ma.Multiaddr, err error)

+ type EdgeTunnel struct

+ Config *v1alpha1.EdgeTunnelConfig

+ var Agent *EdgeTunnel

+ func (t *EdgeTunnel) Enable() bool

+ func (t *EdgeTunnel) GetProxyStream(opts ProxyOptions) (*StreamConn, error)

+ func (t *EdgeTunnel) Group() string

+ func (t *EdgeTunnel) Name() string

+ func (t *EdgeTunnel) Run()

+ func (t *EdgeTunnel) Start()

+ type ProxyOptions struct

+ IP string

+ NodeName string

+ Port int32

+ Protocol string

+ type RelayMap map[string]*peer.AddrInfo

+ func GenerateRelayMap(relayNodes []*v1alpha1.RelayNode, protocol string, listenPort int) RelayMap

+ type StreamAddr struct

+ func (sa *StreamAddr) Network() string

+ func (sa *StreamAddr) String() string

+ type StreamConn struct

+ func NewStreamConn(s network.Stream) *StreamConn

+ func (ns *StreamConn) LocalAddr() net.Addr

+ func (ns *StreamConn) RemoteAddr() net.Addr