simulations

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: May 9, 2022 License: GPL-3.0 Imports: 24 Imported by: 0

README

devp2p Simulations

The p2p/simulations package implements a simulation framework that supports creating a collection of devp2p nodes, connecting them to form a simulation network, performing simulation actions in that network and then extracting useful information.

Nodes

Each node in a simulation network runs multiple services by wrapping a collection of objects which implement the node.Service interface meaning they:

  • can be started and stopped
  • run p2p protocols
  • expose RPC APIs

This means that any object which implements the node.Service interface can be used to run a node in the simulation.

Services

Before running a simulation, a set of service initializers must be registered which can then be used to run nodes in the network.

A service initializer is a function with the following signature:

func(ctx *adapters.ServiceContext) (node.Service, error)

These initializers should be registered by calling the adapters.RegisterServices function in an init() hook:

func init() {
	adapters.RegisterServices(adapters.Services{
		"service1": initService1,
		"service2": initService2,
	})
}

Node Adapters

The simulation framework includes multiple "node adapters" which are responsible for creating an environment in which a node runs.

SimAdapter

The SimAdapter runs nodes in-memory, connecting them using an in-memory, synchronous net.Pipe and connecting to their RPC server using an in-memory rpc.Client.

ExecAdapter

The ExecAdapter runs nodes as child processes of the running simulation.

It does this by executing the binary which is running the simulation but setting argv[0] (i.e. the program name) to p2p-node which is then detected by an init hook in the child process which runs the node.Service using the devp2p node stack rather than executing main().

The nodes listen for devp2p connections and WebSocket RPC clients on random localhost ports.

Network

A simulation network is created with an ID and default service. The default service is used if a node is created without an explicit service. The network has exposed methods for creating, starting, stopping, connecting and disconnecting nodes. It also emits events when certain actions occur.

Events

A simulation network emits the following events:

  • node event - when nodes are created / started / stopped
  • connection event - when nodes are connected / disconnected
  • message event - when a protocol message is sent between two nodes

The events have a "control" flag which when set indicates that the event is the outcome of a controlled simulation action (e.g. creating a node or explicitly connecting two nodes).

This is in contrast to a non-control event, otherwise called a "live" event, which is the outcome of something happening in the network as a result of a control event (e.g. a node actually started up or a connection was actually established between two nodes).

Live events are detected by the simulation network by subscribing to node peer events via RPC when the nodes start up.

Testing Framework

The Simulation type can be used in tests to perform actions in a simulation network and then wait for expectations to be met.

With a running simulation network, the Simulation.Run method can be called with a Step which has the following fields:

  • Action - a function that performs some action in the network

  • Expect - an expectation function which returns whether or not a given node meets the expectation

  • Trigger - a channel that receives node IDs which then trigger a check of the expectation function to be performed against that node

As a concrete example, consider a simulated network of Ethereum nodes. An Action could be the sending of a transaction, Expect it being included in a block, and Trigger a check for every block that is mined.

On return, the Simulation.Run method returns a StepResult which can be used to determine if all nodes met the expectation, how long it took them to meet the expectation and what network events were emitted during the step run.

HTTP API

The simulation framework includes a HTTP API that can be used to control the simulation.

The API is initialised with a particular node adapter and has the following endpoints:

GET    /                            Get network information
POST   /start                       Start all nodes in the network
POST   /stop                        Stop all nodes in the network
GET    /events                      Stream network events
GET    /snapshot                    Take a network snapshot
POST   /snapshot                    Load a network snapshot
POST   /nodes                       Create a node
GET    /nodes                       Get all nodes in the network
GET    /nodes/:nodeid               Get node information
POST   /nodes/:nodeid/start         Start a node
POST   /nodes/:nodeid/stop          Stop a node
POST   /nodes/:nodeid/conn/:peerid  Connect two nodes
DELETE /nodes/:nodeid/conn/:peerid  Disconnect two nodes
GET    /nodes/:nodeid/rpc           Make RPC requests to a node via WebSocket

For convenience, nodeid in the URL can be the name of a node rather than its ID.

Command line client

