simulator

package

Go to main page

Versions in this module

v0

v0.11.0

Nov 17, 2022

Changes in this version

type APIUpdateID

+ const SimBroadcastReceived

+ type BroadcastEntry struct

+ PeerID string

+ Time uint64

+ type BroadcastReceived struct

+ Node string

+ PeerID string

+ Time uint64

type DefaultRouter

+ func (r *DefaultRouter) DisableWakeupBroadcasts()

+ func (r *DefaultRouter) EnableHopLimiting()

+ func (r *DefaultRouter) EnableWakeupBroadcasts()

+ type ExpectedBroadcasts map[string]bool

type InitialNodeState

+ BroadcastsReceived []BroadcastEntry

type NodeState

+ BroadcastsReceived map[string]uint64

+ ExpectedBroadcasts ExpectedBroadcasts

type Simulator

+ func (sim *Simulator) GenerateNetworkGraph()

+ func (sim *Simulator) UpdateRealDistances()

v0.10.0

Sep 27, 2022

Changes in this version

+ const MaxBandwidthReports

type APIUpdateID

+ const SimBandwidthReport

+ type BandwidthReport struct

+ Bandwidth BandwidthSnapshot

+ Node string

+ type BandwidthReports []BandwidthSnapshot

+ type BandwidthSnapshot struct

+ Peers map[string]PeerBandwidthUsage

+ ReceiveTime uint64

type DefaultRouter

+ func (r *DefaultRouter) PingFilter(from types.PublicKey, f *types.Frame) bool

type InitialNodeState

+ BandwidthReports []BandwidthSnapshot

type InitialStateMsg

+ BWReportingInterval int

type NetworkStatsUpdate

+ AverageStretch float64

+ PathConvergence uint64

type Node

+ Type APINodeType

type NodeState

+ BandwidthReports BandwidthReports

+ NextReportIndex uint

+ type PeerBandwidthUsage struct

+ Overlay struct{ ... }

+ Protocol struct{ ... }

type PingType

+ const Ping

+ const Pong

type Simulator

+ func (sim *Simulator) CalculatePathConvergence() float64

+ func (sim *Simulator) Ping(from, to string) (uint16, time.Duration, error)

v0.9.0

Jul 8, 2022

Changes in this version

type APICommandID

+ const SimStartPings

+ const SimStopPings

type APIUpdateID

+ const SimNetworkStatsUpdated

+ const SimPingStateUpdated

+ const SimSnakeEntryAdded

+ const SimSnakeEntryRemoved

type DefaultRouter

+ func (r *DefaultRouter) OverlayReadHandler(quit <-chan bool)

type InitialNodeState

+ SnakeEntries []SnakeRouteEntry

+ type NetworkStatsUpdate struct

+ SnakeAverageStretch float64

+ SnakePathConvergence uint64

+ TreeAverageStretch float64

+ TreePathConvergence uint64

type NodeAdded

+ RouteCount int

type NodeState

+ SnakeEntries map[string]string

+ type PingPayload struct

+ func (p *PingPayload) MarshalBinary(buffer []byte) (int, error)

+ func (p *PingPayload) UnmarshalBinary(data []byte) (int, error)

+ type PingStateUpdate struct

+ Active bool

+ Enabled bool

+ type PingType uint8

+ const SNEKPing

+ const SNEKPong

+ const TreePing

+ const TreePong

type Simulator

+ func (sim *Simulator) CalculateSNEKPathConvergence() float64

+ func (sim *Simulator) CalculateStretch() (tree float64, snek float64)

+ func (sim *Simulator) CalculateTreePathConvergence() float64

+ func (sim *Simulator) PingingActive() bool

+ func (sim *Simulator) StartPinging(ping_period time.Duration)

+ func (sim *Simulator) StartPings()

+ func (sim *Simulator) StopPings()

+ type SnakeEntryAdded struct

+ EntryID string

+ Node string

