message

package
v0.0.0-...-6c8c7d5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 30, 2017 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Overview

Package message is a generated protocol buffer package.

It is generated from these files: 

protos.proto

It has these top-level messages: 

Hello
Available
NotAvailable
NotFound
Register
LookForCoordinator
Welcome
NewNode
DeadNode
RequestForCache
RequestForCacheExternal
Response
AskForResult
SearchInCache
ResponseFromCache
LostConnectionCoordinator
Ping
Pong
GetPing

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProtos = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtos   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type AskForResult 

type AskForResult struct {
	Operation string `protobuf:"bytes,1,opt,name=Operation,proto3" json:"Operation,omitempty"`
}

Message from controller to peer

func (*AskForResult) Descriptor 

func (*AskForResult) Descriptor() ([]byte, []int)

func (*AskForResult) Equal 

func (this *AskForResult) Equal(that interface{}) bool

func (*AskForResult) GetOperation 

func (m *AskForResult) GetOperation() string

func (*AskForResult) GoString 

func (this *AskForResult) GoString() string

func (*AskForResult) Marshal 

func (m *AskForResult) Marshal() (dAtA []byte, err error)

func (*AskForResult) MarshalTo 

func (m *AskForResult) MarshalTo(dAtA []byte) (int, error)

func (*AskForResult) ProtoMessage 

func (*AskForResult) ProtoMessage()

func (*AskForResult) Reset 

func (m *AskForResult) Reset()

func (*AskForResult) Size 

func (m *AskForResult) Size() (n int)

func (*AskForResult) String 

func (this *AskForResult) String() string

func (*AskForResult) Unmarshal 

func (m *AskForResult) Unmarshal(dAtA []byte) error

type Available 

type Available struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=sender" json:"sender,omitempty"`
}

Response msg from coordinator to Hello msg

func (*Available) Descriptor 

func (*Available) Descriptor() ([]byte, []int)

func (*Available) Equal 

func (this *Available) Equal(that interface{}) bool

func (*Available) GetSender 

func (m *Available) GetSender() *actor.PID

func (*Available) GoString 

func (this *Available) GoString() string

func (*Available) Marshal 

func (m *Available) Marshal() (dAtA []byte, err error)

func (*Available) MarshalTo 

func (m *Available) MarshalTo(dAtA []byte) (int, error)

func (*Available) ProtoMessage 

func (*Available) ProtoMessage()

func (*Available) Reset 

func (m *Available) Reset()

func (*Available) Size 

func (m *Available) Size() (n int)

func (*Available) String 

func (this *Available) String() string

func (*Available) Unmarshal 

func (m *Available) Unmarshal(dAtA []byte) error

type DeadNode 

type DeadNode struct {
	DeadNode *actor.PID `protobuf:"bytes,1,opt,name=deadNode" json:"deadNode,omitempty"`
}

Message sent to all peers from coordinator when detects a dead node/peer

func (*DeadNode) Descriptor 

func (*DeadNode) Descriptor() ([]byte, []int)

func (*DeadNode) Equal 

func (this *DeadNode) Equal(that interface{}) bool

func (*DeadNode) GetDeadNode 

func (m *DeadNode) GetDeadNode() *actor.PID

func (*DeadNode) GoString 

func (this *DeadNode) GoString() string

func (*DeadNode) Marshal 

func (m *DeadNode) Marshal() (dAtA []byte, err error)

func (*DeadNode) MarshalTo 

func (m *DeadNode) MarshalTo(dAtA []byte) (int, error)

func (*DeadNode) ProtoMessage 

func (*DeadNode) ProtoMessage()

func (*DeadNode) Reset 

func (m *DeadNode) Reset()

func (*DeadNode) Size 

func (m *DeadNode) Size() (n int)

func (*DeadNode) String 

func (this *DeadNode) String() string

func (*DeadNode) Unmarshal 

func (m *DeadNode) Unmarshal(dAtA []byte) error

type GetPing 

type GetPing struct {
	Peer string `protobuf:"bytes,1,opt,name=Peer,proto3" json:"Peer,omitempty"`
}

Message to ask coordinator for a single ping value

func (*GetPing) Descriptor 

func (*GetPing) Descriptor() ([]byte, []int)

func (*GetPing) Equal 

func (this *GetPing) Equal(that interface{}) bool

func (*GetPing) GetPeer 

func (m *GetPing) GetPeer() string

func (*GetPing) GoString 

func (this *GetPing) GoString() string

func (*GetPing) Marshal 

func (m *GetPing) Marshal() (dAtA []byte, err error)

