mesh

package

v0.6.0 Latest Latest Go to latest Published: Aug 17, 2026 License: AGPL-3.0-or-later Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/deepnlabs/uil

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type NodeMesh
- func NewNodeMesh(nodeID string, port int, handler func(env uil.UILEnvelope)) (*NodeMesh, error)
type PeerInfo

Constants ¶

View Source

const (
	DefaultMeshPort = 9090
	BroadcastAddr   = "255.255.255.255:9090"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type NodeMesh ¶

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

func NewNodeMesh ¶

func NewNodeMesh(nodeID string, port int, handler func(env uil.UILEnvelope)) (*NodeMesh, error)

NewNodeMesh initializes the UDP socket for local subnet broadcast/multicast

func (*NodeMesh) BroadcastGossip ¶

func (m *NodeMesh) BroadcastGossip(env *uil.UILEnvelope) error

BroadcastGossip sends a UILEnvelope pointer to all subnet peers

func (*NodeMesh) Close ¶

func (m *NodeMesh) Close()

func (*NodeMesh) GetActivePeers ¶

func (m *NodeMesh) GetActivePeers() []PeerInfo

GetActivePeers returns a snapshot of discovered nodes

func (*NodeMesh) Start ¶

func (m *NodeMesh) Start(ctx context.Context)

Start Listening and Heartbeat Loops

type PeerInfo ¶

type PeerInfo struct {
	NodeID   string    `json:"node_id"`
	Address  string    `json:"address"`
	LastSeen time.Time `json:"last_seen"`
	CPUTemp  float64   `json:"cpu_temp"`
}

Source Files ¶

View all Source files

discovery.go

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