node

package

v0.7.175 Latest Latest Go to latest Published: May 31, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 19 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 ¶

type DiscoveryHandler
type DistributedHashTableCloser
type MetricsOnlinePusher
type PubSubProvider
type RelayNode
- func NewRelayNode(ctx context.Context, privKey ed25519.PrivateKey, psk security.PSK, ...) (_ *RelayNode, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DiscoveryHandler ¶

type DiscoveryHandler interface {
	DiscoveryHandlerStream(pi warpnet.WarpAddrInfo)
	Run(n discovery.DiscoveryInfoStorer) error
	Close()
}

type DistributedHashTableCloser ¶

type DistributedHashTableCloser interface {
	Close()
}

type MetricsOnlinePusher ¶

type MetricsOnlinePusher interface {
	PushStatusOnline(nodeId string)
	PushStatusOffline(nodeId string)
}

type PubSubProvider ¶

type PubSubProvider interface {
	Run(m pubsub.PubsubServerNodeConnector)
	Close() error
	OwnerID() string
}

type RelayNode ¶

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

func NewRelayNode ¶

func NewRelayNode(
	ctx context.Context,
	privKey ed25519.PrivateKey,
	psk security.PSK,
	ownNodeId warpnet.WarpPeerID,
	selfHashHex string,
	m MetricsOnlinePusher,
) (_ *RelayNode, err error)

func (*RelayNode) GenericStream ¶

func (rn *RelayNode) GenericStream(nodeIdStr string, path stream.WarpRoute, data any) (_ []byte, err error)

func (*RelayNode) Network ¶

func (rn *RelayNode) Network() warpnet.WarpNetwork

func (*RelayNode) Node ¶

func (rn *RelayNode) Node() warpnet.P2PNode

func (*RelayNode) NodeInfo ¶

func (rn *RelayNode) NodeInfo() warpnet.NodeInfo

func (*RelayNode) Peerstore ¶

func (rn *RelayNode) Peerstore() warpnet.WarpPeerstore

func (*RelayNode) SelfStream ¶

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

func (*RelayNode) SetMaxNodePriority ¶

func (rn *RelayNode) SetMaxNodePriority(pid warpnet.WarpPeerID)

func (*RelayNode) SetMinNodePriority ¶

func (rn *RelayNode) SetMinNodePriority(pid warpnet.WarpPeerID)

func (*RelayNode) SetNodePriority ¶

func (rn *RelayNode) SetNodePriority(pid warpnet.WarpPeerID, r warpnet.WarpReachability)

func (*RelayNode) SimpleConnect ¶

func (rn *RelayNode) SimpleConnect(info warpnet.WarpAddrInfo) error

func (*RelayNode) Start ¶

func (rn *RelayNode) Start() (err error)

func (*RelayNode) Stop ¶

func (rn *RelayNode) Stop()

Source Files ¶

View all Source files

relay-node.go

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