Versions in this module Expand all Collapse all v0 v0.9.3 Feb 12, 2021 Changes in this version + const BufferSize + const DiscoveryInterval + const DiscoveryMessageType + const DiscoveryServiceTag + const GoalMessageType + const MissionMessageType + const RecalculatorMessageType + const ReorganizationMessageType + const StateMessageType + const VisualizationAgentType + const VisualizationMessageType + var ChannelVisualization = make(chan Message, BufferSize) + var DiscoveryChannel = make(chan *DiscoveryMessage, BufferSize) + var GoalChannel = make(chan *GoalMessage, BufferSize) + var MissionChannel = make(chan *MissionMessage, BufferSize) + var RecalculationChannel = make(chan *DiscoveryMessage, BufferSize) + var ReorganizationChannel = make(chan *DiscoveryMessage, BufferSize) + var SelfId peer.ID + var StateChannel = make(chan *StateMessage, BufferSize) + func AnnounceSelf(metadata *agentlogic.Agent) + func ClosePath(disconnectedAgent agentlogic.Agent, messageType MessageType) + func InitCommunicationType(path string, messageType MessageType) + func InitD2DCommuncation(agentType agentlogic.AgentType) + func SendGoalFound(senderId string, goal agentlogic.Goal, posiition agentlogic.Vector, ...) error + func SendMission(senderId string, mission *agentlogic.Mission, channelPath string) error + func SendRecalculation(metadata agentlogic.Agent, selfId string) + func SendReorganization(metadata agentlogic.Agent, selfId string) + func SendState(state *agentlogic.State) + func SendVizGoal(goal GoalMessage) + type Channel struct + Close bool + Messages chan *Message + func JoinPath(ctx context.Context, ps *pubsub.PubSub, selfID peer.ID, path string, ...) (*Channel, error) + type DiscoveryMessage struct + Content agentlogic.Agent + MessageMeta MessageMeta + type GoalMessage struct + Content agentlogic.Goal + MessageMeta MessageMeta + Poi string + Position agentlogic.Vector + type Message interface + type MessageMeta struct + MsgType MessageType + SenderId string + SenderType agentlogic.AgentType + type MessageType int + type MissionMessage struct + Content agentlogic.Mission + MessageMeta MessageMeta + type StateMessage struct + Content agentlogic.State + MessageMeta MessageMeta + type VisualizationChannel struct + Messages chan *VisualizationMessage + func GetVizChannel() *VisualizationChannel + func InitVisualizationMessages(subscribe bool) *VisualizationChannel + type VisualizationMessage struct + ContentType MessageType + DiscoveryMessage agentlogic.Agent + GoalMessage GoalMessage + MissionBound orb.Bound + MissionMessage agentlogic.Mission + MsgType MessageType + SenderId string + SenderType agentlogic.AgentType + StateMessage agentlogic.State