func (*GetPing) MarshalTo 

func (m *GetPing) MarshalTo(dAtA []byte) (int, error)

func (*GetPing) ProtoMessage 

func (*GetPing) ProtoMessage()

func (*GetPing) Reset 

func (m *GetPing) Reset()

func (*GetPing) Size 

func (m *GetPing) Size() (n int)

func (*GetPing) String 

func (this *GetPing) String() string

func (*GetPing) Unmarshal 

func (m *GetPing) Unmarshal(dAtA []byte) error

type Hello 

type Hello struct {
	ComputeCapability int64 `protobuf:"varint,1,opt,name=ComputeCapability,proto3" json:"ComputeCapability,omitempty"`
}

Message from a new node to every coordinator, to discover if it is avalaible

func (*Hello) Descriptor 

func (*Hello) Descriptor() ([]byte, []int)

func (*Hello) Equal 

func (this *Hello) Equal(that interface{}) bool

func (*Hello) GetComputeCapability 

func (m *Hello) GetComputeCapability() int64

func (*Hello) GoString 

func (this *Hello) GoString() string

func (*Hello) Marshal 

func (m *Hello) Marshal() (dAtA []byte, err error)

func (*Hello) MarshalTo 

func (m *Hello) MarshalTo(dAtA []byte) (int, error)

func (*Hello) ProtoMessage 

func (*Hello) ProtoMessage()

func (*Hello) Reset 

func (m *Hello) Reset()

func (*Hello) Size 

func (m *Hello) Size() (n int)

func (*Hello) String 

func (this *Hello) String() string

func (*Hello) Unmarshal 

func (m *Hello) Unmarshal(dAtA []byte) error

type LookForCoordinator 

type LookForCoordinator struct {
}

func (*LookForCoordinator) Descriptor 

func (*LookForCoordinator) Descriptor() ([]byte, []int)

func (*LookForCoordinator) Equal 

func (this *LookForCoordinator) Equal(that interface{}) bool

func (*LookForCoordinator) GoString 

func (this *LookForCoordinator) GoString() string

func (*LookForCoordinator) Marshal 

func (m *LookForCoordinator) Marshal() (dAtA []byte, err error)

func (*LookForCoordinator) MarshalTo 

func (m *LookForCoordinator) MarshalTo(dAtA []byte) (int, error)

func (*LookForCoordinator) ProtoMessage 

func (*LookForCoordinator) ProtoMessage()

func (*LookForCoordinator) Reset 

func (m *LookForCoordinator) Reset()

func (*LookForCoordinator) Size 

func (m *LookForCoordinator) Size() (n int)

func (*LookForCoordinator) String 

func (this *LookForCoordinator) String() string

func (*LookForCoordinator) Unmarshal 

func (m *LookForCoordinator) Unmarshal(dAtA []byte) error

type LostConnectionCoordinator 

type LostConnectionCoordinator struct {
	Coordinator *actor.PID `protobuf:"bytes,1,opt,name=coordinator" json:"coordinator,omitempty"`
}

Self-Message when a coordinator goes down

func (*LostConnectionCoordinator) Descriptor 

func (*LostConnectionCoordinator) Descriptor() ([]byte, []int)

func (*LostConnectionCoordinator) Equal 

func (this *LostConnectionCoordinator) Equal(that interface{}) bool

func (*LostConnectionCoordinator) GetCoordinator 

func (m *LostConnectionCoordinator) GetCoordinator() *actor.PID

func (*LostConnectionCoordinator) GoString 

func (this *LostConnectionCoordinator) GoString() string

func (*LostConnectionCoordinator) Marshal 

func (m *LostConnectionCoordinator) Marshal() (dAtA []byte, err error)

func (*LostConnectionCoordinator) MarshalTo 

func (m *LostConnectionCoordinator) MarshalTo(dAtA []byte) (int, error)

func (*LostConnectionCoordinator) ProtoMessage 

func (*LostConnectionCoordinator) ProtoMessage()

func (*LostConnectionCoordinator) Reset 

func (m *LostConnectionCoordinator) Reset()

func (*LostConnectionCoordinator) Size 

func (m *LostConnectionCoordinator) Size() (n int)

func (*LostConnectionCoordinator) String 

func (this *LostConnectionCoordinator) String() string

func (*LostConnectionCoordinator) Unmarshal 

func (m *LostConnectionCoordinator) Unmarshal(dAtA []byte) error

type NewNode 

type NewNode struct {
	Newnode *actor.PID `protobuf:"bytes,1,opt,name=newnode" json:"newnode,omitempty"`
}

