peer_manager

package
v0.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 8, 2020 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Ip 

type Ip = [net.IPv6len]byte

type JsonFileStorage added in v0.6.0 

type JsonFileStorage struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewJsonFileStorage added in v0.6.0 

func NewJsonFileStorage(p string) (*JsonFileStorage, error)

func (*JsonFileStorage) Peers added in v0.6.0 

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

func (*JsonFileStorage) SavePeers added in v0.6.0 

func (a *JsonFileStorage) SavePeers(addrs []proto.TCPAddr) error

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) *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 added in v0.5.0 

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 added in v0.5.0 

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 added in v0.5.0 

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 added in v0.5.0 

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 {
	// 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 {
	SavePeers([]proto.TCPAddr) error
	Peers() ([]proto.TCPAddr, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.