p2p

Mar 5, 2020

Changes in this version

type Config

+ HostDNS string

+ LocalIP string

Jan 7, 2020

Changes in this version

+ type PeersProvider interface

+ Peers func() *peers.Status

type Service

+ func (s *Service) Peers() *peers.Status

Oct 22, 2019

Changes in this version

+ var ErrMessageNotMapped = errors.New("message type is not mapped to a PubSub topic")

+ var GossipTopicMappings = map[string]proto.Message

+ var GossipTypeMapping = make(map[reflect.Type]string)

+ var RPCTopicMappings = map[string]interface

+ var RPCTypeMapping = make(map[reflect.Type]string)

+ func MakePeer(addr string) (*peerstore.PeerInfo, error)

+ type Broadcaster interface

+ Broadcast func(context.Context, proto.Message) error

+ type Config struct

+ BootstrapNodeAddr []string

+ DataDir string

+ Discv5BootStrapAddr []string

+ EnableUPnP bool

+ Encoding string

+ HostAddress string

+ KademliaBootStrapAddr []string

+ MaxPeers uint

+ NoDiscovery bool

+ PrivateKey string

+ RelayNodeAddr string

+ StaticPeers []string

+ TCPPort uint

+ UDPPort uint

+ WhitelistCIDR string

+ type ConnectionHandler interface

+ AddConnectionHandler func(f func(ctx context.Context, id peer.ID) error)

+ AddDisconnectionHandler func(f func(ctx context.Context, id peer.ID) error)

+ type EncodingProvider interface

+ Encoding func() encoder.NetworkEncoding

+ type Listener interface

+ Close func()

+ Lookup func(enode.ID) []*enode.Node

+ LookupRandom func() []*enode.Node

+ Ping func(*enode.Node) error

+ ReadRandomNodes func([]*enode.Node) int

+ RequestENR func(*enode.Node) (*enode.Node, error)

+ Resolve func(*enode.Node) *enode.Node

+ Self func() *enode.Node

+ type P2P interface

+ type PeerManager interface

+ Disconnect func(peer.ID) error

+ PeerID func() peer.ID

+ type PubSubProvider interface

+ PubSub func() *pubsub.PubSub

+ type Sender interface

+ Send func(context.Context, interface{}, peer.ID) (network.Stream, error)

+ type Service struct

+ func NewService(cfg *Config) (*Service, error)

+ func (s *Service) AddConnectionHandler(reqFunc func(ctx context.Context, id peer.ID) error)

+ func (s *Service) AddDisconnectionHandler(handler func(ctx context.Context, id peer.ID) error)

+ func (s *Service) Broadcast(ctx context.Context, msg proto.Message) error

+ func (s *Service) Disconnect(pid peer.ID) error

+ func (s *Service) Encoding() encoder.NetworkEncoding

+ func (s *Service) InfoHandler(w http.ResponseWriter, _ *http.Request)

+ func (s *Service) PeerID() peer.ID

+ func (s *Service) PubSub() *pubsub.PubSub

+ func (s *Service) Send(ctx context.Context, message interface{}, pid peer.ID) (network.Stream, error)

+ func (s *Service) SetStreamHandler(topic string, handler network.StreamHandler)

+ func (s *Service) Start()

+ func (s *Service) Started() bool

+ func (s *Service) Status() error

+ func (s *Service) Stop() error

+ type SetStreamHandler interface

+ SetStreamHandler func(topic string, handler network.StreamHandler)