p2psim is a command line client for the HTTP API, located in cmd/p2psim.

It provides the following commands:

p2psim show
p2psim events [--current] [--filter=FILTER]
p2psim snapshot
p2psim load
p2psim node create [--name=NAME] [--services=SERVICES] [--key=KEY]
p2psim node list
p2psim node show <node>
p2psim node start <node>
p2psim node stop <node>
p2psim node connect <node> <peer>
p2psim node disconnect <node> <peer>
p2psim node rpc <node> <method> [<args>] [--subscribe]

Example

See p2p/simulations/examples/README.md.

Documentation

Overview

Package simulations simulates p2p networks. A mocker simulates starting and stopping real nodes in a network.

Index

Constants

This section is empty.

Variables

View Source 
var DefaultClient = NewClient("http://localhost:8888")

DefaultClient is the default simulation API client which expects the API to be running at http://localhost:8888 仿真网络的默认客户端,默认去连接http://localhost:8888

View Source 
var DialBanTimeout = 200 * time.Millisecond
View Source 
var (
	ErrNodeNotFound = errors.New("node not found")
)

Functions

func ConnLabel 

func ConnLabel(source, target enode.ID) string

ConnLabel generates a deterministic string which represents a connection between two nodes, used to compare if two connections are between the same nodes 输入两个相同的节点id将生成相同的字符串,输入中不区分两者的顺序 该方法用于判断两个连接对象是不是建立在两个相同的节点

func GetMockerList 

func GetMockerList() []string

Get a list of mockers (keys of the map) Useful for frontend to build available mocker selection 获取现有的mocker的名称的列表

func LookupMocker 

func LookupMocker(mockerType string) func(net *Network, quit chan struct{}, nodeCount int)

Lookup a mocker by its name, returns the mockerFn 通过mocker的名称查询它的函数

func VerifyChain 

func VerifyChain(t *testing.T, net *Network, ids []enode.ID)

func VerifyFull 

func VerifyFull(t *testing.T, net *Network, ids []enode.ID)

func VerifyRing 

func VerifyRing(t *testing.T, net *Network, ids []enode.ID)

func VerifyStar 

func VerifyStar(t *testing.T, net *Network, ids []enode.ID, centerIndex int)

Types

type Client 

type Client struct {
	URL string
	// contains filtered or unexported fields
}

Client is a client for the simulation HTTP API which supports creating and managing simulation networks

func NewClient 

func NewClient(url string) *Client

NewClient returns a new simulation API client

func (*Client) ConnectNode 

func (c *Client) ConnectNode(nodeID, peerID string) error

ConnectNode connects a node to a peer node

func (*Client) CreateNode 

func (c *Client) CreateNode(config *adapters.NodeConfig) (*p2p.NodeInfo, error)

CreateNode creates a node in the network using the given configuration

func (*Client) CreateSnapshot 

func (c *Client) CreateSnapshot() (*Snapshot, error)

CreateSnapshot creates a network snapshot

func (*Client) Delete 

func (c *Client) Delete(path string) error

Delete performs a HTTP DELETE request

func (*Client) DisconnectNode 

func (c *Client) DisconnectNode(nodeID, peerID string) error

DisconnectNode disconnects a node from a peer node

func (*Client) Get 

func (c *Client) Get(path string, out interface{}) error

Get performs a HTTP GET request decoding the resulting JSON response into "out"

func (*Client) GetNetwork 

func (c *Client) GetNetwork() (*Network, error)

GetNetwork returns details of the network

func (*Client) GetNode 

func (c *Client) GetNode(nodeID string) (*p2p.NodeInfo, error)

GetNode returns details of a node

func (*Client) GetNodes 

func (c *Client) GetNodes() ([]*p2p.NodeInfo, error)

GetNodes returns all nodes which exist in the network

func (*Client) LoadSnapshot 

func (c *Client) LoadSnapshot(snap *Snapshot) error

LoadSnapshot loads a snapshot into the network

func (*Client) Post 

func (c *Client) Post(path string, in, out interface{}) error

Post performs a HTTP POST request sending "in" as the JSON body and decoding the resulting JSON response into "out"

