node

package

v0.5.141-dev Latest Latest Go to latest Published: Nov 20, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 19 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DistributedHashTableDiscoverer interface {
	ClosestPeers() []warpnet.WarpPeerID
	Close()
}

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

func NewModeratorNode(
	ctx context.Context,
	privKey ed25519.PrivateKey,
	psk security.PSK,
	selfHashHex string,
) (_ *ModeratorNode, err error)

func (mn *ModeratorNode) ClosestPeers() []warpnet.WarpPeerID

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

func (mn *ModeratorNode) ID() warpnet.WarpPeerID

func (mn *ModeratorNode) Node() warpnet.P2PNode

func (mn *ModeratorNode) NodeInfo() warpnet.NodeInfo

func (mn *ModeratorNode) SelfStream(_ stream.WarpRoute, _ any) (_ []byte, err error)

func (mn *ModeratorNode) Start() (err error)

func (mn *ModeratorNode) Stop()