peer_manager

Documentation

Index

• type DuplicateChecker
• type PeerManager
• type PeerManagerImpl
  • func NewPeerManager(spawner PeerSpawner, storage PeerStorage, limitConnections int, ...) *PeerManagerImpl
  • func (a *PeerManagerImpl) AddAddress(ctx context.Context, addr proto.TCPAddr) error
  • func (a *PeerManagerImpl) AddConnected(peer peer.Peer)
  • func (a *PeerManagerImpl) AskPeers()
  • func (a *PeerManagerImpl) ClearSuspended(now time.Time)
  • func (a *PeerManagerImpl) Close()
  • func (a *PeerManagerImpl) Connect(ctx context.Context, addr proto.TCPAddr) error
  • func (a *PeerManagerImpl) Connected(p peer.Peer) (peer.Peer, bool)
  • func (a *PeerManagerImpl) ConnectedCount() int
  • func (a *PeerManagerImpl) Disconnect(p peer.Peer)
  • func (a *PeerManagerImpl) EachConnected(f func(peer peer.Peer, score *big.Int))
  • func (a *PeerManagerImpl) InOutCount() (in int, out int)
  • func (a *PeerManagerImpl) IsSuspended(p peer.Peer) bool
  • func (a *PeerManagerImpl) KnownPeers() []storage.KnownPeer
  • func (a *PeerManagerImpl) NewConnection(p peer.Peer) error
  • func (a *PeerManagerImpl) PeerWithHighestScore() (peer.Peer, *big.Int, bool)
  • func (a *PeerManagerImpl) RemoveSpawned(addr proto.TCPAddr)
  • func (a *PeerManagerImpl) Run(ctx context.Context)
  • func (a *PeerManagerImpl) Score(p peer.Peer) (*proto.Score, error)
  • func (a *PeerManagerImpl) SetConnectPeers(connect bool)
  • func (a *PeerManagerImpl) SpawnIncomingConnection(ctx context.Context, conn net.Conn) error
  • func (a *PeerManagerImpl) SpawnOutgoingConnections(ctx context.Context)
  • func (a *PeerManagerImpl) Spawned() []proto.IpPort
  • func (a *PeerManagerImpl) Suspend(p peer.Peer, suspendTime time.Time, reason string)
  • func (a *PeerManagerImpl) Suspended() []storage.SuspendedPeer
  • func (a *PeerManagerImpl) UpdateKnownPeers(known []storage.KnownPeer) error
  • func (a *PeerManagerImpl) UpdateScore(p peer.Peer, score *big.Int) error
• type PeerSpawner
• type PeerSpawnerImpl
  • func NewPeerSpawner(pool bytespool.Pool, parent peer.Parent, WavesNetwork string, ...) *PeerSpawnerImpl
  • func (a *PeerSpawnerImpl) SpawnIncoming(ctx context.Context, c net.Conn) error
  • func (a *PeerSpawnerImpl) SpawnOutgoing(ctx context.Context, address proto.TCPAddr) error
• type PeerStorage

Types

type DuplicateChecker

type DuplicateChecker interface {
	Add([]byte) bool
}

type PeerManager

type PeerManager interface {
	Connected(peer.Peer) (peer.Peer, bool)
	NewConnection(peer.Peer) error
	ConnectedCount() int
	InOutCount() (in int, out int)
	EachConnected(func(peer.Peer, *proto.Score))
	IsSuspended(peer.Peer) bool
	Suspend(peer peer.Peer, suspendTime time.Time, reason string)
	Suspended() []storage.SuspendedPeer
	AddConnected(peer.Peer)
	PeerWithHighestScore() (peer.Peer, *big.Int, bool)
	UpdateScore(p peer.Peer, score *proto.Score) error
	UpdateKnownPeers([]storage.KnownPeer) error
	KnownPeers() []storage.KnownPeer
	Close()
	SpawnOutgoingConnections(context.Context)
	SpawnIncomingConnection(ctx context.Context, conn net.Conn) error
	Spawned() []proto.IpPort
	Connect(context.Context, proto.TCPAddr) error
	Score(p peer.Peer) (*proto.Score, error)

	// AskPeers sends GetPeersMessage message to all connected nodes.
	AskPeers()

	Disconnect(peer.Peer)
}

type PeerManagerImpl

type PeerManagerImpl struct {
	// contains filtered or unexported fields
}

func NewPeerManager

func NewPeerManager(spawner PeerSpawner, storage PeerStorage,
	limitConnections int, version proto.Version) *PeerManagerImpl

func (*PeerManagerImpl) AddAddress

func (a *PeerManagerImpl) AddAddress(ctx context.Context, addr proto.TCPAddr) error

func (*PeerManagerImpl) AddConnected

func (a *PeerManagerImpl) AddConnected(peer peer.Peer)

func (*PeerManagerImpl) AskPeers