func (*Client) RPCClient 

func (c *Client) RPCClient(ctx context.Context, nodeID string) (*rpc.Client, error)

RPCClient returns an RPC client connected to a node

func (*Client) Send 

func (c *Client) Send(method, path string, in, out interface{}) error

Send performs a HTTP request, sending "in" as the JSON request body and decoding the JSON response into "out" 客户端向服务端发送一个http请求 method代表请求方法,path是路径 in是输入数据,编码成json发送 out是接收的json数据编码成的结果

func (*Client) StartNetwork 

func (c *Client) StartNetwork() error

StartNetwork starts all existing nodes in the simulation network

func (*Client) StartNode 

func (c *Client) StartNode(nodeID string) error

StartNode starts a node

func (*Client) StopNetwork 

func (c *Client) StopNetwork() error

StopNetwork stops all existing nodes in a simulation network

func (*Client) StopNode 

func (c *Client) StopNode(nodeID string) error

StopNode stops a node

func (*Client) SubscribeNetwork 

func (c *Client) SubscribeNetwork(events chan *Event, opts SubscribeOpts) (event.Subscription, error)

SubscribeNetwork subscribes to network events which are sent from the server as a server-sent-events stream, optionally receiving events for existing nodes and connections and filtering message events

type Conn 

type Conn struct {
	// One is the node which initiated the connection
	// 连接的发起方的节点id
	One enode.ID `json:"one"`

	// Other is the node which the connection was made to
	// 连接的接收方的节点id
	Other enode.ID `json:"other"`

	// Up tracks whether or not the connection is active
	// 连接的状态
	Up bool `json:"up"`
	// contains filtered or unexported fields
}

Conn represents a connection between two nodes in the network 仿真网络中的一个连接

func (*Conn) String 

func (c *Conn) String() string

String returns a log-friendly string

type Event 

type Event struct {
	// Type is the type of the event
	// 用于区分三种不同的类型
	Type EventType `json:"type"`

	// Time is the time the event happened
	// 事件触发的时间
	Time time.Time `json:"time"`

	// Control indicates whether the event is the result of a controlled
	// action in the network
	Control bool `json:"control"`

	// Node is set if the type is EventTypeNode
	Node *Node `json:"node,omitempty"`

	// Conn is set if the type is EventTypeConn
	Conn *Conn `json:"conn,omitempty"`

	// Msg is set if the type is EventTypeMsg
	Msg *Msg `json:"msg,omitempty"`

	//Optionally provide data (currently for simulation frontends only)
	Data interface{} `json:"data"`
}

Event is an event emitted by a simulation network Event代表仿真网络中触发的事件,有三种类型node,conn,msg

func ControlEvent 

func ControlEvent(v interface{}) *Event

ControlEvent creates a new control event 创建一个控制事件,与NewEvent区别就是设置Control字段为true

func NewEvent 

func NewEvent(v interface{}) *Event

NewEvent creates a new event for the given object which should be either a Node, Conn or Msg.

The object is copied so that the event represents the state of the object when NewEvent is called.

func (*Event) String 

func (e *Event) String() string

String returns the string representation of the event

type EventType 

type EventType string

EventType is the type of event emitted by a simulation network 代表仿真网络中的事件类型 有三种node,conn以及msg 

const (
	// EventTypeNode is the type of event emitted when a node is either
	// created, started or stopped
	EventTypeNode EventType = "node"

	// EventTypeConn is the type of event emitted when a connection is
	// is either established or dropped between two nodes
	EventTypeConn EventType = "conn"

	// EventTypeMsg is the type of event emitted when a p2p message it
	// sent between two nodes
	EventTypeMsg EventType = "msg"
)

type Expectation 

type Expectation struct {
	// Nodes is a list of nodes to check
	Nodes []enode.ID

	// Check checks whether a given node meets the expectation
	Check func(context.Context, enode.ID) (bool, error)
}

type Msg 

type Msg struct {
	One      enode.ID `json:"one"`
	Other    enode.ID `json:"other"`
	Protocol string   `json:"protocol"`
	Code     uint64   `json:"code"`
	Received bool     `json:"received"`
}

