Package com.tnsai.coordination.groups.network

Class DefaultNetworkMesh

java.lang.Object

com.tnsai.coordination.groups.DefaultAgentGroup

com.tnsai.coordination.groups.network.DefaultNetworkMesh

All Implemented Interfaces:

com.tnsai.agents.groups.AgentGroup, NetworkMesh

public class DefaultNetworkMesh
extends DefaultAgentGroup
implements NetworkMesh

Default implementation of NetworkMesh.

Provides a peer-to-peer network with configurable topology, dynamic connections, and message routing through the mesh.

Constructor Summary

Constructors

Constructor	Description
DefaultNetworkMesh(String id, String name, String description, Topology topology, com.tnsai.agents.groups.GroupPolicy policy)	Creates a new DefaultNetworkMesh.

Method Summary

Modifier and Type	Method	Description
NetworkMeshResult	broadcastMessage(String message)	Broadcasts a message to all agents in the network.
void	connectPeers(String agentA, String agentB)	Connects two peers bidirectionally.
void	disconnectPeers(String agentA, String agentB)	Disconnects two peers bidirectionally.
List<String>	findShortestPath(String from, String to)	Finds the shortest path between two agents.
Set<String>	getConnectedPeers(String agentId)	Returns the directly connected peers of an agent.
DynamicConnections	getConnections()	Returns the connection manager.
Topology	getTopology()	Returns the network topology.
void	initializeTopology()	Initializes connections based on the configured topology.
boolean	removeMember(String agentId)
NetworkMeshResult	routeMessage(String from, String to, String message)	Routes a message from one agent to another through the mesh.
String	toString()

Methods inherited from class com.tnsai.coordination.groups.DefaultAgentGroup

addLifecycleListener, addMember, addMembershipListener, assignTask, broadcast, dissolve, electLeader, electLeader, findMembers, getDescription, getEventBus, getId, getLeader, getLifecycle, getMember, getMembers, getMembershipManager, getMetrics, getName, getPolicy, hasMember, notifyTaskComplete, notifyTaskFailed, removeLifecycleListener, removeMembershipListener, scatter, scatter, scatterAsync, setPolicy, start, stop, stopNow

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.tnsai.agents.groups.AgentGroup

addLifecycleListener, addMember, addMembershipListener, assignTask, broadcast, broadcast, dissolve, electLeader, electLeader, findMembers, getDescription, getEventBus, getId, getLeader, getLifecycle, getMember, getMemberCount, getMembers, getMembershipManager, getMetrics, getName, getPolicy, hasMember, isActive, isDissolved, removeLifecycleListener, removeMembershipListener, scatter, scatter, scatterAsync, setPolicy, start, stop, stopNow

Constructor Details

DefaultNetworkMesh

public DefaultNetworkMesh(String id,
 String name,
 String description,
 Topology topology,
 com.tnsai.agents.groups.GroupPolicy policy)

Creates a new DefaultNetworkMesh.

Parameters:

id - mesh ID

name - mesh name

description - mesh description

topology - network topology

policy - group policy

Method Details

getTopology

public Topology getTopology()

Description copied from interface: NetworkMesh

Returns the network topology.

Specified by:

getTopology in interface NetworkMesh

Returns:

topology type

connectPeers

public void connectPeers(String agentA,
 String agentB)

Description copied from interface: NetworkMesh

Connects two peers bidirectionally.

Specified by:

connectPeers in interface NetworkMesh

Parameters:

agentA - first agent ID

agentB - second agent ID

disconnectPeers

public void disconnectPeers(String agentA,
 String agentB)

Description copied from interface: NetworkMesh

Disconnects two peers bidirectionally.

Specified by:

disconnectPeers in interface NetworkMesh

Parameters:

agentA - first agent ID

agentB - second agent ID

getConnectedPeers

public Set<String> getConnectedPeers(String agentId)

Description copied from interface: NetworkMesh

Returns the directly connected peers of an agent.

Specified by:

getConnectedPeers in interface NetworkMesh

Parameters:

agentId - agent ID

Returns:

set of connected peer IDs

findShortestPath

public List<String> findShortestPath(String from,
 String to)

Description copied from interface: NetworkMesh

Finds the shortest path between two agents.

Specified by:

findShortestPath in interface NetworkMesh

Parameters:

from - source agent ID

to - target agent ID

Returns:

list of agent IDs forming the path, or empty if no path

routeMessage

public NetworkMeshResult routeMessage(String from,
 String to,
 String message)

Description copied from interface: NetworkMesh

Routes a message from one agent to another through the mesh.

Specified by:

routeMessage in interface NetworkMesh

Parameters:

from - source agent ID

to - target agent ID

message - message content

Returns:

routing result

broadcastMessage

public NetworkMeshResult broadcastMessage(String message)

Description copied from interface: NetworkMesh

Broadcasts a message to all agents in the network.

Specified by:

broadcastMessage in interface NetworkMesh

Parameters:

message - message content

Returns:

broadcast result with all responses

getConnections

public DynamicConnections getConnections()

Description copied from interface: NetworkMesh

Returns the connection manager.

Specified by:

getConnections in interface NetworkMesh

Returns:

dynamic connections

initializeTopology

public void initializeTopology()

Initializes connections based on the configured topology. Should be called after all members are added.

removeMember

public boolean removeMember(String agentId)

Specified by:

removeMember in interface com.tnsai.agents.groups.AgentGroup

Overrides:

removeMember in class DefaultAgentGroup

toString

public String toString()

Overrides:

toString in class DefaultAgentGroup