Versions in this module Expand all Collapse all v0 v0.4.3 Jul 25, 2019 Changes in this version + func IsDockerAvailable(daemonAddr string) bool + func IsKubernetesAvailable(kubeConfigPath string) bool + type Adapter interface + NewNode func(config NodeConfig) Node + Snapshot func() AdapterSnapshot + type AdapterSnapshot struct + Config interface{} + Type string + type ConnectionSnapshot struct + From string + To string + type DockerAdapter struct + func NewDockerAdapter(config DockerAdapterConfig) (*DockerAdapter, error) + func (a DockerAdapter) NewNode(config NodeConfig) Node + func (a DockerAdapter) Snapshot() AdapterSnapshot + type DockerAdapterConfig struct + BuildContext *DockerBuildContext + DaemonAddr string + DockerImage string + func DefaultDockerAdapterConfig() DockerAdapterConfig + type DockerBuildContext struct + Directory string + Dockerfile string + Tag string + func DefaultDockerBuildContext() DockerBuildContext + type DockerNode struct + func (n *DockerNode) Info() NodeInfo + func (n *DockerNode) Snapshot() (NodeSnapshot, error) + func (n *DockerNode) Start() error + func (n *DockerNode) Stop() error + type ExecAdapter struct + func NewExecAdapter(config ExecAdapterConfig) (*ExecAdapter, error) + func (a ExecAdapter) NewNode(config NodeConfig) Node + func (a ExecAdapter) Snapshot() AdapterSnapshot + type ExecAdapterConfig struct + BaseDataDirectory string + ExecutablePath string + type ExecNode struct + func (n *ExecNode) Info() NodeInfo + func (n *ExecNode) Snapshot() (NodeSnapshot, error) + func (n *ExecNode) Start() error + func (n *ExecNode) Stop() error + type KubernetesAdapter struct + func NewKubernetesAdapter(config KubernetesAdapterConfig) (*KubernetesAdapter, error) + func (a KubernetesAdapter) NewNode(config NodeConfig) Node + func (a KubernetesAdapter) Snapshot() AdapterSnapshot + type KubernetesAdapterConfig struct + BuildContext *KubernetesBuildContext + DockerImage string + KubeConfigPath string + Namespace string + func DefaultKubernetesAdapterConfig() KubernetesAdapterConfig + type KubernetesBuildContext struct + Directory string + Dockerfile string + Password string + Registry string + Tag string + Username string + func (bc *KubernetesBuildContext) ImageTag() string + type KubernetesNode struct + func (n *KubernetesNode) Info() NodeInfo + func (n *KubernetesNode) Snapshot() (NodeSnapshot, error) + func (n *KubernetesNode) Start() error + func (n *KubernetesNode) Stop() error + type Node interface + Info func() NodeInfo + Snapshot func() (NodeSnapshot, error) + Start func() error + Stop func() error + type NodeConfig struct + Args []string + Env []string + ID NodeID + Stderr io.Writer + Stdout io.Writer + type NodeID string + type NodeInfo struct + BzzAddr string + Enode string + HTTPListen string + ID NodeID + PprofListen string + RPCListen string + type NodeSnapshot struct + Adapter *AdapterSnapshot + Config NodeConfig + type Simulation struct + func NewSimulation(adapter Adapter) *Simulation + func NewSimulationFromSnapshot(snapshot *Snapshot) (*Simulation, error) + func (s *Simulation) AddBootnode(id NodeID, args []string) (Node, error) + func (s *Simulation) AddNode(id NodeID, args []string) (Node, error) + func (s *Simulation) AddNodes(idPrefix string, count int, args []string) ([]Node, error) + func (s *Simulation) CreateClusterWithBootnode(idPrefix string, count int, args []string) ([]Node, error) + func (s *Simulation) DefaultAdapter() Adapter + func (s *Simulation) Get(id NodeID) (Node, error) + func (s *Simulation) GetAll() []Node + func (s *Simulation) HTTPBaseAddr(id NodeID) (string, error) + func (s *Simulation) Init(config NodeConfig) error + func (s *Simulation) InitWithAdapter(config NodeConfig, adapter Adapter) error + func (s *Simulation) RPCClient(id NodeID) (*rpc.Client, error) + func (s *Simulation) Snapshot() (*Snapshot, error) + func (s *Simulation) Start(id NodeID) error + func (s *Simulation) StartAll() error + func (s *Simulation) Stop(id NodeID) error + func (s *Simulation) StopAll() error + func (s *Simulation) WaitForHealthyNetwork() error + type Snapshot struct + Connections []ConnectionSnapshot + DefaultAdapter *AdapterSnapshot + Nodes []NodeSnapshot + func LoadSnapshotFromFile(filePath string) (*Snapshot, error)
Go to main page