client

package

Go to main page

Versions in this module

v0

v0.9.0

Nov 24, 2022

v0.8.0

Nov 8, 2022

v0.7.0

Nov 8, 2022

Changes in this version

type HolePunchState

+ NATMappings []nat.Mapping

v0.6.0

Nov 7, 2022

Changes in this version

+ var MaxPingCount = 10

+ var PingDuration = 10 * time.Second

+ var Version = "dev"

+ func Ping(ctx context.Context, h host.Host, p peer.ID) (<-chan ping.Result, network.Stream)

type HolePunchState

+ LatencyMeasurements []LatencyMeasurement

+ NetworkInformation *pb.NetworkInformation

+ OpenMaddrsAfter []multiaddr.Multiaddr

+ OpenMaddrsBefore []multiaddr.Multiaddr

+ ProtocolFilters []int32

+ RemoteRttAfterHolePunch time.Duration

type Host

+ func (h *Host) FilterLocal(remoteID peer.ID, maddrs []multiaddr.Multiaddr) []multiaddr.Multiaddr

+ func (h *Host) FilterRemote(remoteID peer.ID, maddrs []multiaddr.Multiaddr) []multiaddr.Multiaddr

+ func (h *Host) MeasurePing(ctx context.Context, pid peer.ID, mType pb.LatencyMeasurementType) <-chan LatencyMeasurement

+ func (h *Host) PingRelays(ctx context.Context, addrInfo map[peer.ID]*peer.AddrInfo) []LatencyMeasurement

+ func (h *Host) ProtocolFilters() []int32

+ type LatencyMeasurement struct

v0.6.0-rc1

Nov 7, 2022

v0.5.0

Oct 22, 2022

Changes in this version

+ var App = &cli.App

+ var CommunicationTimeout = 15 * time.Second

+ var RetryCount = 3

+ func RootAction(c *cli.Context) error

+ type HolePunchAttempt struct

+ DirectDialError string

+ ElapsedTime time.Duration

+ EndedAt time.Time

+ Error string

+ HostID peer.ID

+ OpenedAt time.Time

+ Outcome pb.HolePunchAttemptOutcome

+ RemoteAddrs []multiaddr.Multiaddr

+ RemoteID peer.ID

+ StartRTT time.Duration

+ StartedAt time.Time

+ func (hpa HolePunchAttempt) ToProto() *pb.HolePunchAttempt

+ type HolePunchState struct

+ ConnectEndedAt time.Time

+ ConnectStartedAt time.Time

+ EndedAt time.Time

+ Error string

+ HasDirectConns bool

+ HolePunchAttempts []*HolePunchAttempt

+ HostID peer.ID

+ LocalMaddrs []multiaddr.Multiaddr

+ OpenMaddrs []multiaddr.Multiaddr

+ Outcome pb.HolePunchOutcome

+ RemoteID peer.ID

+ RemoteMaddrs []multiaddr.Multiaddr

+ RouterHTML string

+ func NewHolePunchState(hostID peer.ID, remoteID peer.ID, rmaddrs []multiaddr.Multiaddr, ...) *HolePunchState

+ func (hps HolePunchState) ToProto(apiKey string) (*pb.TrackHolePunchRequest, error)

+ func (hps HolePunchState) TrackHolePunch(ctx context.Context, remoteID peer.ID, evtChan <-chan *holepunch.Event) HolePunchAttempt

+ type Host struct

+ func InitHost(c *cli.Context, privKey crypto.PrivKey) (*Host, error)

+ func (h *Host) Bootstrap(ctx context.Context) error

+ func (h *Host) Close() error

+ func (h *Host) GetAgentVersion(pid peer.ID) *string

+ func (h *Host) GetProtocols(pid peer.ID) []string

+ func (h *Host) HolePunch(ctx context.Context, addrInfo peer.AddrInfo) *HolePunchState

+ func (h *Host) RegisterPeerToTrace(pid peer.ID) <-chan *holepunch.Event

+ func (h *Host) Trace(evt *holepunch.Event)

+ func (h *Host) UnregisterPeerToTrace(pid peer.ID)

+ func (h *Host) WaitForDCUtRStream(pid peer.ID) <-chan struct{}

+ func (h *Host) WaitForPublicAddr(ctx context.Context) error

+ type Punchr struct

+ func NewPunchr(c *cli.Context) (*Punchr, error)

+ func (p Punchr) Bootstrap(ctx context.Context) error

+ func (p Punchr) Close() error

+ func (p Punchr) InitHosts(c *cli.Context) error

+ func (p Punchr) Register(c *cli.Context) error

+ func (p Punchr) RequestAddrInfo(ctx context.Context, clientID peer.ID) (*peer.AddrInfo, error)

+ func (p Punchr) StartHolePunching(ctx context.Context) error

+ func (p Punchr) TrackHolePunchResult(ctx context.Context, hps *HolePunchState) error

+ func (p Punchr) UpdateRouterHTML() error

+ type ResourceManager struct

+ func NewResourceManager() (*ResourceManager, error)

+ func (r *ResourceManager) OpenStream(p peer.ID, dir network.Direction) (network.StreamManagementScope, error)

+ func (r *ResourceManager) Register(pid peer.ID) <-chan struct{}

+ func (r *ResourceManager) Unregister(pid peer.ID)

+ type StreamManagementScope struct

+ func (s *StreamManagementScope) SetProtocol(proto protocol.ID) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL