Documentation ¶
Overview ¶
Package hive exposes the hive protocol implementation which is the discovery protocol used to inform and be informed about other peers in the network. It gossips about all peers by default and performs no specific prioritization about which peers are gossipped to others.
Index ¶
- Variables
- type Service
- func (s *Service) BroadcastPeers(ctx context.Context, addressee swarm.Address, peers ...swarm.Address) error
- func (s *Service) Close() error
- func (s *Service) Metrics() []prometheus.Collector
- func (s *Service) Protocol() p2p.ProtocolSpec
- func (s *Service) SetAddPeersHandler(h func(addr ...swarm.Address))
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrRateLimitExceeded = errors.New("rate limit exceeded")
)
Functions ¶
This section is empty.
Types ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func New ¶
func New(streamer p2p.StreamerPinger, addressbook addressbook.GetPutter, networkID uint64, logger logging.Logger) *Service
func (*Service) BroadcastPeers ¶
func (*Service) Metrics ¶ added in v0.5.3
func (s *Service) Metrics() []prometheus.Collector
func (*Service) Protocol ¶
func (s *Service) Protocol() p2p.ProtocolSpec
func (*Service) SetAddPeersHandler ¶ added in v0.2.0
Click to show internal directories.
Click to hide internal directories.