server

Documentation

Index

• Constants
• Variables
• func HandleConnection(conn *network.ManagedConnection)
• func Plugin() *node.Plugin
• func ReplayAutopeeringEvents(handlers *EventHandlers)
• func ShortNodeIDString(b []byte) string
• type AddNodeEvent
• type ConnectNodesEvent
• type DisconnectNodesEvent
• type EventHandlers
• type EventHandlersConsumer
• type NeighborMetric
• type NetworkMap
  • func NewNetworkMap(networkVersion string) *NetworkMap
  • func (nm *NetworkMap) NetworkGraph() *graph.Graph
  • func (nm *NetworkMap) NumOfNeighbors() map[string]*NeighborMetric
• type RemoveNodeEvent

Constants

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

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(addNodeCaller),
	events.NewEvent(removeNodeCaller),
	events.NewEvent(connectNodesCaller),
	events.NewEvent(disconnectNodesCaller),
	events.NewEvent(errorCaller),
	events.NewEvent(heartbeatPacketCaller),
	events.NewEvent(fpcHeartbeatPacketCaller),
	events.NewEvent(metricHeartbeatPacketCaller),
}

Events holds the events of the analysis server package.

var Networks = make(map[string]*NetworkMap)

Networks maps all available versions to network map

Functions

func HandleConnection

func HandleConnection(conn *network.ManagedConnection)

HandleConnection handles the given connection.

func Plugin

func Plugin() *node.Plugin

Plugin gets the plugin instance.

func ReplayAutopeeringEvents

func ReplayAutopeeringEvents(handlers *EventHandlers)

ReplayAutopeeringEvents replays recorded events on the given event handler.

func ShortNodeIDString

func ShortNodeIDString(b []byte) string

ShortNodeIDString returns the short nodeID as a string.

Types

type AddNodeEvent

type AddNodeEvent struct {
	NetworkVersion string
	NodeID         string
}

AddNodeEvent is the payload type of an AddNode event.

type ConnectNodesEvent

type ConnectNodesEvent struct {
	NetworkVersion string
	SourceID       string
	TargetID       string
}

ConnectNodesEvent is the payload type of a ConnectNodesEvent.

type DisconnectNodesEvent

type DisconnectNodesEvent struct {
	NetworkVersion string
	SourceID       string
	TargetID       string
}

DisconnectNodesEvent is the payload type f a DisconnectNodesEvent.

type EventHandlers

type EventHandlers struct {
	// Addnode defines the handler called when adding a new node.
	AddNode func(event *AddNodeEvent)
	// RemoveNode defines the handler called when adding removing a node.
	RemoveNode func(event *RemoveNodeEvent)
	// ConnectNodes defines the handler called when connecting two nodes.
	ConnectNodes func(event *ConnectNodesEvent)
	// DisconnectNodes defines the handler called when connecting two nodes.
	DisconnectNodes func(event *DisconnectNodesEvent)
}

EventHandlers holds the handler for each event of the record manager.

type EventHandlersConsumer

type EventHandlersConsumer = func(handler *EventHandlers)

EventHandlersConsumer defines the consumer function of an *EventHandlers.

type NeighborMetric

type NeighborMetric struct {
	Inbound  uint
	Outbound uint
}

NeighborMetric contains the number of inbound/outbound neighbors.

type NetworkMap

type NetworkMap struct {
	// contains filtered or unexported fields
}

NetworkMap contains information about the peer connections on a specific network.

func NewNetworkMap

func NewNetworkMap(networkVersion string) *NetworkMap

NewNetworkMap creates a new network map with a given network version

func (*NetworkMap) NetworkGraph

func (nm *NetworkMap) NetworkGraph() *graph.Graph

NetworkGraph returns the autopeering network graph for the current network.

func (*NetworkMap) NumOfNeighbors

func (nm *NetworkMap) NumOfNeighbors() map[string]*NeighborMetric

NumOfNeighbors returns a map of nodeIDs to their neighbor count.

type RemoveNodeEvent

type RemoveNodeEvent struct {
	NetworkVersion string
	NodeID         string
}

RemoveNodeEvent is the payload type of a RemoveNode event.