Msg represents a p2p message sent between two nodes in the network 代表仿真网络中发送的消息

func (*Msg) String 

func (m *Msg) String() string

String returns a log-friendly string

type MsgFilter 

type MsgFilter struct {
	// Proto is matched against a message's protocol
	Proto string

	// Code is matched against a message's code, with -1 matching all codes
	Code int64
}

MsgFilter is used to filter message events based on protocol and message code MsgFilter代表了一个协议的一种消息码 消息码这里可以是通配符*和-1,代表这个协议的所有消息

type MsgFilters 

type MsgFilters map[MsgFilter]struct{}

MsgFilters is a collection of filters which are used to filter message events 保存了许多MsgFilter对象,一个协议的一个消息码就使用一个MsgFilter对象表示

func NewMsgFilters 

func NewMsgFilters(filterParam string) (MsgFilters, error)

NewMsgFilters constructs a collection of message filters from a URL query parameter.

The parameter is expected to be a dash-separated list of individual filters, each having the format '<proto>:<codes>', where <proto> is the name of a protocol and <codes> is a comma-separated list of message codes.

A message code of '*' or '-1' is considered a wildcard and matches any code. 创建一个消息过滤器,消息过滤的格式是 <proto>:<codes>-<proto>:<codes>-...- 用破折号分割 <proto>是协议的名称,<codes>是消息码,使用逗号分割 <codes>中支持使用*和-1作为通配符

func (MsgFilters) Match 

func (m MsgFilters) Match(msg *Msg) bool

Match checks if the given message matches any of the filters 判断指定的消息是否被匹配到

type Network 

type Network struct {
	NetworkConfig

	// 保存网络中的所有节点
	Nodes []*Node `json:"nodes"`

	// 保存网络中所有连接
	Conns []*Conn `json:"conns"`
	// contains filtered or unexported fields
}

Network models a p2p simulation network which consists of a collection of simulated nodes and the connections which exist between them.

The Network has a single NodeAdapter which is responsible for actually starting nodes and connecting them together.

The Network emits events when nodes are started and stopped, when they are connected and disconnected, and also when messages are sent between nodes. Network对象代表一个仿真网络,包括了一组仿真节点和这些节点间建立的连接

func NewNetwork 

func NewNetwork(nodeAdapter adapters.NodeAdapter, conf *NetworkConfig) *Network

NewNetwork returns a Network which uses the given NodeAdapter and NetworkConfig 新建一个仿真网络需要NodeAdapter和NetworkConfig NodeAdapter用来指定如何在网络中创建节点,NetworkConfig指定了该仿真网络的一些配置

func (*Network) Config 

func (net *Network) Config() *NetworkConfig

Config returns the network configuration 获取网络的配置信息

func (*Network) Connect 

func (net *Network) Connect(oneID, otherID enode.ID) error

Connect connects two nodes together by calling the "admin_addPeer" RPC method on the "one" node so that it connects to the "other" node 建立两个节点间的连接,通过调用admin_addPerr这个RPC方法

func (*Network) ConnectNodesChain 

func (net *Network) ConnectNodesChain(ids []enode.ID) (err error)

ConnectNodesChain connects all nodes in a chain topology. If ids argument is nil, all nodes that are up will be connected.

func (*Network) ConnectNodesFull 

func (net *Network) ConnectNodesFull(ids []enode.ID) (err error)

ConnectNodesFull connects all nodes one to another. It provides a complete connectivity in the network which should be rarely needed.

func (*Network) ConnectNodesRing 

func (net *Network) ConnectNodesRing(ids []enode.ID) (err error)

ConnectNodesRing connects all nodes in a ring topology. If ids argument is nil, all nodes that are up will be connected.

func (*Network) ConnectNodesStar 

func (net *Network) ConnectNodesStar(ids []enode.ID, center enode.ID) (err error)

ConnectNodesStar connects all nodes into a star topology If ids argument is nil, all nodes that are up will be connected.

func (*Network) ConnectToLastNode 

