P2p_peer_state.InfoSourceval create :
created:Tezos_base.TzPervasives.Time.System.t ->
?trusted:bool ->
peer_metadata:'peer_meta ->
Tezos_base.TzPervasives.P2p_peer.Id.t ->
('conn, 'peer_meta, 'conn_meta) peer_infocreate ~trusted ~meta peer_id is a freshly minted peer_id info for peer_id.
val peer_id :
('conn, 'peer_meta, 'conn_meta) peer_info ->
Tezos_base.TzPervasives.P2p_peer.Id.tval created :
('conn, 'peer_meta, 'conn_meta) peer_info ->
Tezos_base.TzPervasives.Time.System.tval last_failed_connection :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionval last_rejected_connection :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionval last_established_connection :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionval last_disconnection :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionval last_seen :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionlast_seen gi is the most recent of:
* last established connection * last rejected connection * last disconnection
val last_miss :
('conn, 'peer_meta, 'conn_meta) peer_info ->
(Tezos_base.TzPervasives.P2p_connection.Id.t
* Tezos_base.TzPervasives.Time.System.t)
optionlast_miss gi is the most recent of:
* last failed connection * last rejected connection * last disconnection
val log_incoming_rejection :
timestamp:Tezos_base.TzPervasives.Time.System.t ->
('conn, 'peer_meta, 'conn_meta) peer_info ->
Tezos_base.TzPervasives.P2p_connection.Id.t ->
unitval events :
('conn, 'peer_meta, 'conn_meta) t ->
Tezos_base.TzPervasives.P2p_peer.Pool_event.t listval watch :
('conn, 'peer_meta, 'conn_meta) t ->
Tezos_base.TzPervasives.P2p_peer.Pool_event.t Lwt_stream.t
* Lwt_watcher.stopper