func (a *PeerManagerImpl) AskPeers()

func (*PeerManagerImpl) ClearSuspended

func (a *PeerManagerImpl) ClearSuspended(now time.Time)

func (*PeerManagerImpl) Close

func (a *PeerManagerImpl) Close()

func (*PeerManagerImpl) Connect

func (a *PeerManagerImpl) Connect(ctx context.Context, addr proto.TCPAddr) error

func (*PeerManagerImpl) Connected

func (a *PeerManagerImpl) Connected(p peer.Peer) (peer.Peer, bool)

func (*PeerManagerImpl) ConnectedCount

func (a *PeerManagerImpl) ConnectedCount() int

func (*PeerManagerImpl) Disconnect

func (a *PeerManagerImpl) Disconnect(p peer.Peer)

func (*PeerManagerImpl) EachConnected

func (a *PeerManagerImpl) EachConnected(f func(peer peer.Peer, score *big.Int))

func (*PeerManagerImpl) InOutCount

func (a *PeerManagerImpl) InOutCount() (in int, out int)

InOutCount counts connected peers, in - incoming connections out - outgoing connections

func (*PeerManagerImpl) IsSuspended

func (a *PeerManagerImpl) IsSuspended(p peer.Peer) bool

func (*PeerManagerImpl) KnownPeers

func (a *PeerManagerImpl) KnownPeers() []storage.KnownPeer

func (*PeerManagerImpl) NewConnection

func (a *PeerManagerImpl) NewConnection(p peer.Peer) error

func (*PeerManagerImpl) PeerWithHighestScore

func (a *PeerManagerImpl) PeerWithHighestScore() (peer.Peer, *big.Int, bool)

func (*PeerManagerImpl) RemoveSpawned

func (a *PeerManagerImpl) RemoveSpawned(addr proto.TCPAddr)

func (*PeerManagerImpl) Run

func (a *PeerManagerImpl) Run(ctx context.Context)

func (*PeerManagerImpl) Score

func (a *PeerManagerImpl) Score(p peer.Peer) (*proto.Score, error)

func (*PeerManagerImpl) SetConnectPeers

func (a *PeerManagerImpl) SetConnectPeers(connect bool)

func (*PeerManagerImpl) SpawnIncomingConnection

func (a *PeerManagerImpl) SpawnIncomingConnection(ctx context.Context, conn net.Conn) error

func (*PeerManagerImpl) SpawnOutgoingConnections

func (a *PeerManagerImpl) SpawnOutgoingConnections(ctx context.Context)

func (*PeerManagerImpl) Spawned

func (a *PeerManagerImpl) Spawned() []proto.IpPort

func (*PeerManagerImpl) Suspend

func (a *PeerManagerImpl) Suspend(p peer.Peer, suspendTime time.Time, reason string)

func (*PeerManagerImpl) Suspended

func (a *PeerManagerImpl) Suspended() []storage.SuspendedPeer

func (*PeerManagerImpl) UpdateKnownPeers

func (a *PeerManagerImpl) UpdateKnownPeers(known []storage.KnownPeer) error

func (*PeerManagerImpl) UpdateScore

func (a *PeerManagerImpl) UpdateScore(p peer.Peer, score *big.Int) error

type PeerSpawner

type PeerSpawner interface {
	SpawnOutgoing(ctx context.Context, addr proto.TCPAddr) error
	SpawnIncoming(ctx context.Context, c net.Conn) error
}

type PeerSpawnerImpl

type PeerSpawnerImpl struct {
	DuplicateChecker DuplicateChecker
	// contains filtered or unexported fields
}

func NewPeerSpawner

func NewPeerSpawner(pool bytespool.Pool, parent peer.Parent, WavesNetwork string, declAddr proto.TCPAddr, nodeName string, nodeNonce uint64, version proto.Version) *PeerSpawnerImpl

func (*PeerSpawnerImpl) SpawnIncoming

func (a *PeerSpawnerImpl) SpawnIncoming(ctx context.Context, c net.Conn) error

func (*PeerSpawnerImpl) SpawnOutgoing

func (a *PeerSpawnerImpl) SpawnOutgoing(ctx context.Context, address proto.TCPAddr) error

type PeerStorage

type PeerStorage interface {
	Known() []storage.KnownPeer
	AddKnown(known []storage.KnownPeer) error
	DeleteKnown(known []storage.KnownPeer) error
	DropKnown() error

	Suspended(now time.Time) []storage.SuspendedPeer
	AddSuspended(suspended []storage.SuspendedPeer) error
	IsSuspendedIP(ip storage.IP, now time.Time) bool
	IsSuspendedIPs(ips []storage.IP, now time.Time) []bool
	DeleteSuspendedByIP(suspended []storage.SuspendedPeer) error
	RefreshSuspended(now time.Time) error
	DropSuspended() error

	DropStorage() error
}