Documentation ¶
Index ¶
Constants ¶
View Source
const ( // PluginName is the name of the analysis server plugin. PluginName = "Analysis-Server" // CfgAnalysisServerBindAddress defines the bind address of the analysis server. CfgAnalysisServerBindAddress = "analysis.server.bindAddress" // IdleTimeout defines the idle timeout of the read from the client's connection. IdleTimeout = 1 * time.Minute )
Variables ¶
View Source
var Events = struct { // AddNode triggers when adding a new node. AddNode *events.Event // RemoveNode triggers when removing a node. RemoveNode *events.Event // ConnectNodes triggers when connecting two nodes. ConnectNodes *events.Event // DisconnectNodes triggers when disconnecting two nodes. DisconnectNodes *events.Event // Error triggers when an error occurs. Error *events.Event // Heartbeat triggers when an heartbeat has been received. Heartbeat *events.Event // FPCHeartbeat triggers when an FPC heartbeat has been received. FPCHeartbeat *events.Event // MetricHeartbeat triggers when an MetricHeartbeat heartbeat has been received. MetricHeartbeat *events.Event }{ events.NewEvent(stringCaller), events.NewEvent(stringCaller), events.NewEvent(stringStringCaller), events.NewEvent(stringStringCaller), events.NewEvent(errorCaller), events.NewEvent(heartbeatPacketCaller), events.NewEvent(fpcHeartbeatPacketCaller), events.NewEvent(metricHeartbeatPacketCaller), }
Events holds the events of the analysis server package.
Functions ¶
func HandleConnection ¶
func HandleConnection(conn *network.ManagedConnection)
HandleConnection handles the given connection.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.