messages

Documentation

Index

• Constants
• func BuildMessage(myId int, c clock.LogicalClock, messageType MessageType, weight float64, ...) string
• type CommandType
  • func IdentifyCommand(command string) CommandType
• type LiberateCommand
  • func ParseLiberateCommand(command string, numPorts int) *LiberateCommand
• type Message
  • func ParseMessage(msg string) (Message, error)
• type MessageType
  • func (m MessageType) String() string
• type RequestCommand
  • func ParseRequestCommand(command string, numPorts int) *RequestCommand

Constants

const (
	Request MessageType = "request"
	Reply   MessageType = "reply"
	Cancel  MessageType = "cancel"
	Flood   MessageType = "flood"
	Echo    MessageType = "echo"
	Short   MessageType = "short"

	Ask      CommandType = "ask"
	Detect   CommandType = "detect"
	Liberate CommandType = "liberate"
	Unknown  CommandType = "unknown"
)

Functions

func BuildMessage

func BuildMessage(myId int, c clock.LogicalClock, messageType MessageType, weight float64, initiatorId int, initiatedAt int) string

Types

type CommandType

type CommandType string

func IdentifyCommand

func IdentifyCommand(command string) CommandType

type LiberateCommand

type LiberateCommand struct {
	ParentIds   []int
	LiberateAll bool
}

func ParseLiberateCommand

func ParseLiberateCommand(command string, numPorts int) *LiberateCommand

type Message

type Message struct {
	SenderId    int     `json:"id"`
	Text        string  `json:"type"`
	ClockStr    string  `json:"clock_str"`
	Weight      float64 `json:"weight"`
	InitiatorId int     `json:"initiator_id"`
	InitiatedAt int     `json:"initiated_at"`
}

func ParseMessage

func ParseMessage(msg string) (Message, error)

type MessageType

type MessageType string

func (MessageType) String

func (m MessageType) String() string

type RequestCommand

type RequestCommand struct {
	NeededReplies int
	ChildIds      []int
}

func ParseRequestCommand

func ParseRequestCommand(command string, numPorts int) *RequestCommand