func (net *Network) ConnectToLastNode(id enode.ID) (err error)

ConnectToLastNode connects the node with provided NodeID to the last node that is up, and avoiding connection to self. It is useful when constructing a chain network topology when Network adds and removes nodes dynamically.

func (*Network) ConnectToRandomNode 

func (net *Network) ConnectToRandomNode(id enode.ID) (err error)

ConnectToRandomNode connects the node with provided NodeID to a random node that is up.

func (*Network) DidConnect 

func (net *Network) DidConnect(one, other enode.ID) error

DidConnect tracks the fact that the "one" node connected to the "other" node

func (*Network) DidDisconnect 

func (net *Network) DidDisconnect(one, other enode.ID) error

DidDisconnect tracks the fact that the "one" node disconnected from the "other" node

func (*Network) DidReceive 

func (net *Network) DidReceive(sender, receiver enode.ID, proto string, code uint64) error

DidReceive tracks the fact that "receiver" received a message from "sender"

func (*Network) DidSend 

func (net *Network) DidSend(sender, receiver enode.ID, proto string, code uint64) error

DidSend tracks the fact that "sender" sent a message to "receiver"

func (*Network) Disconnect 

func (net *Network) Disconnect(oneID, otherID enode.ID) error

Disconnect disconnects two nodes by calling the "admin_removePeer" RPC method on the "one" node so that it disconnects from the "other" node 断开两个节点间的连接,调用了admin_removePeer这个RPC方法

func (*Network) Events 

func (net *Network) Events() *event.Feed

Events returns the output event feed of the Network. 外部通过这个方法订阅网络中发生的事件

func (*Network) GetConn 

func (net *Network) GetConn(oneID, otherID enode.ID) *Conn

GetConn returns the connection which exists between "one" and "other" regardless of which node initiated the connection 获取仿真网络中两个节点之间的连接对象,没建立连接返回nil

func (*Network) GetNode 

func (net *Network) GetNode(id enode.ID) *Node

GetNode gets the node with the given ID, returning nil if the node does not exist

func (*Network) GetNodeByName 

func (net *Network) GetNodeByName(name string) *Node

GetNodeByName gets the node with the given name, returning nil if the node does not exist 通过节点的名称查询Node对象,如果节点不存在返回nil

func (*Network) GetNodeIDs 

func (net *Network) GetNodeIDs(excludeIDs ...enode.ID) []enode.ID

GetNodeIDs returns the IDs of all existing nodes Nodes can optionally be excluded by specifying their enode.ID.

func (*Network) GetNodeIDsByProperty 

func (net *Network) GetNodeIDsByProperty(property string) []enode.ID

GetNodeIDsByProperty returns existing node's enode IDs that have the given property string registered in the NodeConfig

func (*Network) GetNodes 

func (net *Network) GetNodes(excludeIDs ...enode.ID) []*Node

GetNodes returns the existing nodes. Nodes can optionally be excluded by specifying their enode.ID.

func (*Network) GetNodesByID 

func (net *Network) GetNodesByID(nodeIDs []enode.ID) []*Node

GetNodesByID returns existing nodes with the given enode.IDs. If a node doesn't exist with a given enode.ID, it is ignored.

func (*Network) GetNodesByProperty 

func (net *Network) GetNodesByProperty(property string) []*Node

GetNodesByProperty returns existing nodes that have the given property string registered in their NodeConfig

func (*Network) GetOrCreateConn 

func (net *Network) GetOrCreateConn(oneID, otherID enode.ID) (*Conn, error)

GetOrCreateConn is like GetConn but creates the connection if it doesn't already exist 获取仿真网络中两个节点之间的连接对象,没建立连接新创建一个连接返回

func (*Network) GetRandomDownNode 

func (net *Network) GetRandomDownNode(excludeIDs ...enode.ID) *Node

GetRandomDownNode returns a random node on the network, which is stopped.

func (*Network) GetRandomNode 

func (net *Network) GetRandomNode(excludeIDs ...enode.ID) *Node

GetRandomNode returns a random node on the network, regardless of whether it is running or not

