Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + const ColocationLimit + const InboundRatio + const MaxBackOffDuration + const MinBackOffDuration + const PeerConnected + const PeerConnecting + const PeerDisconnected + const PeerDisconnecting + type Status struct + func NewStatus(ctx context.Context, config *StatusConfig) *Status + func (p *Status) Active() []peer.ID + func (p *Status) Add(record *enr.Record, pid peer.ID, address ma.Multiaddr, ...) + func (p *Status) Address(pid peer.ID) (ma.Multiaddr, error) + func (p *Status) All() []peer.ID + func (p *Status) Bad() []peer.ID + func (p *Status) BestFinalized(maxPeers int, ourFinalizedEpoch types.Epoch) (types.Epoch, []peer.ID) + func (p *Status) BestNonFinalized(minPeers int, ourHeadEpoch types.Epoch) (types.Epoch, []peer.ID) + func (p *Status) ChainState(pid peer.ID) (*pb.Status, error) + func (p *Status) ChainStateLastUpdated(pid peer.ID) (time.Time, error) + func (p *Status) CommitteeIndices(pid peer.ID) ([]uint64, error) + func (p *Status) Connected() []peer.ID + func (p *Status) ConnectedPeerLimit() uint64 + func (p *Status) Connecting() []peer.ID + func (p *Status) ConnectionState(pid peer.ID) (peerdata.PeerConnectionState, error) + func (p *Status) Direction(pid peer.ID) (network.Direction, error) + func (p *Status) Disconnected() []peer.ID + func (p *Status) Disconnecting() []peer.ID + func (p *Status) ENR(pid peer.ID) (*enr.Record, error) + func (p *Status) HighestEpoch() types.Epoch + func (p *Status) Inactive() []peer.ID + func (p *Status) Inbound() []peer.ID + func (p *Status) InboundConnected() []peer.ID + func (p *Status) InboundLimit() int + func (p *Status) IsAboveInboundLimit() bool + func (p *Status) IsActive(pid peer.ID) bool + func (p *Status) IsBad(pid peer.ID) bool + func (p *Status) IsReadyToDial(pid peer.ID) bool + func (p *Status) MaxPeerLimit() int + func (p *Status) Metadata(pid peer.ID) (metadata.Metadata, error) + func (p *Status) NextValidTime(pid peer.ID) (time.Time, error) + func (p *Status) Outbound() []peer.ID + func (p *Status) OutboundConnected() []peer.ID + func (p *Status) PeersToPrune() []peer.ID + func (p *Status) Prune() + func (p *Status) RandomizeBackOff(pid peer.ID) + func (p *Status) Scorers() *scorers.Service + func (p *Status) SetChainState(pid peer.ID, chainState *pb.Status) + func (p *Status) SetConnectionState(pid peer.ID, state peerdata.PeerConnectionState) + func (p *Status) SetMetadata(pid peer.ID, metaData metadata.Metadata) + func (p *Status) SetNextValidTime(pid peer.ID, nextTime time.Time) + func (p *Status) SubscribedToSubnet(index uint64) []peer.ID + type StatusConfig struct + PeerLimit int + ScorerParams *scorers.Config Other modules containing this package github.com/prysmaticlabs/prysm github.com/prysmaticlabs/prysm/v3 github.com/prysmaticlabs/prysm/v4 github.com/prysmaticlabs/prysm/v5
Go to main page