Message sent to all peers when a new node enter the region

func (*NewNode) Descriptor 

func (*NewNode) Descriptor() ([]byte, []int)

func (*NewNode) Equal 

func (this *NewNode) Equal(that interface{}) bool

func (*NewNode) GetNewnode 

func (m *NewNode) GetNewnode() *actor.PID

func (*NewNode) GoString 

func (this *NewNode) GoString() string

func (*NewNode) Marshal 

func (m *NewNode) Marshal() (dAtA []byte, err error)

func (*NewNode) MarshalTo 

func (m *NewNode) MarshalTo(dAtA []byte) (int, error)

func (*NewNode) ProtoMessage 

func (*NewNode) ProtoMessage()

func (*NewNode) Reset 

func (m *NewNode) Reset()

func (*NewNode) Size 

func (m *NewNode) Size() (n int)

func (*NewNode) String 

func (this *NewNode) String() string

func (*NewNode) Unmarshal 

func (m *NewNode) Unmarshal(dAtA []byte) error

type NotAvailable 

type NotAvailable struct {
}

Response from coordinator is no slot

func (*NotAvailable) Descriptor 

func (*NotAvailable) Descriptor() ([]byte, []int)

func (*NotAvailable) Equal 

func (this *NotAvailable) Equal(that interface{}) bool

func (*NotAvailable) GoString 

func (this *NotAvailable) GoString() string

func (*NotAvailable) Marshal 

func (m *NotAvailable) Marshal() (dAtA []byte, err error)

func (*NotAvailable) MarshalTo 

func (m *NotAvailable) MarshalTo(dAtA []byte) (int, error)

func (*NotAvailable) ProtoMessage 

func (*NotAvailable) ProtoMessage()

func (*NotAvailable) Reset 

func (m *NotAvailable) Reset()

func (*NotAvailable) Size 

func (m *NotAvailable) Size() (n int)

func (*NotAvailable) String 

func (this *NotAvailable) String() string

func (*NotAvailable) Unmarshal 

func (m *NotAvailable) Unmarshal(dAtA []byte) error

type NotFound 

type NotFound struct {
	Operation string `protobuf:"bytes,1,opt,name=Operation,proto3" json:"Operation,omitempty"`
}

Message in response to peer when someone doesnt have the result in cache

func (*NotFound) Descriptor 

func (*NotFound) Descriptor() ([]byte, []int)

func (*NotFound) Equal 

func (this *NotFound) Equal(that interface{}) bool

func (*NotFound) GetOperation 

func (m *NotFound) GetOperation() string

func (*NotFound) GoString 

func (this *NotFound) GoString() string

func (*NotFound) Marshal 

func (m *NotFound) Marshal() (dAtA []byte, err error)

func (*NotFound) MarshalTo 

func (m *NotFound) MarshalTo(dAtA []byte) (int, error)

func (*NotFound) ProtoMessage 

func (*NotFound) ProtoMessage()

func (*NotFound) Reset 

func (m *NotFound) Reset()

func (*NotFound) Size 

func (m *NotFound) Size() (n int)

func (*NotFound) String 

func (this *NotFound) String() string

func (*NotFound) Unmarshal 

func (m *NotFound) Unmarshal(dAtA []byte) error

type Ping 

type Ping struct {
	Ping int64 `protobuf:"varint,1,opt,name=Ping,proto3" json:"Ping,omitempty"`
}

Message from coordinator to self or to peer: init ping/pong process

func (*Ping) Descriptor 

func (*Ping) Descriptor() ([]byte, []int)

func (*Ping) Equal 

func (this *Ping) Equal(that interface{}) bool

func (*Ping) GetPing 

func (m *Ping) GetPing() int64

func (*Ping) GoString 

func (this *Ping) GoString() string

func (*Ping) Marshal 

func (m *Ping) Marshal() (dAtA []byte, err error)

func (*Ping) MarshalTo 

func (m *Ping) MarshalTo(dAtA []byte) (int, error)

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

func (m *Ping) Size() (n int)

func (*Ping) String 

func (this *Ping) String() string

func (*Ping) Unmarshal 

func (m *Ping) Unmarshal(dAtA []byte) error

type Pong 

type Pong struct {
	Pong int64 `protobuf:"varint,1,opt,name=Pong,proto3" json:"Pong,omitempty"`
}

Response from Ping message

func (*Pong) Descriptor 

func (*Pong) Descriptor() ([]byte, []int)

func (*Pong) Equal 

func (this *Pong) Equal(that interface{}) bool

func (*Pong) GetPong 

func (m *Pong) GetPong() int64

