communicator

Documentation

Index

• Variables
• func GenerateId() string
• func MarshallMessage(msg *Message) []byte
• type Message
  • func UnmarshallMessage(buffer []byte) Message
• type MessageType
  • func (mt MessageType) String() string

Variables

var PendingGetData = make(map[string]chan string)

var PendingGetSucc = make(map[string]chan shared.DistantNode)

var PendingHearBeat = make(map[string]chan shared.DistantNode)

var PendingLookups = make(map[string]chan shared.DistantNode)

Global variable -------------------------------------------------------

Functions

func GenerateId

func GenerateId() string

func MarshallMessage

func MarshallMessage(msg *Message) []byte

Exported methods ------------------------------------------------------

Types

type Message

type Message struct {
	TypeOfMsg   MessageType
	Origin      shared.DistantNode
	Destination shared.DistantNode
	Parameters  map[string]string
}

func UnmarshallMessage

func UnmarshallMessage(buffer []byte) Message

type MessageType

type MessageType int

Const parts -----------------------------------------------------------

const (
	LOOKUP               MessageType = iota + 1 //1
	LOOKUPRESPONSE                              //2
	UPDATESUCCESSOR                             //3
	UPDATEPREDECESSOR                           //4
	PRINTRING                                   //5
	JOINRING                                    //6
	UPDATEFINGERTABLE                           //7
	AREYOUALIVE                                 //8
	IAMALIVE                                    //9
	GETSUCCESORE                                //10
	GETSUCCESORERESPONSE                        //11
	GETDATA                                     //12
	GETDATARESPONSE                             //13
	SETDATA                                     //14
	DELETEDATA                                  //15
)

func (MessageType) String

func (mt MessageType) String() string