network

Documentation

Index

• type BaseNetwork
  • func NewNetwork(peers map[peerpb.PeerID]peer.Protocol, failures, runTicks int) BaseNetwork
  • func (n *BaseNetwork) Alive(p peer.Protocol) bool
  • func (n *BaseNetwork) Crash(id peerpb.PeerID) peer.Protocol
  • func (n *BaseNetwork) CrashN(c int, except peerpb.PeerID)
  • func (n *BaseNetwork) Delay(from, to peerpb.PeerID)
  • func (n *BaseNetwork) F() int
  • func (n *BaseNetwork) RunNetwork(goal func(p peer.Protocol) bool, quorum bool) bool
  • func (n *BaseNetwork) UnDelay(from, to peerpb.PeerID)
• type Network

Types

type BaseNetwork

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

func NewNetwork

func NewNetwork(peers map[peerpb.PeerID]peer.Protocol, failures, runTicks int) BaseNetwork

func (*BaseNetwork) Alive

func (n *BaseNetwork) Alive(p peer.Protocol) bool

func (*BaseNetwork) Crash

func (n *BaseNetwork) Crash(id peerpb.PeerID) peer.Protocol

func (*BaseNetwork) CrashN

func (n *BaseNetwork) CrashN(c int, except peerpb.PeerID)

func (*BaseNetwork) Delay

func (n *BaseNetwork) Delay(from, to peerpb.PeerID)

func (*BaseNetwork) F

func (n *BaseNetwork) F() int

func (*BaseNetwork) RunNetwork

func (n *BaseNetwork) RunNetwork(goal func(p peer.Protocol) bool, quorum bool) bool

runNetwork waits until the given goal for an epaxos node has been completed. If quorum is true, it will wait until the goal is completed on a quorum of nodes. If it is false, it will wait until the goal is completed on all nodes.

func (*BaseNetwork) UnDelay

func (n *BaseNetwork) UnDelay(from, to peerpb.PeerID)

type Network

type Network interface {
}