connection

Documentation

Index

• type AddrBook
  • func NewAddrBook() AddrBook
• type DefaultAddrBook
  • func (ab *DefaultAddrBook) AddPeer(peer Peer) error
  • func (ab *DefaultAddrBook) GetPeerByID(id string) (Peer, bool)
  • func (ab *DefaultAddrBook) GetPeers() []Peer
  • func (ab *DefaultAddrBook) RemovePeerByID(id string)
• type DefaultPeer
  • func (p *DefaultPeer) CloseStream() error
  • func (p *DefaultPeer) Send(message services.P2PMessage) error
  • func (p *DefaultPeer) Start() error
• type Peer
  • func NewPeer(stream network.Stream) Peer

Types

type AddrBook

type AddrBook interface {
	GetPeers() []Peer
	GetPeerByID(id string) (Peer, bool)
	AddPeer(Peer Peer) error
	RemovePeerByID(id string)
}

func NewAddrBook

func NewAddrBook() AddrBook

type DefaultAddrBook

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

func (*DefaultAddrBook) AddPeer

func (ab *DefaultAddrBook) AddPeer(peer Peer) error

func (*DefaultAddrBook) GetPeerByID

func (ab *DefaultAddrBook) GetPeerByID(id string) (Peer, bool)

func (*DefaultAddrBook) GetPeers

func (ab *DefaultAddrBook) GetPeers() []Peer

func (*DefaultAddrBook) RemovePeerByID

func (ab *DefaultAddrBook) RemovePeerByID(id string)

type DefaultPeer

type DefaultPeer struct {
	ID string
	// contains filtered or unexported fields
}

func (*DefaultPeer) CloseStream

func (p *DefaultPeer) CloseStream() error

func (*DefaultPeer) Send

func (p *DefaultPeer) Send(message services.P2PMessage) error

func (*DefaultPeer) Start

func (p *DefaultPeer) Start() error

type Peer

type Peer interface {
	Start() error

	Send(message services.P2PMessage) error
	CloseStream() error
	// contains filtered or unexported methods
}

func NewPeer

func NewPeer(stream network.Stream) Peer