+ PeerID string

+ type SnakeEntryRemoved struct

+ EntryID string

+ Node string

+ type SnakeRouteEntry struct

+ EntryID string

+ PeerID string

+ type StartPings struct

+ func (c StartPings) Run(log *log.Logger, sim *Simulator)

+ func (c StartPings) String() string

+ type StopPings struct

+ func (c StopPings) Run(log *log.Logger, sim *Simulator)

+ func (c StopPings) String() string

v0.8.0

Apr 4, 2022

Changes in this version

type DefaultRouter

+ func (r *DefaultRouter) ManholeHandler(w http.ResponseWriter, req *http.Request)

type SimRouter

+ ManholeHandler func(w http.ResponseWriter, req *http.Request)

v0.7.0

Mar 30, 2022

Changes in this version

+ const FAILURE_PREAMBLE

+ type APICommandID int

+ const SimAddNode

+ const SimAddPeer

+ const SimConfigureAdversaryDefaults

+ const SimConfigureAdversaryPeer

+ const SimDebug

+ const SimDelay

+ const SimPause

+ const SimPlay

+ const SimRemoveNode

+ const SimRemovePeer

+ const UnknownCommand

+ type APICommandMessageID int

+ const SimPlaySequence

+ const UnknownCommandMsg

+ type APIEventMessageID int

+ const SimStateUpdate

+ const UnknownEventMsg

+ type APINodeType int

+ const DefaultNode

+ const GeneralAdversaryNode

+ const UnknownType

+ type AddNode struct

+ Node string

+ NodeType APINodeType

+ func (c AddNode) Run(log *log.Logger, sim *Simulator)

+ func (c AddNode) String() string

+ type AddPeer struct

+ Node string

+ Peer string

+ func (c AddPeer) Run(log *log.Logger, sim *Simulator)

+ func (c AddPeer) String() string

+ type ConfigureAdversaryDefaults struct

+ DropRates adversary.DropRates

+ Node string

+ func (c ConfigureAdversaryDefaults) Run(log *log.Logger, sim *Simulator)

+ func (c ConfigureAdversaryDefaults) String() string

+ type ConfigureAdversaryPeer struct

+ DropRates adversary.DropRates

+ Node string

+ Peer string

+ func (c ConfigureAdversaryPeer) Run(log *log.Logger, sim *Simulator)

+ func (c ConfigureAdversaryPeer) String() string

+ type DefaultRouter struct

+ func (r *DefaultRouter) ConfigureFilterDefaults(rates adversary.DropRates)

+ func (r *DefaultRouter) ConfigureFilterPeer(peer types.PublicKey, rates adversary.DropRates)

+ func (r *DefaultRouter) Connect(conn net.Conn, options ...router.ConnectionOption) (types.SwitchPortID, error)

+ func (r *DefaultRouter) Coords() types.Coordinates

+ func (r *DefaultRouter) Ping(ctx context.Context, a net.Addr) (uint16, time.Duration, error)

+ func (r *DefaultRouter) PublicKey() types.PublicKey

+ func (r *DefaultRouter) Subscribe(ch chan events.Event)

+ type Delay struct

+ Length uint64

+ func (c Delay) Run(log *log.Logger, sim *Simulator)

+ func (c Delay) String() string

+ type EventSequencePlayer interface

+ AddToPlaylist func(commands []SimCommand)

+ Pause func()

+ Play func()

+ type EventSequenceRunner struct

+ func (r *EventSequenceRunner) Pause()

+ func (r *EventSequenceRunner) Play()

+ func (r *EventSequenceRunner) Run(sim *Simulator)

type InitialNodeState

+ NodeType APINodeType

type NodeAdded

+ NodeType int

type NodeState

+ NodeType APINodeType

+ func (n NodeState) String() string

+ type Pause struct

+ func (c Pause) Run(log *log.Logger, sim *Simulator)

+ func (c Pause) String() string