func (*Network) GetRandomUpNode 

func (net *Network) GetRandomUpNode(excludeIDs ...enode.ID) *Node

GetRandomUpNode returns a random node on the network, which is running.

func (*Network) InitConn 

func (net *Network) InitConn(oneID, otherID enode.ID) (*Conn, error)

InitConn(one, other) retrieves the connection model for the connection between peers one and other, or creates a new one if it does not exist the order of nodes does not matter, i.e., Conn(i,j) == Conn(j, i) it checks if the connection is already up, and if the nodes are running NOTE: it also checks whether there has been recent attempt to connect the peers this is cheating as the simulation is used as an oracle and know about remote peers attempt to connect to a node which will then not initiate the connection 初始化一个连接 调用时两个节点间要么没建立连接,要么连接还没启动 而且这两个节点必须是启动状态的

func (*Network) Load 

func (net *Network) Load(snap *Snapshot) error

Load loads a network snapshot 从快照中恢复一个仿真网络

func (*Network) NewNodeWithConfig 

func (net *Network) NewNodeWithConfig(conf *adapters.NodeConfig) (*Node, error)

NewNodeWithConfig adds a new node to the network with the given config, returning an error if a node with the same ID or name already exists 指定节点的配置信息,在仿真网络中创建一个新的节点

func (*Network) Reset 

func (net *Network) Reset()

Reset resets all network properties: empties the nodes and the connection list 重置整个网络,清空建立的节点和连接

func (*Network) Shutdown 

func (net *Network) Shutdown()

Shutdown stops all nodes in the network and closes the quit channel 用来停止整个仿真网络 调用所有Node对象的Stop方法,如果实现了Close方法的话也调用Close 关闭所有节点后再关闭net.quitc管道

func (*Network) Snapshot 

func (net *Network) Snapshot() (*Snapshot, error)

Snapshot creates a network snapshot 创建网络快照

func (*Network) SnapshotWithServices 

func (net *Network) SnapshotWithServices(addServices []string, removeServices []string) (*Snapshot, error)

创建网络快照,可以让快照中所有的启动的节点都有或者没有指定的服务

func (*Network) Start 

func (net *Network) Start(id enode.ID) error

Start starts the node with the given ID 启动网络中指定id的节点 执行节点的Start方法,并设置节点的Up为true 最后监听针对这个节点的rpc事件,例如增加或减少对等节点,发送或接收到消息

func (*Network) StartAll 

func (net *Network) StartAll() error

StartAll starts all nodes in the network 启动网络中的所有节点

func (*Network) Stop 

func (net *Network) Stop(id enode.ID) error

Stop stops the node with the given ID 停止仿真网络中的某个节点,其实就是调用节点的Stop方法

func (*Network) StopAll 

func (net *Network) StopAll() error

StopAll stops all nodes in the network 停止网络中的所有节点

func (*Network) Subscribe 

func (net *Network) Subscribe(events chan *Event)

Subscribe reads control events from a channel and executes them 从输入的events管道中接收到Control类型的事件,然后执行这些事件

type NetworkConfig 

type NetworkConfig struct {
	ID             string `json:"id"`
	DefaultService string `json:"default_service,omitempty"`
}

NetworkConfig defines configuration options for starting a Network NetworkConfig指定了启动一个仿真网络需要配置 包括这个网络的ID,以及网络中的节点使用的默认服务

type Node 

type Node struct {
	adapters.Node `json:"-"`

	// Config if the config used to created the node
	// 创建adapters.Node的时候使用的配置
	Config *adapters.NodeConfig `json:"config"`
	// contains filtered or unexported fields
}

Node is a wrapper around adapters.Node which is used to track the status of a node in the network 这里的Node是对adapters.Node一层封装,用来追踪节点在仿真网络中的状态 它也实现了adapters.Node接口

func (*Node) ID 

func (n *Node) ID() enode.ID

ID returns the ID of the node

func (*Node) MarshalJSON 

func (n *Node) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface so that the encoded JSON includes the NodeInfo

func (*Node) NodeInfo 

func (n *Node) NodeInfo() *p2p.NodeInfo

