p2p

package

v0.0.0-...-29ced8b Latest Latest Go to latest Published: Oct 27, 2024 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func NOPHandshakeFunc(Peer) error

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

type DefaultDecoder struct{}

func (nd DefaultDecoder) Decode(r io.Reader, msg *Message) error

type GOBDecoder struct {
}

func (gd GOBDecoder) Decode(r io.Reader, msg *Message) error

type HandshakeFunc func(Peer) error

HandshakeFunc... ?

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

Message holds any arbitrary data that is being sent over the each transport between two nodes in the network.

type Peer interface {
}

Peer is an interface that represent the remote node.

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

TCPPeer represent the remote node over a TCP established connection.

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

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

func NewTCPTransport(opts TCPTransportOpts) *TCPTransport

func (t *TCPTransport) ListenAndAccept() error

type TCPTransportOpts struct {
	ListenAddr    string
	HandshakeFunc HandshakeFunc
	Decoder       Decoder
}

type Transport interface {
	ListenAndAccept() error
}

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