+ type Play struct

+ func (c Play) Run(log *log.Logger, sim *Simulator)

+ func (c Play) String() string

+ type RemoveNode struct

+ Node string

+ func (c RemoveNode) Run(log *log.Logger, sim *Simulator)

+ func (c RemoveNode) String() string

+ type RemovePeer struct

+ Node string

+ Peer string

+ func (c RemovePeer) Run(log *log.Logger, sim *Simulator)

+ func (c RemovePeer) String() string

+ type RouterCreatorFn func(log *log.Logger, sk ed25519.PrivateKey, debug bool) SimRouter

+ type SimCommand interface

+ Run func(log *log.Logger, sim *Simulator)

+ func UnmarshalCommandJSON(command *SimCommandMsg) (SimCommand, error)

+ type SimCommandMsg struct

+ Event interface{}

+ MsgID APICommandID

+ type SimCommandSequenceMsg struct

+ Events []SimCommandMsg

+ MsgID APICommandMessageID

+ type SimRouter interface

+ ConfigureFilterDefaults func(rates adversary.DropRates)

+ ConfigureFilterPeer func(peer types.PublicKey, rates adversary.DropRates)

+ Connect func(conn net.Conn, options ...router.ConnectionOption) (types.SwitchPortID, error)

+ Coords func() types.Coordinates

+ Ping func(ctx context.Context, a net.Addr) (uint16, time.Duration, error)

+ PublicKey func() types.PublicKey

+ Subscribe func(ch chan events.Event)

type Simulator

+ AcceptCommands bool

+ func (sim *Simulator) AddToPlaylist(commands []SimCommand)

+ func (sim *Simulator) ConfigureFilterDefaults(node string, rates adversary.DropRates)

+ func (sim *Simulator) ConfigureFilterPeer(node string, peer string, rates adversary.DropRates)

+ func (sim *Simulator) DisconnectAllPeers(disconnectNode string)

+ func (sim *Simulator) Pause()

+ func (sim *Simulator) Play()

+ func (sim *Simulator) RemoveNode(node string)

type State

+ func (s State) String() string

type StateAccessor

+ func (s *StateAccessor) DebugLog() string

+ type StateDebug struct

+ func (c StateDebug) Run(log *log.Logger, sim *Simulator)

+ func (c StateDebug) String() string

v0.6.0

Dec 13, 2021

Changes in this version

+ type APIMessageID int

+ const SimInitialState

+ const SimUpdate

+ const UnknownMessage

+ type APIUpdateID int

+ const SimNodeAdded

+ const SimNodeRemoved

+ const SimPeerAdded

+ const SimPeerRemoved

+ const SimSnakeAscUpdated

+ const SimSnakeDescUpdated

+ const SimTreeParentUpdated

+ const SimTreeRootAnnUpdated

+ const UnknownUpdate

+ type InitialNodeState struct

+ Peers []PeerInfo

+ PublicKey string

+ RootState RootState

+ SnakeAsc string

+ SnakeAscPath string

+ SnakeDesc string

+ SnakeDescPath string

+ TreeParent string

+ type InitialStateMsg struct

+ End bool

+ MsgID APIMessageID

+ Nodes map[string]InitialNodeState

+ type NodeAdded struct

+ Node string

+ PublicKey string

+ type NodeRemoved struct

+ Node string

+ type NodeState struct

+ Announcement RootAnnouncement

+ AscendingPathID string

+ AscendingPeer string

+ Connections map[int]string

+ Coords []uint64

+ DescendingPathID string

+ DescendingPeer string

+ Parent string

+ PeerID string

+ func NewNodeState(peerID string) *NodeState

+ type PeerAdded struct

+ Node string

+ Peer string

+ Port uint64

+ type PeerInfo struct

+ ID string

+ Port int

+ type PeerRemoved struct

+ Node string

+ Peer string

+ type RootAnnouncement struct

+ Root string

+ Sequence uint64

