public interface Connector<A extends Agent<?>>
extends java.io.Serializable
Modifier and Type | Method and Description |
---|---|
void |
connectAgent(A agent,
GroupInformation sourceInfo,
GroupInformation targetInfo)
The method that creates links between the agent whose `agentInit` is in charge of.
|
static <A extends Agent<?>,L extends Link> |
createLink(long id,
A agent,
java.lang.Class<L> linkClass,
SerializableBiConsumer<A,L> linkDataInjector) |
static <A extends Agent<?>,L extends Link> |
createLinks(java.util.Collection<java.lang.Long> ids,
A agent,
java.lang.Class<L> linkClass,
SerializableBiConsumer<A,L> linkDataInjector) |
void connectAgent(A agent, GroupInformation sourceInfo, GroupInformation targetInfo)
agent
- : the agent to be connected. Links are to be added directly to this agent.sourceInfo
- : information of the source grouptargetInfo
- : information of the target groupstatic <A extends Agent<?>,L extends Link> void createLink(long id, A agent, java.lang.Class<L> linkClass, SerializableBiConsumer<A,L> linkDataInjector)
static <A extends Agent<?>,L extends Link> void createLinks(java.util.Collection<java.lang.Long> ids, A agent, java.lang.Class<L> linkClass, SerializableBiConsumer<A,L> linkDataInjector)