p2p

type Decoder ¶

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

type DefaultDecoder ¶

type DefaultDecoder struct{}

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

type GOBDecoder ¶

type GOBDecoder struct{}

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

type HandshakeFunc ¶

type HandshakeFunc func(Peer) error

type Peer ¶

type Peer interface {
	Close() error
}

Peer is an interface that represents the remote node.

type RPC ¶

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

RPC represents any arbitrary data that is being sent over the each transport between two nodes in the network

type TCPPeer ¶

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

TCPPeer represents the remote node over a TCP establised connection.

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

func (p *TCPPeer) Close() error

type TCPTransport ¶

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

func NewTCPTransport(opts TCPTransportOpts) *TCPTransport

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

func (t *TCPTransport) ListenAndAccept() error

type TCPTransportOpts ¶

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

type Transport ¶

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

Transport is anything that hundles the communication between the nodes in the network, this can be of the form (TCP, UDP, websockets, ...)