+ Time uint64

+ type RootState struct

+ AnnSequence uint64

+ AnnTime uint64

+ Coords []uint64

+ Root string

+ type SimEvent interface

+ type SimEventMsg struct

+ Event SimEvent

+ UpdateID APIUpdateID

type Simulator

+ State *StateAccessor

+ func (sim *Simulator) StartNodeEventHandler(t string)

+ type SnakeAscUpdate struct

+ Node string

+ PathID string

+ Peer string

+ Prev string

+ type SnakeDescUpdate struct

+ Node string

+ PathID string

+ Peer string

+ Prev string

+ type State struct

+ Nodes map[string]*NodeState

+ func NewState() *State

+ type StateAccessor struct

+ func NewStateAccessor() *StateAccessor

+ func (s *StateAccessor) GetLinkCount() float64

+ func (s *StateAccessor) GetNodeCoords(name string) []uint64

+ func (s *StateAccessor) GetNodeName(peerID string) (string, error)

+ func (s *StateAccessor) Subscribe(ch chan<- SimEvent) State

+ type StateUpdateMsg struct

+ Event SimEventMsg

+ MsgID APIMessageID

+ type TreeParentUpdate struct

+ Node string

+ Peer string

+ Prev string

+ type TreeRootAnnUpdate struct

+ Coords []uint64

+ Node string

+ Root string

+ Sequence uint64

+ Time uint64

v0.5.0

Oct 21, 2021

Changes in this version

type Distance

+ ObservedSNEK int64

+ ObservedTree int64

v0.4.0

Oct 8, 2021

Changes in this version

type Simulator

+ func (sim *Simulator) PingSNEK(from, to string) error

+ func (sim *Simulator) PingTree(from, to string) error

+ func (sim *Simulator) PingingEnabled() bool

+ func (sim *Simulator) Uptime() time.Duration

v0.3.0

Jun 8, 2021

v0.2.0

May 24, 2021

Changes in this version

type Node

+ ListenAddr *net.TCPAddr

type Simulator

+ func (sim *Simulator) PathfindSNEK(from, to string) error

+ func (sim *Simulator) PathfindTree(from, to string) error

+ func (sim *Simulator) SNEKPathConvergence() map[string]map[string]bool

+ func (sim *Simulator) TreePathConvergence() map[string]map[string]bool

v0.1.0

May 5, 2021

Changes in this version

+ type Distance struct

+ Observed int64

+ Real int64

+ type Node struct

+ ListenPort string

+ type Simulator struct

+ func NewSimulator(log *log.Logger) *Simulator

+ func (sim *Simulator) CalculateShortestPaths(nodes map[string]struct{}, wires map[string]map[string]bool)

+ func (sim *Simulator) ConnectNodes(a, b string) error

+ func (sim *Simulator) CreateNode(t string) error

+ func (sim *Simulator) DHTConvergence() map[string]map[string]bool

+ func (sim *Simulator) DisconnectNodes(a, b string) error

+ func (sim *Simulator) Distances() map[string]map[string]*Distance

+ func (sim *Simulator) LookupCoords(target string) (types.SwitchPorts, error)

+ func (sim *Simulator) LookupNodeID(target types.SwitchPorts) (string, error)

+ func (sim *Simulator) LookupPublicKey(target types.PublicKey) (string, error)

+ func (sim *Simulator) Node(t string) *Node

+ func (sim *Simulator) Nodes() map[string]*Node

+ func (sim *Simulator) PathConvergence() map[string]map[string]bool

+ func (sim *Simulator) Pathfind(from, to string) error

+ func (sim *Simulator) ReportDeadLink(source, target types.PublicKey)

+ func (sim *Simulator) ReportDistance(a, b string, l int64)

+ func (sim *Simulator) ReportNewLink(c net.Conn, source, target types.PublicKey)

+ func (sim *Simulator) Wires() map[string]map[string]net.Conn

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