electionMsgTesting

Documentation

Index

• func NewTestVolunteerMessage(ele *elections.Elections, f, a int) *electionMsgs.FedVoteVolunteerMsg
• type Controller
  • func NewController(feds, auds int) *Controller
  • func (c *Controller) ElectionStatus(node int) string
  • func (c *Controller) RouteLeaderLevelMessage(from int, level int, to []int) bool
  • func (c *Controller) RouteLeaderSetLevelMessage(from []int, level int, to []int) bool
  • func (c *Controller) RouteLeaderSetVoteMessage(from []int, vol int, to []int) bool
  • func (c *Controller) RouteLeaderVoteMessage(from int, vol int, to []int) bool
  • func (c *Controller) RouteMessage(msg interfaces.IMsg, nodes []int)
  • func (c *Controller) RouteVolunteerMessage(vol int, nodes []int)
• type MessageBuffer
  • func NewMessageBuffer() *MessageBuffer
  • func (b *MessageBuffer) Add(msg interfaces.IMsg)
  • func (b *MessageBuffer) RetrieveIndex(index int) (interfaces.IMsg, error)
  • func (b *MessageBuffer) RetrieveLeaderLevelMessageByLevel(leader interfaces.IHash, level int) interfaces.IMsg
  • func (b *MessageBuffer) RetrieveLeaderVoteMessage(leader interfaces.IHash, vol interfaces.IHash) interfaces.IMsg

Functions

func NewTestVolunteerMessage

func NewTestVolunteerMessage(ele *elections.Elections, f, a int) *electionMsgs.FedVoteVolunteerMsg

Types

type Controller

type Controller struct {
	Elections        []*elections.Elections
	ElectionAdapters []*electionMsgs.ElectionAdapter
	Volunteers       []*electionMsgs.FedVoteVolunteerMsg

	Buffer        *MessageBuffer
	GlobalDisplay *election.Display

	//Router          *Router
	OutputsToRouter bool

	*priminterpreter.Primitives

	PrintingTrace bool

	History []string
	// contains filtered or unexported fields
}

Controller will be able to route messages to a set of nodes and control various communication patterns

func NewController

func NewController(feds, auds int) *Controller

NewController creates all the elections and initial volunteer messages

func (*Controller) ElectionStatus

func (c *Controller) ElectionStatus(node int) string

func (*Controller) RouteLeaderLevelMessage

func (c *Controller) RouteLeaderLevelMessage(from int, level int, to []int) bool

func (*Controller) RouteLeaderSetLevelMessage

func (c *Controller) RouteLeaderSetLevelMessage(from []int, level int, to []int) bool

func (*Controller) RouteLeaderSetVoteMessage

func (c *Controller) RouteLeaderSetVoteMessage(from []int, vol int, to []int) bool

func (*Controller) RouteLeaderVoteMessage

func (c *Controller) RouteLeaderVoteMessage(from int, vol int, to []int) bool

func (*Controller) RouteMessage

func (c *Controller) RouteMessage(msg interfaces.IMsg, nodes []int)

RouteMessage will execute message on all nodes given and add the messages returned to the buffer

func (*Controller) RouteVolunteerMessage

func (c *Controller) RouteVolunteerMessage(vol int, nodes []int)

type MessageBuffer

type MessageBuffer struct {
	// A list of all messages, it's an ever growing set, trimming the front
	// keeps the index the same by using the 'base' field.
	Messages []interfaces.IMsg
	Base     int

	// When looking for a message by someone, this helps searching
	MessagesMap map[[32]byte][]int
}

MessageBuffer will manage all messages in the message list

func NewMessageBuffer

func NewMessageBuffer() *MessageBuffer

func (*MessageBuffer) Add

func (b *MessageBuffer) Add(msg interfaces.IMsg)

func (*MessageBuffer) RetrieveIndex

func (b *MessageBuffer) RetrieveIndex(index int) (interfaces.IMsg, error)

func (*MessageBuffer) RetrieveLeaderLevelMessageByLevel

func (b *MessageBuffer) RetrieveLeaderLevelMessageByLevel(leader interfaces.IHash, level int) interfaces.IMsg

func (*MessageBuffer) RetrieveLeaderVoteMessage

func (b *MessageBuffer) RetrieveLeaderVoteMessage(leader interfaces.IHash, vol interfaces.IHash) interfaces.IMsg

RetrieveLeaderVoteMessage takes a vol too as multiple vote 0s can be sent out