node

package

v0.5.91 Latest Latest Go to latest Published: Oct 26, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 22 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

type DistributedHashTableDiscoverer interface {
	ClosestPeers() ([]warpnet.WarpPeerID, error)
	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, error)

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(path stream.WarpRoute, data any) (_ []byte, err error)

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

func (mn *ModeratorNode) Stop()

type ProviderCloser interface {
	io.Closer
}