NodeInfo returns information about the node 获取NodeInfo

func (*Node) SetUp 

func (n *Node) SetUp(up bool)

SetUp sets the up (online) status of the nodes with the given value 设置up为输入的值

func (*Node) String 

func (n *Node) String() string

String returns a log-friendly string

func (*Node) UnmarshalJSON 

func (n *Node) UnmarshalJSON(raw []byte) error

UnmarshalJSON implements json.Unmarshaler interface so that we don't lose Node.up status. IMPORTANT: The implementation is incomplete; we lose p2p.NodeInfo.

func (*Node) Up 

func (n *Node) Up() bool

Up returns whether the node is currently up (online) 得知当前节点是否正在运行

type NodeSnapshot 

type NodeSnapshot struct {
	Node Node `json:"node,omitempty"`

	// Snapshots is arbitrary data gathered from calling node.Snapshots()
	Snapshots map[string][]byte `json:"snapshots,omitempty"`
}

NodeSnapshot represents the state of a node in the network 用于保存一个节点的快照

type NoopService 

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

NoopService is the service that does not do anything but implements node.Service interface.

func NewNoopService 

func NewNoopService(ackC map[enode.ID]chan struct{}) *NoopService

func (*NoopService) APIs 

func (t *NoopService) APIs() []rpc.API

func (*NoopService) Protocols 

func (t *NoopService) Protocols() []p2p.Protocol

func (*NoopService) Start 

func (t *NoopService) Start() error

func (*NoopService) Stop 

func (t *NoopService) Stop() error

type Server 

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

Server is an HTTP server providing an API to manage a simulation network

func NewServer 

func NewServer(network *Network) *Server

NewServer returns a new simulation API server 创建一个simulations.Server对象 并注册了各种方法的路由

func (*Server) ConnectNode 

func (s *Server) ConnectNode(w http.ResponseWriter, req *http.Request)

ConnectNode connects a node to a peer node

func (*Server) CreateNode 

func (s *Server) CreateNode(w http.ResponseWriter, req *http.Request)

CreateNode creates a node in the network using the given configuration 通过请求中的参数创建一个节点

func (*Server) CreateSnapshot 

func (s *Server) CreateSnapshot(w http.ResponseWriter, req *http.Request)

CreateSnapshot creates a network snapshot

func (*Server) DELETE 

func (s *Server) DELETE(path string, handle http.HandlerFunc)

DELETE registers a handler for DELETE requests to a particular path 注册指定路径DELETE请求的处理函数

func (*Server) DisconnectNode 

func (s *Server) DisconnectNode(w http.ResponseWriter, req *http.Request)

DisconnectNode disconnects a node from a peer node

func (*Server) GET 

func (s *Server) GET(path string, handle http.HandlerFunc)

GET registers a handler for GET requests to a particular path 注册指定路径GET请求的处理函数

func (*Server) GetMockers 

func (s *Server) GetMockers(w http.ResponseWriter, req *http.Request)

GetMockerList returns a list of available mockers 获取仿真网络中现有的mocker,目前有三种:startStop,probabilistic和boot

func (*Server) GetNetwork 

func (s *Server) GetNetwork(w http.ResponseWriter, req *http.Request)

GetNetwork returns details of the network

func (*Server) GetNode 

func (s *Server) GetNode(w http.ResponseWriter, req *http.Request)

GetNode returns details of a node

func (*Server) GetNodes 

func (s *Server) GetNodes(w http.ResponseWriter, req *http.Request)

GetNodes returns all nodes which exist in the network

func (*Server) JSON 

func (s *Server) JSON(w http.ResponseWriter, status int, data interface{})

JSON sends "data" as a JSON HTTP response 将data编码成json字符串,然后发送给客户端

func (*Server) LoadSnapshot 

func (s *Server) LoadSnapshot(w http.ResponseWriter, req *http.Request)

LoadSnapshot loads a snapshot into the network

func (*Server) NodeRPC 

func (s *Server) NodeRPC(w http.ResponseWriter, req *http.Request)

