p2p

package
v0.16.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 12, 2021 License: GPL-3.0 Imports: 23 Imported by: 0

Documentation

Overview

Package p2p is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Backoff 

type Backoff interface {
	Reset()
	Backoff() time.Duration
}

type Dialer 

type Dialer func(ctx context.Context, target string, opts ...grpc.DialOption) (conn *grpc.ClientConn, err error)

type MessageQueue 

type MessageQueue interface {
	Get() PeerMessage
}

type MockMessageQueue 

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

MockMessageQueue is a mock of MessageQueue interface

func NewMockMessageQueue 

func NewMockMessageQueue(ctrl *gomock.Controller) *MockMessageQueue

NewMockMessageQueue creates a new mock instance

func (*MockMessageQueue) EXPECT 

func (m *MockMessageQueue) EXPECT() *MockMessageQueueMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockMessageQueue) Get 

func (m *MockMessageQueue) Get() PeerMessage

Get mocks base method

type MockMessageQueueMockRecorder 

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

MockMessageQueueMockRecorder is the mock recorder for MockMessageQueue

func (*MockMessageQueueMockRecorder) Get 

func (mr *MockMessageQueueMockRecorder) Get() *gomock.Call

Get indicates an expected call of Get

type MockP2PNetwork 

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

MockP2PNetwork is a mock of P2PNetwork interface

func NewMockP2PNetwork 

func NewMockP2PNetwork(ctrl *gomock.Controller) *MockP2PNetwork

NewMockP2PNetwork creates a new mock instance

func (*MockP2PNetwork) AddRemoteNode 

func (m *MockP2PNetwork) AddRemoteNode(node model.NodeInfo) bool

AddRemoteNode mocks base method

func (*MockP2PNetwork) Broadcast 

func (m *MockP2PNetwork) Broadcast(message *network.NetworkMessage)

Broadcast mocks base method

func (*MockP2PNetwork) Configure 

func (m *MockP2PNetwork) Configure(config P2PNetworkConfig) error

Configure mocks base method

func (*MockP2PNetwork) Configured 

func (m *MockP2PNetwork) Configured() bool

Configured mocks base method

func (*MockP2PNetwork) EXPECT 

func (m *MockP2PNetwork) EXPECT() *MockP2PNetworkMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockP2PNetwork) Peers 

func (m *MockP2PNetwork) Peers() []Peer

Peers mocks base method

func (*MockP2PNetwork) ReceivedMessages 

func (m *MockP2PNetwork) ReceivedMessages() MessageQueue

ReceivedMessages mocks base method

func (*MockP2PNetwork) Send 

func (m *MockP2PNetwork) Send(peer model.PeerID, message *network.NetworkMessage) error

Send mocks base method

func (*MockP2PNetwork) Start 

func (m *MockP2PNetwork) Start() error

Start mocks base method

func (*MockP2PNetwork) Statistics 

func (m *MockP2PNetwork) Statistics() []stats.Statistic

Statistics mocks base method

func (*MockP2PNetwork) Stop 

func (m *MockP2PNetwork) Stop() error

Stop mocks base method

type MockP2PNetworkMockRecorder 

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

MockP2PNetworkMockRecorder is the mock recorder for MockP2PNetwork

func (*MockP2PNetworkMockRecorder) AddRemoteNode 

func (mr *MockP2PNetworkMockRecorder) AddRemoteNode(node interface{}) *gomock.Call

AddRemoteNode indicates an expected call of AddRemoteNode

func (*MockP2PNetworkMockRecorder) Broadcast 

func (mr *MockP2PNetworkMockRecorder) Broadcast(message interface{}) *gomock.Call

Broadcast indicates an expected call of Broadcast

func (*MockP2PNetworkMockRecorder) Configure 

func (mr *MockP2PNetworkMockRecorder) Configure(config interface{}) *gomock.Call

Configure indicates an expected call of Configure

