base

package

v0.2.473 Latest Latest Go to latest Published: May 18, 2025 License: GPL-2.0, GPL-3.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Warp-net/warpnet

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func DisableOption() func() libp2p.Option
func EnableAutoRelayWithStaticRelays(static []warpnet.PeerAddrInfo, currentNodeID warpnet.WarpPeerID) func() libp2p.Option
func WithDefaultTCPConnectionTimeout(t time.Duration) warpnet.TCPOption
func WithDialTimeout(t time.Duration) warpnet.SwarmOption
func WithDialTimeoutLocal(t time.Duration) warpnet.SwarmOption
type Streamer
type WarpNode
- func NewWarpNode(ctx context.Context, privKey warpnet.WarpPrivateKey, ...) (*WarpNode, error)

Constants ¶

View Source

const DefaultTimeout = 60 * time.Second

View Source

const ErrSelfRequest = warpnet.WarpError("self request is not allowed")

Variables ¶

This section is empty.

Functions ¶

func DisableOption ¶

func DisableOption() func() libp2p.Option

func EnableAutoRelayWithStaticRelays ¶

func EnableAutoRelayWithStaticRelays(static []warpnet.PeerAddrInfo, currentNodeID warpnet.WarpPeerID) func() libp2p.Option

func WithDefaultTCPConnectionTimeout ¶

func WithDefaultTCPConnectionTimeout(t time.Duration) warpnet.TCPOption

func WithDialTimeout ¶

func WithDialTimeout(t time.Duration) warpnet.SwarmOption

func WithDialTimeoutLocal ¶

func WithDialTimeoutLocal(t time.Duration) warpnet.SwarmOption

Types ¶

type Streamer ¶

type Streamer interface {
	Send(peerAddr warpnet.PeerAddrInfo, r stream.WarpRoute, data []byte) ([]byte, error)
}

type WarpNode ¶

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

func NewWarpNode ¶

func NewWarpNode(
	ctx context.Context,
	privKey warpnet.WarpPrivateKey,
	store warpnet.WarpPeerstore,
	ownerId string,
	psk security.PSK,
	listenAddr string,
	routingFn func(node warpnet.P2PNode) (warpnet.WarpPeerRouting, error),
) (*WarpNode, error)

func (*WarpNode) Connect ¶

func (n *WarpNode) Connect(p warpnet.PeerAddrInfo) error

func (*WarpNode) Mux ¶

func (n *WarpNode) Mux() warpnet.WarpProtocolSwitch

func (*WarpNode) Network ¶

func (n *WarpNode) Network() warpnet.WarpNetwork

func (*WarpNode) Node ¶

func (n *WarpNode) Node() warpnet.P2PNode

func (*WarpNode) NodeInfo ¶

func (n *WarpNode) NodeInfo() warpnet.NodeInfo

func (*WarpNode) Peerstore ¶

func (n *WarpNode) Peerstore() warpnet.WarpPeerstore

func (*WarpNode) SetStreamHandler ¶

func (n *WarpNode) SetStreamHandler(route stream.WarpRoute, handler warpnet.WarpStreamHandler)

func (*WarpNode) StopNode ¶

func (n *WarpNode) StopNode()

func (*WarpNode) Stream ¶

func (n *WarpNode) Stream(nodeId warpnet.WarpPeerID, path stream.WarpRoute, data any) (_ []byte, err error)

Source Files ¶

View all Source files

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