P2p_point_state.Info
type 'conn point_info = 'conn t
Type of info associated to a point.
val compare : 'conn point_info -> 'conn point_info -> int
val create :
?trusted:bool ->
?expected_peer_id:Mavryk_base.TzPervasives.P2p_peer.Id.t ->
Mavryk_base.TzPervasives.P2p_addr.t ->
Mavryk_base.TzPervasives.P2p_addr.port ->
'conn point_info
create ~trusted addr port
is a freshly minted point_info. If trusted
is true, this point is considered trusted and will be treated as such. If expected_peer_id
is specified, we check during a connection that the id
received is the same as the expected_peer_id
.
val trusted : 'conn point_info -> bool
trusted pi
is true
iff pi
has is trusted, i.e. "whitelisted".
val known_public : 'conn point_info -> bool
Points can announce themselves as either public or private. Private points will not be advertised to other nodes.
val set_trusted : 'conn point_info -> unit
val unset_trusted : 'conn point_info -> unit
val get_expected_peer_id :
'conn point_info ->
Mavryk_base.TzPervasives.P2p_peer.Id.t option
Return the expected_peer_id
given to create
.
val last_failed_connection :
'conn point_info ->
Mavryk_base.TzPervasives.Time.System.t option
val last_rejected_connection :
'conn point_info ->
(Mavryk_base.TzPervasives.P2p_peer.Id.t
* Mavryk_base.TzPervasives.Time.System.t)
option
val last_established_connection :
'conn point_info ->
(Mavryk_base.TzPervasives.P2p_peer.Id.t
* Mavryk_base.TzPervasives.Time.System.t)
option
val last_disconnection :
'conn point_info ->
(Mavryk_base.TzPervasives.P2p_peer.Id.t
* Mavryk_base.TzPervasives.Time.System.t)
option
val last_seen :
'conn point_info ->
(Mavryk_base.TzPervasives.P2p_peer.Id.t
* Mavryk_base.TzPervasives.Time.System.t)
option
last_seen pi
is the most recent of:
* last established connection * last rejected connection * last disconnection
val last_miss :
'conn point_info ->
Mavryk_base.TzPervasives.Time.System.t option
last_miss pi
is the most recent of:
* last failed connection * last rejected connection * last disconnection
val reset_reconnection_delay : 'conn point_info -> unit
val cannot_reconnect_yet :
now:Mavryk_base.TzPervasives.Time.System.t ->
'conn point_info ->
bool
val reconnection_time :
'conn point_info ->
Mavryk_base.TzPervasives.Time.System.t option
val point : 'conn point_info -> Mavryk_base.TzPervasives.P2p_point.Id.t
val log_incoming_rejection :
timestamp:Mavryk_base.TzPervasives.Time.System.t ->
'conn point_info ->
Mavryk_base.TzPervasives.P2p_peer.Id.t ->
unit
val events : 'conn t -> Mavryk_base.TzPervasives.P2p_point.Pool_event.t list
val watch :
'conn t ->
Mavryk_base.TzPervasives.P2p_point.Pool_event.t Lwt_stream.t
* Lwt_watcher.stopper