package selection import ( "github.com/iotaledger/goshimmer/packages/autopeering/peer" "github.com/iotaledger/goshimmer/packages/autopeering/salt" "github.com/iotaledger/hive.go/events" ) // Events contains all the events that are triggered during the neighbor selection. var Events = struct { // A SaltUpdated event is triggered, when the private and public salt were updated. SaltUpdated *events.Event // An OutgoingPeering event is triggered, when a valid response of PeeringRequest has been received. OutgoingPeering *events.Event // An IncomingPeering event is triggered, when a valid PeerRequest has been received. IncomingPeering *events.Event // A Dropped event is triggered, when a neighbor is dropped or when a drop message is received. Dropped *events.Event }{ SaltUpdated: events.NewEvent(saltUpdatedCaller), OutgoingPeering: events.NewEvent(peeringCaller), IncomingPeering: events.NewEvent(peeringCaller), Dropped: events.NewEvent(droppedCaller), } // SaltUpdatedEvent bundles the information sent in the SaltUpdated event. type SaltUpdatedEvent struct { Self peer.ID // ID of the peer triggering the event. Public, Private *salt.Salt // the updated salt } // PeeringEvent bundles the information sent in the OutgoingPeering and IncomingPeering event. type PeeringEvent struct { Self peer.ID // ID of the peer triggering the event. Peer *peer.Peer // peering partner Status bool // true, when the peering partner has accepted the request } // DroppedEvent bundles the information sent in Dropped events. type DroppedEvent struct { Self peer.ID // ID of the peer triggering the event. DroppedID peer.ID // ID of the peer that gets dropped. } func saltUpdatedCaller(handler interface{}, params ...interface{}) { handler.(func(*SaltUpdatedEvent))(params[0].(*SaltUpdatedEvent)) } func peeringCaller(handler interface{}, params ...interface{}) { handler.(func(*PeeringEvent))(params[0].(*PeeringEvent)) } func droppedCaller(handler interface{}, params ...interface{}) { handler.(func(*DroppedEvent))(params[0].(*DroppedEvent)) }