hive2

Documentation

Index

• type Config
• type Service
  • func New(streamer p2p.StreamerPinger, addressBook addressbook.GetPutter, ...) *Service
  • func (s *Service) BroadcastPeers(ctx context.Context, addressee boson.Address, peers ...boson.Address) error
  • func (s *Service) Close() error
  • func (s *Service) DoFindNode(ctx context.Context, target, peer boson.Address, pos []int32, limit int32) (res chan boson.Address, err error)
  • func (s *Service) IsHive2() bool
  • func (s *Service) IsStart() bool
  • func (s *Service) Metrics() []prometheus.Collector
  • func (s *Service) NotifyDiscoverWork(peers ...boson.Address)
  • func (s *Service) Protocol() p2p.ProtocolSpec
  • func (s *Service) SetAddPeersHandler(h func(addr ...boson.Address))
  • func (s *Service) SetConfig(config Config)
  • func (s *Service) Start()

Types

type Config

type Config struct {
	Kad               *kademlia.Kad
	Base              boson.Address
	AllowPrivateCIDRs bool
}

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 (s *Service) BroadcastPeers(ctx context.Context, addressee boson.Address, peers ...boson.Address) error

func (*Service) Close

func (s *Service) Close() error

func (*Service) DoFindNode

func (s *Service) DoFindNode(ctx context.Context, target, peer boson.Address, pos []int32, limit int32) (res chan boson.Address, err error)

func (*Service) IsHive2

func (s *Service) IsHive2() bool

func (*Service) IsStart

func (s *Service) IsStart() bool

func (*Service) Metrics

func (s *Service) Metrics() []prometheus.Collector

func (*Service) NotifyDiscoverWork

func (s *Service) NotifyDiscoverWork(peers ...boson.Address)

NotifyDiscoverWork notifies hive2 discover work.

func (*Service) Protocol

func (s *Service) Protocol() p2p.ProtocolSpec

func (*Service) SetAddPeersHandler

func (s *Service) SetAddPeersHandler(h func(addr ...boson.Address))

func (*Service) SetConfig

func (s *Service) SetConfig(config Config)

func (*Service) Start

func (s *Service) Start()