Documentation
¶
Index ¶
- Constants
- Variables
- func EmptyOption() func() libp2p.Option
- func EnableAutoRelayWithStaticRelays(static []warpnet.WarpAddrInfo, currentNodeID warpnet.WarpPeerID) func() libp2p.Option
- func WarpIdentity(privKey ed25519.PrivateKey) libp2p.Option
- func WithDefaultTCPConnectionTimeout(t time.Duration) warpnet.TCPOption
- func WithDialTimeout(t time.Duration) warpnet.SwarmOption
- func WithDialTimeoutLocal(t time.Duration) warpnet.SwarmOption
- type BackoffEnabler
- type Streamer
- type WarpNode
- func (n *WarpNode) BaseNodeInfo() warpnet.NodeInfo
- func (n *WarpNode) Connect(p warpnet.WarpAddrInfo) error
- func (n *WarpNode) Node() warpnet.P2PNode
- func (n *WarpNode) SelfStream(path stream.WarpRoute, data any) (_ []byte, err error)
- func (n *WarpNode) SetStreamHandlers(handlers ...warpnet.WarpStreamHandler)
- func (n *WarpNode) StopNode()
- func (n *WarpNode) Stream(nodeId warpnet.WarpPeerID, path stream.WarpRoute, data any) (_ []byte, err error)
Constants ¶
View Source
const DefaultTimeout = 60 * time.Second
View Source
const ErrSelfRequest = warpnet.WarpError("self request is not allowed")
Variables ¶
View Source
var CommonOptions = []libp2p.Option{ libp2p.WithDialTimeout(DefaultTimeout), libp2p.SwarmOpts( WithDialTimeout(DefaultTimeout), WithDialTimeoutLocal(DefaultTimeout), ), libp2p.Transport(warpnet.NewTCPTransport, WithDefaultTCPConnectionTimeout(DefaultTimeout)), libp2p.Ping(true), libp2p.Security(warpnet.NoiseID, warpnet.NewNoise), libp2p.EnableAutoNATv2(), libp2p.EnableRelay(), libp2p.EnableRelayService(relay.WithDefaultResources()), libp2p.EnableHolePunching(), libp2p.EnableNATService(), libp2p.NATPortMap(), }
Functions ¶
func EmptyOption ¶ added in v0.2.494
func EnableAutoRelayWithStaticRelays ¶
func EnableAutoRelayWithStaticRelays(static []warpnet.WarpAddrInfo, currentNodeID warpnet.WarpPeerID) func() libp2p.Option
func WarpIdentity ¶ added in v0.3.110
func WarpIdentity(privKey ed25519.PrivateKey) libp2p.Option
func WithDialTimeout ¶
func WithDialTimeout(t time.Duration) warpnet.SwarmOption
func WithDialTimeoutLocal ¶
func WithDialTimeoutLocal(t time.Duration) warpnet.SwarmOption
Types ¶
type BackoffEnabler ¶ added in v0.2.481
type BackoffEnabler interface {
IsBackoffEnabled(id warpnet.WarpPeerID) bool
Reset(id warpnet.WarpPeerID)
}
type WarpNode ¶
type WarpNode struct {
// contains filtered or unexported fields
}
func NewWarpNode ¶
func (*WarpNode) BaseNodeInfo ¶ added in v0.3.8
func (*WarpNode) SelfStream ¶ added in v0.3.114
func (*WarpNode) SetStreamHandlers ¶ added in v0.3.110
func (n *WarpNode) SetStreamHandlers(handlers ...warpnet.WarpStreamHandler)
Source Files
Click to show internal directories.
Click to hide internal directories.