p2p

package

v0.0.0-...-fe73bcc Latest Latest Go to latest Published: Nov 18, 2018 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package p2p implements a TCP based perfect peer-to-peer link.

This section is empty.

View Source

var WithDefault = func(n *Node) {
	n.Node = node.New(node.WithDefault)
}

WithDefault can be used to instantiate a new node with default options.

func WithChannel(channel string) func(*Node)

WithChannel sets the RPC channel name when instantiating a new p2p node.

func WithKeepAlive(keepAlive time.Duration) func(*Node)

WithKeepAlive sets the TCP keepalive when instantiating a new p2p node (e.g. New(WithKeepAlive(1 * time.Seconds), ...)).

func WithNode(node link.Node) func(*Node)

WithNode sets the node when instantiating a new p2p node (e.g. New(WithNode(n), ...)).

type Node struct {
	link.Node
	// contains filtered or unexported fields
}

Node implements perfect peer-to-peer link.

func New(configs ...func(*Node)) *Node

New instantiates a new TCP based perfect peer-to-peer link.

func (n *Node) Deliver(f func(p link.Peer, m link.Message))

Deliver registers the deliver handler.

func (n *Node) Send(q link.Peer, m link.Message) error

Send requests to send message m to process q.

type Payload struct {
	ID      string
	Addr    net.Addr
	Message link.Message
}

Payload wraps the message and the ID of the sender.