node

package

v0.6.104 Latest Latest Go to latest Published: Mar 28, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 26 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
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 WithDialTimeout(t time.Duration) warpnet.SwarmOption
func WithDialTimeoutLocal(t time.Duration) warpnet.SwarmOption
type BackoffEnabler
type Streamer
type WarpNode
- func NewWarpNode(ctx context.Context, opts ...warpnet.WarpOption) (*WarpNode, error)

Constants ¶

View Source

const (
	DefaultTimeout                          = 60 * time.Second
	ErrPrivateKeyRequired warpnet.WarpError = "private key is required"
)

View Source

const ErrFieldNotFound warpnet.WarpError = "field not found"

View Source

const ErrMultipleIdentities warpnet.WarpError = "cannot specify multiple identities"

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(transport.NewCamouflageTransport),
	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 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

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