peer_manager

Documentation

Index

• type DuplicateChecker
• type Ip
• type MemoryPeerStorage
  • func (a *MemoryPeerStorage) Peers() ([]proto.TCPAddr, error)
  • func (a *MemoryPeerStorage) SavePeers(peers []proto.TCPAddr) error
• type PeerManager
• type PeerManagerImpl
  • func NewPeerManager(spawner PeerSpawner, storage PeerStorage, limitConnections int, ...) *PeerManagerImpl
  • func (a *PeerManagerImpl) AddAddress(ctx context.Context, addr string)
  • func (a *PeerManagerImpl) AddConnected(peer peer.Peer)
  • func (a *PeerManagerImpl) AskPeers()
  • 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() ([]proto.TCPAddr, error)
  • 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, reason string)
  • func (a *PeerManagerImpl) Suspended() []string
  • func (a *PeerManagerImpl) UpdateKnownPeers(known []proto.TCPAddr) 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 Ip

type Ip = [net.IPv6len]byte

type MemoryPeerStorage

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

func (*MemoryPeerStorage) Peers

func (a *MemoryPeerStorage) Peers() ([]proto.TCPAddr, error)

func (*MemoryPeerStorage) SavePeers

func (a *MemoryPeerStorage) SavePeers(peers []proto.TCPAddr) error

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, string)
	Suspended() []string
	AddConnected(peer.Peer)
	PeerWithHighestScore() (peer.Peer, *big.Int, bool)
	UpdateScore(p peer.Peer, score *proto.Score) error
	UpdateKnownPeers([]proto.TCPAddr) error
	KnownPeers() ([]proto.TCPAddr, error)
	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)

	// for all connected node send GetPeersMessage
	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 string)

func (*PeerManagerImpl) AddConnected

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

func (*PeerManagerImpl) AskPeers

func (a *PeerManagerImpl) AskPeers()

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)

Count 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() ([]proto.TCPAddr, error)

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, reason string)

func (*PeerManagerImpl) Suspended

func (a *PeerManagerImpl) Suspended() []string

func (*PeerManagerImpl) UpdateKnownPeers

func (a *PeerManagerImpl) UpdateKnownPeers(known []proto.TCPAddr) 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 {
	All() ([]proto.TCPAddr, error)
	Known() ([]proto.TCPAddr, error)
	AddKnown(proto.TCPAddr) error
	Add([]proto.TCPAddr) error
}