func (*MockP2PNetworkMockRecorder) Configured 

func (mr *MockP2PNetworkMockRecorder) Configured() *gomock.Call

Configured indicates an expected call of Configured

func (*MockP2PNetworkMockRecorder) Peers 

func (mr *MockP2PNetworkMockRecorder) Peers() *gomock.Call

Peers indicates an expected call of Peers

func (*MockP2PNetworkMockRecorder) ReceivedMessages 

func (mr *MockP2PNetworkMockRecorder) ReceivedMessages() *gomock.Call

ReceivedMessages indicates an expected call of ReceivedMessages

func (*MockP2PNetworkMockRecorder) Send 

func (mr *MockP2PNetworkMockRecorder) Send(peer, message interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockP2PNetworkMockRecorder) Start 

func (mr *MockP2PNetworkMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockP2PNetworkMockRecorder) Statistics 

func (mr *MockP2PNetworkMockRecorder) Statistics() *gomock.Call

Statistics indicates an expected call of Statistics

func (*MockP2PNetworkMockRecorder) Stop 

func (mr *MockP2PNetworkMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type NumberOfPeersStatistic 

type NumberOfPeersStatistic struct {
	NumberOfPeers int
}

func (NumberOfPeersStatistic) Name 

func (n NumberOfPeersStatistic) Name() string

func (NumberOfPeersStatistic) String 

func (n NumberOfPeersStatistic) String() string

type P2PNetwork 

type P2PNetwork interface {
	stats.StatsProvider
	// Configure configures the P2PNetwork. Must be called before Start().
	Configure(config P2PNetworkConfig) error
	// Configured returns whether the system is configured or not
	Configured() bool
	// Start starts the P2P network on the local node.
	Start() error
	// Stop stops the P2P network on the local node.
	Stop() error
	// AddRemoteNode adds a remote node to the local node's view of the network, so it can become one of our peers.
	// If we'll try to connect to the remote node, true is returned, otherwise false.
	AddRemoteNode(node model.NodeInfo) bool
	// ReceivedMessages returns a queue containing all messages received from our peers. It must be drained, because when its buffer is full the producer (P2PNetwork) is blocked.
	ReceivedMessages() MessageQueue
	// Send sends a message to a specific peer.
	Send(peer model.PeerID, message *network.NetworkMessage) error
	// Broadcast sends a message to all peers.
	Broadcast(message *network.NetworkMessage)
	// Peers returns our peers (remote nodes we're currently connected to).
	Peers() []Peer
}

P2PNetwork defines the API for the P2P layer, used to connect to peers and exchange messages.

func NewP2PNetwork 

func NewP2PNetwork() P2PNetwork

func NewP2PNetworkWithOptions 

func NewP2PNetworkWithOptions(listener net.Listener, dialer Dialer) P2PNetwork

type P2PNetworkConfig 

type P2PNetworkConfig struct {
	NodeID        model.NodeID
	PublicAddress string
	// ListenAddress specifies the socket address the gRPC server should listen on.
	// If not set, the node will not accept incoming connections (but outbound connections can still be made).
	ListenAddress  string
	BootstrapNodes []string
	ClientCert     tls.Certificate
	// ServerCert specifies the TLS server certificate. If set the server should open a TLS socket, otherwise plain TCP.
	ServerCert tls.Certificate
	TrustStore cert.TrustStore
}

type Peer 

type Peer struct {
	NodeID  model.NodeID
	PeerID  model.PeerID
	Address string
}

func (Peer) String 

func (p Peer) String() string

type PeerMessage 

type PeerMessage struct {
	Peer    model.PeerID
	Message *network.NetworkMessage
}

type PeersStatistic 

type PeersStatistic struct {
	Peers []Peer
}

func (PeersStatistic) Name 

func (p PeersStatistic) Name() string

func (PeersStatistic) String 

func (p PeersStatistic) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.