NodeRPC forwards RPC requests to a node in the network via a WebSocket connection

func (*Server) OPTIONS 

func (s *Server) OPTIONS(path string, handle http.HandlerFunc)

OPTIONS registers a handler for OPTIONS requests to a particular path 注册指定路径OPTIONS请求的处理函数

func (*Server) Options 

func (s *Server) Options(w http.ResponseWriter, req *http.Request)

Options responds to the OPTIONS HTTP method by returning a 200 OK response with the "Access-Control-Allow-Headers" header set to "Content-Type"

func (*Server) POST 

func (s *Server) POST(path string, handle http.HandlerFunc)

POST registers a handler for POST requests to a particular path 注册指定路径POST请求的处理函数

func (*Server) ResetNetwork 

func (s *Server) ResetNetwork(w http.ResponseWriter, req *http.Request)

ResetNetwork resets all properties of a network to its initial (empty) state

func (*Server) ServeHTTP 

func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP implements the http.Handler interface by delegating to the underlying httprouter.Router

func (*Server) StartMocker 

func (s *Server) StartMocker(w http.ResponseWriter, req *http.Request)

StartMocker starts the mocker node simulation

func (*Server) StartNetwork 

func (s *Server) StartNetwork(w http.ResponseWriter, req *http.Request)

StartNetwork starts all nodes in the network

func (*Server) StartNode 

func (s *Server) StartNode(w http.ResponseWriter, req *http.Request)

StartNode starts a node

func (*Server) StopMocker 

func (s *Server) StopMocker(w http.ResponseWriter, req *http.Request)

StopMocker stops the mocker node simulation

func (*Server) StopNetwork 

func (s *Server) StopNetwork(w http.ResponseWriter, req *http.Request)

StopNetwork stops all nodes in the network

func (*Server) StopNode 

func (s *Server) StopNode(w http.ResponseWriter, req *http.Request)

StopNode stops a node

func (*Server) StreamNetworkEvents 

func (s *Server) StreamNetworkEvents(w http.ResponseWriter, req *http.Request)

StreamNetworkEvents streams network events as a server-sent-events stream 以数据流的形式不断输出网络中的事件

type Simulation 

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

Simulation provides a framework for running actions in a simulated network and then waiting for expectations to be met

func NewSimulation 

func NewSimulation(network *Network) *Simulation

NewSimulation returns a new simulation which runs in the given network

func (*Simulation) Run 

func (s *Simulation) Run(ctx context.Context, step *Step) (result *StepResult)

Run performs a step of the simulation by performing the step's action and then waiting for the step's expectation to be met

type Snapshot 

type Snapshot struct {
	Nodes []NodeSnapshot `json:"nodes,omitempty"`
	Conns []Conn         `json:"conns,omitempty"`
}

Snapshot represents the state of a network at a single point in time and can be used to restore the state of a network Snapshot对象用于保存仿真网络在某个时刻的状态,可以用来恢复整个网络

type Step 

type Step struct {
	// Action is the action to perform for this step
	Action func(context.Context) error

	// Trigger is a channel which receives node ids and triggers an
	// expectation check for that node
	Trigger chan enode.ID

	// Expect is the expectation to wait for when performing this step
	Expect *Expectation
}

type StepResult 

type StepResult struct {
	// Error is the error encountered whilst running the step
	Error error

	// StartedAt is the time the step started
	StartedAt time.Time

	// FinishedAt is the time the step finished
	FinishedAt time.Time

	// Passes are the timestamps of the successful node expectations
	Passes map[enode.ID]time.Time

	// NetworkEvents are the network events which occurred during the step
	NetworkEvents []*Event
}

type SubscribeOpts 

type SubscribeOpts struct {
	// Current instructs the server to send events for existing nodes and
	// connections first
	// 是否获取当前网络中的节点和连接
	Current bool

	// Filter instructs the server to only send a subset of message events
	// 消息事件的过滤器
	Filter string
}

SubscribeOpts is a collection of options to use when subscribing to network events 客户端订阅仿真网络的事件的配置选项

Source Files

View all Source files

Directories

Path Synopsis

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.