func (*Pong) GoString 

func (this *Pong) GoString() string

func (*Pong) Marshal 

func (m *Pong) Marshal() (dAtA []byte, err error)

func (*Pong) MarshalTo 

func (m *Pong) MarshalTo(dAtA []byte) (int, error)

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) Size 

func (m *Pong) Size() (n int)

func (*Pong) String 

func (this *Pong) String() string

func (*Pong) Unmarshal 

func (m *Pong) Unmarshal(dAtA []byte) error

type Register 

type Register struct {
	ComputeCapability int64 `protobuf:"varint,1,opt,name=computeCapability,proto3" json:"computeCapability,omitempty"`
}

Message sent from new node to his coordinator after receiving Available msg

func (*Register) Descriptor 

func (*Register) Descriptor() ([]byte, []int)

func (*Register) Equal 

func (this *Register) Equal(that interface{}) bool

func (*Register) GetComputeCapability 

func (m *Register) GetComputeCapability() int64

func (*Register) GoString 

func (this *Register) GoString() string

func (*Register) Marshal 

func (m *Register) Marshal() (dAtA []byte, err error)

func (*Register) MarshalTo 

func (m *Register) MarshalTo(dAtA []byte) (int, error)

func (*Register) ProtoMessage 

func (*Register) ProtoMessage()

func (*Register) Reset 

func (m *Register) Reset()

func (*Register) Size 

func (m *Register) Size() (n int)

func (*Register) String 

func (this *Register) String() string

func (*Register) Unmarshal 

func (m *Register) Unmarshal(dAtA []byte) error

type RequestForCache 

type RequestForCache struct {
	Operation string     `protobuf:"bytes,1,opt,name=Operation,proto3" json:"Operation,omitempty"`
	Sender    *actor.PID `protobuf:"bytes,2,opt,name=sender" json:"sender,omitempty"`
}

Message sent by a node to other nodes (also coordinator if necessary)

func (*RequestForCache) Descriptor 

func (*RequestForCache) Descriptor() ([]byte, []int)

func (*RequestForCache) Equal 

func (this *RequestForCache) Equal(that interface{}) bool

func (*RequestForCache) GetOperation 

func (m *RequestForCache) GetOperation() string

func (*RequestForCache) GetSender 

func (m *RequestForCache) GetSender() *actor.PID

func (*RequestForCache) GoString 

func (this *RequestForCache) GoString() string

func (*RequestForCache) Marshal 

func (m *RequestForCache) Marshal() (dAtA []byte, err error)

func (*RequestForCache) MarshalTo 

func (m *RequestForCache) MarshalTo(dAtA []byte) (int, error)

func (*RequestForCache) ProtoMessage 

func (*RequestForCache) ProtoMessage()

func (*RequestForCache) Reset 

func (m *RequestForCache) Reset()

func (*RequestForCache) Size 

func (m *RequestForCache) Size() (n int)

func (*RequestForCache) String 

func (this *RequestForCache) String() string

func (*RequestForCache) Unmarshal 

func (m *RequestForCache) Unmarshal(dAtA []byte) error

type RequestForCacheExternal 

type RequestForCacheExternal struct {
	Operation string     `protobuf:"bytes,1,opt,name=Operation,proto3" json:"Operation,omitempty"`
	Sender    *actor.PID `protobuf:"bytes,2,opt,name=sender" json:"sender,omitempty"`
}

Message sent by a coordinator to other coordinators

func (*RequestForCacheExternal) Descriptor 

func (*RequestForCacheExternal) Descriptor() ([]byte, []int)

func (*RequestForCacheExternal) Equal 

func (this *RequestForCacheExternal) Equal(that interface{}) bool

func (*RequestForCacheExternal) GetOperation 

func (m *RequestForCacheExternal) GetOperation() string

func (*RequestForCacheExternal) GetSender 

func (m *RequestForCacheExternal) GetSender() *actor.PID

func (*RequestForCacheExternal) GoString 

func (this *RequestForCacheExternal) GoString() string

func (*RequestForCacheExternal) Marshal 

func (m *RequestForCacheExternal) Marshal() (dAtA []byte, err error)

func (*RequestForCacheExternal) MarshalTo 

func (m *RequestForCacheExternal) MarshalTo(dAtA []byte) (int, error)

func (*RequestForCacheExternal) ProtoMessage 

func (*RequestForCacheExternal) ProtoMessage()

func (*RequestForCacheExternal) Reset 

func (m *RequestForCacheExternal) Reset()

func (*RequestForCacheExternal) Size 

