node

package
v0.5.84 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 23, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 26 Imported by: 0

Documentation

Index

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 

func EmptyOption() func() libp2p.Option

func EnableAutoRelayWithStaticRelays 

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

func WarpIdentity 

func WarpIdentity(privKey ed25519.PrivateKey) 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 BackoffEnabler 

type BackoffEnabler interface {
	IsBackoffEnabled(id warpnet.WarpPeerID) bool
	Reset(id warpnet.WarpPeerID)
}

type Streamer 

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

type WarpNode 

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

func NewWarpNode 

func NewWarpNode(
	ctx context.Context,
	opts ...warpnet.WarpOption,
) (*WarpNode, error)

func (*WarpNode) BaseNodeInfo 

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

func (*WarpNode) Connect 

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

func (*WarpNode) Node 

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

func (*WarpNode) SelfStream 

func (n *WarpNode) SelfStream(path stream.WarpRoute, data any) (_ []byte, err error)

func (*WarpNode) SetStreamHandlers 

func (n *WarpNode) SetStreamHandlers(handlers ...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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.