p2p

Documentation

Index

• func NOHandshakeFunc(Peer) error
• type Decoder
• type DefaultDecoder
  • func (dec DefaultDecoder) Decode(r io.Reader, msg *RPC) error
• type GOBdecoder
  • func (dec GOBdecoder) Decode(r io.Reader, msg *RPC) error
• type HandshakeFunc
• type Peer
• type RPC
• type TCPPeer
  • func NewTCPPeer(conn net.Conn, outBound bool) *TCPPeer
  • func (p *TCPPeer) Close() error
• type TCPTransport
  • func NewTCPTransport(opts TCPTransportOpts) *TCPTransport
  • func (t *TCPTransport) Consume() <-chan RPC
  • func (t *TCPTransport) ListenAndAccept() error
• type TCPTransportOpts
• type Transport

Functions

func NOHandshakeFunc

func NOHandshakeFunc(Peer) error

Types

type Decoder

type Decoder interface {
	Decode(io.Reader, *RPC) error
}

type DefaultDecoder

type DefaultDecoder struct{}

func (DefaultDecoder) Decode

func (dec DefaultDecoder) Decode(r io.Reader, msg *RPC) error

type GOBdecoder

type GOBdecoder struct{}

func (GOBdecoder) Decode

func (dec GOBdecoder) Decode(r io.Reader, msg *RPC) error

type HandshakeFunc

type HandshakeFunc func(Peer) error

type Peer

type Peer interface {
	Close() error
}

Interface that represents the remote node

type RPC

type RPC struct {
	From    net.Addr
	Payload []byte
}

type TCPPeer

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

func NewTCPPeer

func NewTCPPeer(conn net.Conn, outBound bool) *TCPPeer

func (*TCPPeer) Close

func (p *TCPPeer) Close() error

TCPPeer implements peer interface

type TCPTransport

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

Mutex will protect the peers

func NewTCPTransport

func NewTCPTransport(opts TCPTransportOpts) *TCPTransport

func (*TCPTransport) Consume

func (t *TCPTransport) Consume() <-chan RPC

Consume implements the transport interface. Returns read-only channel for reading the incoming messages.

func (*TCPTransport) ListenAndAccept

func (t *TCPTransport) ListenAndAccept() error

type TCPTransportOpts

type TCPTransportOpts struct {
	ListenAddr string
	HandShaker HandshakeFunc
	Decoder    Decoder
	OnPeer     func(Peer) error
}

type Transport

type Transport interface {
	ListenAndAccept() error
	Consume() <-chan RPC
}

Communication between nodes (tcp,UDP, websockets,....)