peer

Documentation

Index

• type Buffer
  • func NewPeerBuffer() *Buffer
  • func (peerBuffer *Buffer) AddPeer(peer string) bool
  • func (peerBuffer *Buffer) GetPeers() []string
  • func (peerBuffer *Buffer) GetRandomPeer() string
  • func (peerBuffer *Buffer) GetRandomPeers(noPeers int) []string
  • func (peerBuffer *Buffer) Length() int
  • func (peerBuffer *Buffer) RemovePeer(peer string)
• type Peer

Types

type Buffer

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

Buffer is the buffer with encoded peers.

func NewPeerBuffer

func NewPeerBuffer() *Buffer

NewPeerBuffer creates a PeerBuffer.

func (*Buffer) AddPeer

func (peerBuffer *Buffer) AddPeer(peer string) bool

AddPeer adds a peer in peers buffer. AddPeer returns `false` when the peer already exists in buffer and it wasn't added again.

func (*Buffer) GetPeers

func (peerBuffer *Buffer) GetPeers() []string

GetPeers returns a list of strings that contains peers.

func (*Buffer) GetRandomPeer

func (peerBuffer *Buffer) GetRandomPeer() string

GetRandomPeer returns random peer from peers buffer.

func (*Buffer) GetRandomPeers

func (peerBuffer *Buffer) GetRandomPeers(noPeers int) []string

GetRandomPeers returns a list of random peers from peers buffer.

func (*Buffer) Length

func (peerBuffer *Buffer) Length() int

Length returns length of peers buffer.

func (*Buffer) RemovePeer

func (peerBuffer *Buffer) RemovePeer(peer string)

RemovePeer removes a peer from peers buffer.

type Peer

type Peer interface {
	String() string
	Send(msg []byte, route string, peerToSend string) error
}

Peer is the interface of Host Peer.