func (m *RequestForCacheExternal) Size() (n int)

func (*RequestForCacheExternal) String 

func (this *RequestForCacheExternal) String() string

func (*RequestForCacheExternal) Unmarshal 

func (m *RequestForCacheExternal) Unmarshal(dAtA []byte) error

type Response 

type Response struct {
	Result string `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
}

Response msg for RequestForCache/RequestForCacheExternal

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) Equal 

func (this *Response) Equal(that interface{}) bool

func (*Response) GetResult 

func (m *Response) GetResult() string

func (*Response) GoString 

func (this *Response) GoString() string

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (this *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

type ResponseFromCache 

type ResponseFromCache struct {
	Result string `protobuf:"bytes,1,opt,name=Result,proto3" json:"Result,omitempty"`
}

Response msg from a peer to another peer

func (*ResponseFromCache) Descriptor 

func (*ResponseFromCache) Descriptor() ([]byte, []int)

func (*ResponseFromCache) Equal 

func (this *ResponseFromCache) Equal(that interface{}) bool

func (*ResponseFromCache) GetResult 

func (m *ResponseFromCache) GetResult() string

func (*ResponseFromCache) GoString 

func (this *ResponseFromCache) GoString() string

func (*ResponseFromCache) Marshal 

func (m *ResponseFromCache) Marshal() (dAtA []byte, err error)

func (*ResponseFromCache) MarshalTo 

func (m *ResponseFromCache) MarshalTo(dAtA []byte) (int, error)

func (*ResponseFromCache) ProtoMessage 

func (*ResponseFromCache) ProtoMessage()

func (*ResponseFromCache) Reset 

func (m *ResponseFromCache) Reset()

func (*ResponseFromCache) Size 

func (m *ResponseFromCache) Size() (n int)

func (*ResponseFromCache) String 

func (this *ResponseFromCache) String() string

func (*ResponseFromCache) Unmarshal 

func (m *ResponseFromCache) Unmarshal(dAtA []byte) error

type SearchInCache 

type SearchInCache struct {
	Operation string     `protobuf:"bytes,1,opt,name=Operation,proto3" json:"Operation,omitempty"`
	FromPeer  *actor.PID `protobuf:"bytes,2,opt,name=FromPeer" json:"FromPeer,omitempty"`
}

Message from peer to controller

func (*SearchInCache) Descriptor 

func (*SearchInCache) Descriptor() ([]byte, []int)

func (*SearchInCache) Equal 

func (this *SearchInCache) Equal(that interface{}) bool

func (*SearchInCache) GetFromPeer 

func (m *SearchInCache) GetFromPeer() *actor.PID

func (*SearchInCache) GetOperation 

func (m *SearchInCache) GetOperation() string

func (*SearchInCache) GoString 

func (this *SearchInCache) GoString() string

func (*SearchInCache) Marshal 

func (m *SearchInCache) Marshal() (dAtA []byte, err error)

func (*SearchInCache) MarshalTo 

func (m *SearchInCache) MarshalTo(dAtA []byte) (int, error)

func (*SearchInCache) ProtoMessage 

func (*SearchInCache) ProtoMessage()

func (*SearchInCache) Reset 

func (m *SearchInCache) Reset()

func (*SearchInCache) Size 

func (m *SearchInCache) Size() (n int)

func (*SearchInCache) String 

func (this *SearchInCache) String() string

func (*SearchInCache) Unmarshal 

func (m *SearchInCache) Unmarshal(dAtA []byte) error

type Welcome 

type Welcome struct {
	Nodes map[string]*actor.PID `` /* 137-byte string literal not displayed */
}

Message to new node from coordinator containing the peer list

func (*Welcome) Descriptor 

func (*Welcome) Descriptor() ([]byte, []int)

func (*Welcome) Equal 

func (this *Welcome) Equal(that interface{}) bool

func (*Welcome) GetNodes 

func (m *Welcome) GetNodes() map[string]*actor.PID

func (*Welcome) GoString 

func (this *Welcome) GoString() string

func (*Welcome) Marshal 

func (m *Welcome) Marshal() (dAtA []byte, err error)

func (*Welcome) MarshalTo 

func (m *Welcome) MarshalTo(dAtA []byte) (int, error)

func (*Welcome) ProtoMessage 

func (*Welcome) ProtoMessage()

func (*Welcome) Reset 

func (m *Welcome) Reset()

func (*Welcome) Size 

func (m *Welcome) Size() (n int)

func (*Welcome) String 

func (this *Welcome) String() string

func (*Welcome) Unmarshal 

func (m *Welcome) Unmarshal(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.