Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

simulation

package

Go to main page

Versions in this module

v1

v1.8.15

Aug 29, 2018

v1.8.14

Aug 22, 2018

v1.8.13

Jul 31, 2018

Changes in this version

+ var DefaultHTTPSimAddr = ":8888"

+ var ErrNoPivotNode = errors.New("no pivot node set")

+ var ErrNodeNotFound = errors.New("node not found")

+ type AddNodeOption func(*adapters.NodeConfig)

+ func AddNodeWithMsgEvents(enable bool) AddNodeOption

+ func AddNodeWithService(serviceName string) AddNodeOption

+ type BucketKey string

+ var BucketKeyKademlia BucketKey = "kademlia"

+ type PeerEvent struct

+ Error error

+ Event *p2p.PeerEvent

+ NodeID discover.NodeID

+ type PeerEventsFilter struct

+ func NewPeerEventsFilter() *PeerEventsFilter

+ func (f *PeerEventsFilter) MsgCode(c uint64) *PeerEventsFilter

+ func (f *PeerEventsFilter) Protocol(p string) *PeerEventsFilter

+ func (f *PeerEventsFilter) Type(t p2p.PeerEventType) *PeerEventsFilter

+ type Result struct

+ Duration time.Duration

+ Error error

+ type RunFunc func(context.Context, *Simulation) error

+ type ServiceFunc func(ctx *adapters.ServiceContext, bucket *sync.Map) (s node.Service, cleanup func(), err error)

+ type Simulation struct

+ Net *simulations.Network

+ func New(services map[string]ServiceFunc) (s *Simulation)

+ func (s *Simulation) AddNode(opts ...AddNodeOption) (id discover.NodeID, err error)

+ func (s *Simulation) AddNodes(count int, opts ...AddNodeOption) (ids []discover.NodeID, err error)

+ func (s *Simulation) AddNodesAndConnectChain(count int, opts ...AddNodeOption) (ids []discover.NodeID, err error)

+ func (s *Simulation) AddNodesAndConnectFull(count int, opts ...AddNodeOption) (ids []discover.NodeID, err error)

+ func (s *Simulation) AddNodesAndConnectRing(count int, opts ...AddNodeOption) (ids []discover.NodeID, err error)

+ func (s *Simulation) AddNodesAndConnectStar(count int, opts ...AddNodeOption) (ids []discover.NodeID, err error)

+ func (s *Simulation) Close()

+ func (s *Simulation) ConnectNodesChain(ids []discover.NodeID) (err error)

+ func (s *Simulation) ConnectNodesFull(ids []discover.NodeID) (err error)

+ func (s *Simulation) ConnectNodesRing(ids []discover.NodeID) (err error)

+ func (s *Simulation) ConnectNodesStar(id discover.NodeID, ids []discover.NodeID) (err error)

+ func (s *Simulation) ConnectNodesStarPivot(ids []discover.NodeID) (err error)

+ func (s *Simulation) ConnectToLastNode(id discover.NodeID) (err error)

+ func (s *Simulation) ConnectToPivotNode(id discover.NodeID) (err error)

+ func (s *Simulation) ConnectToRandomNode(id discover.NodeID) (err error)

+ func (s *Simulation) Done() <-chan struct{}

+ func (s *Simulation) DownNodeIDs() (ids []discover.NodeID)

+ func (s *Simulation) NodeIDs() (ids []discover.NodeID)

+ func (s *Simulation) NodeItem(id discover.NodeID, key interface{}) (value interface{}, ok bool)

+ func (s *Simulation) NodesItems(key interface{}) (values map[discover.NodeID]interface{})

+ func (s *Simulation) PeerEvents(ctx context.Context, ids []discover.NodeID, filters ...*PeerEventsFilter) <-chan PeerEvent

+ func (s *Simulation) PivotNodeID() (id *discover.NodeID)

+ func (s *Simulation) RandomService(name string) node.Service

+ func (s *Simulation) RandomUpNode(exclude ...discover.NodeID) *adapters.SimNode

+ func (s *Simulation) Run(ctx context.Context, f RunFunc) (r Result)

+ func (s *Simulation) RunSimulation(w http.ResponseWriter, req *http.Request)

+ func (s *Simulation) Service(name string, id discover.NodeID) node.Service

+ func (s *Simulation) Services(name string) (services map[discover.NodeID]node.Service)

+ func (s *Simulation) SetNodeItem(id discover.NodeID, key interface{}, value interface{})

+ func (s *Simulation) SetPivotNode(id discover.NodeID)

+ func (s *Simulation) StartNode(id discover.NodeID) (err error)

+ func (s *Simulation) StartRandomNode() (id discover.NodeID, err error)

+ func (s *Simulation) StartRandomNodes(count int) (ids []discover.NodeID, err error)

+ func (s *Simulation) StopNode(id discover.NodeID) (err error)

+ func (s *Simulation) StopRandomNode() (id discover.NodeID, err error)

+ func (s *Simulation) StopRandomNodes(count int) (ids []discover.NodeID, err error)

+ func (s *Simulation) UpNodeIDs() (ids []discover.NodeID)

+ func (s *Simulation) UpNodesItems(key interface{}) (values map[discover.NodeID]interface{})

+ func (s *Simulation) UploadSnapshot(snapshotFile string, opts ...AddNodeOption) error

+ func (s *Simulation) WaitTillHealthy(ctx context.Context, kadMinProxSize int) (ill map[discover.NodeID]*network.Kademlia, err error)

+ func (s *Simulation) WithServer(addr string) *Simulation