simulation

package

v0.0.1 Latest Latest Go to latest Published: Jan 17, 2020 License: Apache-2.0 Imports: 17 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

Repository

github.com/iotaledger/autopeering-sim

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ConvergenceToString() (output [][]string)
func DropLink(x, y peer.ID, timestamp int64, list []Link) bool
func LinksToString(linkList []Link) (output [][]string)
func MessagesToString(nodeMap map[peer.ID]Node, status *StatusMap) (output [][]string)
func NewLinkAnalysis(nodeMap map[peer.ID]Node) *linkAnalysis
func WriteAdjlist(nodeMap map[peer.ID]Node, filename string) error
func WriteCSV(records [][]string, filename string, header ...[]string) error
type Convergence
type ConvergenceList
- func NewConvergenceList() *ConvergenceList
- func (c *ConvergenceList) Append(t Convergence)
- func (c *ConvergenceList) GetAvgNeighbors() float64
- func (c *ConvergenceList) GetConvergence() float64
type Link
- func NewLink(x, y peer.ID, timestamp int64) Link
- func (l Link) String() string
type Node
- func NewNode(name string, saltLifetime time.Duration, network *transport.ChanNetwork, ...) Node
- func (n Node) GetNeighbors() []*peer.Peer
- func (n Node) GetOutgoingNeighbors() []*peer.Peer
- func (n Node) ID() peer.ID
- func (n Node) Peer() *peer.Peer
type Status
type StatusMap
- func NewStatusMap() *StatusMap
- func (s *StatusMap) Append(from, to peer.ID, op byte)
- func (s *StatusMap) GetSummary(id peer.ID) (cnt StatusSum)
type StatusSum

Constants ¶

View Source

const (
	ACCEPTED = 'A'
	REJECTED = 'R'
	DROPPED  = 'D'
	OUTBOUND = 'O'
	INCOMING = 'I'
)

Variables ¶

View Source

var RecordConv = NewConvergenceList()

Functions ¶

func ConvergenceToString ¶

func ConvergenceToString() (output [][]string)

func DropLink ¶

func DropLink(x, y peer.ID, timestamp int64, list []Link) bool

func LinksToString ¶

func LinksToString(linkList []Link) (output [][]string)

func MessagesToString ¶

func MessagesToString(nodeMap map[peer.ID]Node, status *StatusMap) (output [][]string)

func NewLinkAnalysis ¶

func NewLinkAnalysis(nodeMap map[peer.ID]Node) *linkAnalysis

func WriteAdjlist ¶

func WriteAdjlist(nodeMap map[peer.ID]Node, filename string) error

func WriteCSV ¶

func WriteCSV(records [][]string, filename string, header ...[]string) error

Types ¶

type Convergence ¶

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

type ConvergenceList ¶

type ConvergenceList struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewConvergenceList ¶

func NewConvergenceList() *ConvergenceList

func (*ConvergenceList) Append ¶

func (c *ConvergenceList) Append(t Convergence)

func (*ConvergenceList) GetAvgNeighbors ¶

func (c *ConvergenceList) GetAvgNeighbors() float64

func (*ConvergenceList) GetConvergence ¶

func (c *ConvergenceList) GetConvergence() float64

type Link ¶

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

func NewLink ¶

func NewLink(x, y peer.ID, timestamp int64) Link

func (Link) String ¶

func (l Link) String() string

type Node ¶

type Node struct {
	Start func()
	Stop  func()
	// contains filtered or unexported fields
}

func NewNode ¶

func NewNode(name string, saltLifetime time.Duration, network *transport.ChanNetwork, dropOnUpdate bool, discover selection.DiscoverProtocol) Node

func (Node) GetNeighbors ¶

func (n Node) GetNeighbors() []*peer.Peer

func (Node) GetOutgoingNeighbors ¶

func (n Node) GetOutgoingNeighbors() []*peer.Peer

func (Node) ID ¶

func (n Node) ID() peer.ID

func (Node) Peer ¶

func (n Node) Peer() *peer.Peer

type Status ¶

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

type StatusMap ¶

type StatusMap struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewStatusMap ¶

func NewStatusMap() *StatusMap

func (*StatusMap) Append ¶

func (s *StatusMap) Append(from, to peer.ID, op byte)

func (*StatusMap) GetSummary ¶

func (s *StatusMap) GetSummary(id peer.ID) (cnt StatusSum)

type StatusSum ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
config
visualizer

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL