adf_core_python.core.component.communication package

adf_core_python.core.component.communication package#

Submodules#

adf_core_python.core.component.communication.channel_subscriber module#

class adf_core_python.core.component.communication.channel_subscriber.ChannelSubscriber#

Bases: ABC

abstractmethod subscribe(agent_info: AgentInfo, world_info: WorldInfo, scenario_info: ScenarioInfo) → list[int]#

Subscribe to the channel.

Parameters:
Returns:

The list of subscribed channels.

Return type:

list[int]

adf_core_python.core.component.communication.communication_message module#

class adf_core_python.core.component.communication.communication_message.CommunicationMessage(is_wireless_message: bool)#

Bases: ABC

abstractmethod get_bit_size() → int#
is_wireless_message() → bool#
abstractmethod to_bits() → bitarray#

adf_core_python.core.component.communication.communication_module module#

class adf_core_python.core.component.communication.communication_module.CommunicationModule#

Bases: ABC

abstractmethod receive(agent: Agent, message_manager: MessageManager) → None#
abstractmethod send(agent: Agent, message_manager: MessageManager) → None#

adf_core_python.core.component.communication.message_coordinator module#

class adf_core_python.core.component.communication.message_coordinator.MessageCoordinator#

Bases: ABC

abstractmethod coordinate(agent_info: AgentInfo, world_info: WorldInfo, scenario_info: ScenarioInfo, message_manager: MessageManager, send_message_list: list[CommunicationMessage], channel_send_message_list: list[list[CommunicationMessage]]) → None#

Module contents#

Contents