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 ¶
- Variables
- type AskForResult
- func (*AskForResult) Descriptor() ([]byte, []int)
- func (this *AskForResult) Equal(that interface{}) bool
- func (m *AskForResult) GetOperation() string
- func (this *AskForResult) GoString() string
- func (m *AskForResult) Marshal() (dAtA []byte, err error)
- func (m *AskForResult) MarshalTo(dAtA []byte) (int, error)
- func (*AskForResult) ProtoMessage()
- func (m *AskForResult) Reset()
- func (m *AskForResult) Size() (n int)
- func (this *AskForResult) String() string
- func (m *AskForResult) Unmarshal(dAtA []byte) error
- type Available
- func (*Available) Descriptor() ([]byte, []int)
- func (this *Available) Equal(that interface{}) bool
- func (m *Available) GetSender() *actor.PID
- func (this *Available) GoString() string
- func (m *Available) Marshal() (dAtA []byte, err error)
- func (m *Available) MarshalTo(dAtA []byte) (int, error)
- func (*Available) ProtoMessage()
- func (m *Available) Reset()
- func (m *Available) Size() (n int)
- func (this *Available) String() string
- func (m *Available) Unmarshal(dAtA []byte) error
- type DeadNode
- func (*DeadNode) Descriptor() ([]byte, []int)
- func (this *DeadNode) Equal(that interface{}) bool
- func (m *DeadNode) GetDeadNode() *actor.PID
- func (this *DeadNode) GoString() string
- func (m *DeadNode) Marshal() (dAtA []byte, err error)
- func (m *DeadNode) MarshalTo(dAtA []byte) (int, error)
- func (*DeadNode) ProtoMessage()
- func (m *DeadNode) Reset()
- func (m *DeadNode) Size() (n int)
- func (this *DeadNode) String() string
- func (m *DeadNode) Unmarshal(dAtA []byte) error
- type GetPing
- func (*GetPing) Descriptor() ([]byte, []int)
- func (this *GetPing) Equal(that interface{}) bool
- func (m *GetPing) GetPeer() string
- func (this *GetPing) GoString() string
- func (m *GetPing) Marshal() (dAtA []byte, err error)
- func (m *GetPing) MarshalTo(dAtA []byte) (int, error)
- func (*GetPing) ProtoMessage()
- func (m *GetPing) Reset()
- func (m *GetPing) Size() (n int)
- func (this *GetPing) String() string
- func (m *GetPing) Unmarshal(dAtA []byte) error
- type Hello
- func (*Hello) Descriptor() ([]byte, []int)
- func (this *Hello) Equal(that interface{}) bool
- func (m *Hello) GetComputeCapability() int64
- func (this *Hello) GoString() string
- func (m *Hello) Marshal() (dAtA []byte, err error)
- func (m *Hello) MarshalTo(dAtA []byte) (int, error)
- func (*Hello) ProtoMessage()
- func (m *Hello) Reset()
- func (m *Hello) Size() (n int)
- func (this *Hello) String() string
- func (m *Hello) Unmarshal(dAtA []byte) error
- type LookForCoordinator
- func (*LookForCoordinator) Descriptor() ([]byte, []int)
- func (this *LookForCoordinator) Equal(that interface{}) bool
- func (this *LookForCoordinator) GoString() string
- func (m *LookForCoordinator) Marshal() (dAtA []byte, err error)
- func (m *LookForCoordinator) MarshalTo(dAtA []byte) (int, error)
- func (*LookForCoordinator) ProtoMessage()
- func (m *LookForCoordinator) Reset()
- func (m *LookForCoordinator) Size() (n int)
- func (this *LookForCoordinator) String() string
- func (m *LookForCoordinator) Unmarshal(dAtA []byte) error
- type LostConnectionCoordinator
- func (*LostConnectionCoordinator) Descriptor() ([]byte, []int)
- func (this *LostConnectionCoordinator) Equal(that interface{}) bool
- func (m *LostConnectionCoordinator) GetCoordinator() *actor.PID
- func (this *LostConnectionCoordinator) GoString() string
- func (m *LostConnectionCoordinator) Marshal() (dAtA []byte, err error)
- func (m *LostConnectionCoordinator) MarshalTo(dAtA []byte) (int, error)
- func (*LostConnectionCoordinator) ProtoMessage()
- func (m *LostConnectionCoordinator) Reset()
- func (m *LostConnectionCoordinator) Size() (n int)
- func (this *LostConnectionCoordinator) String() string
- func (m *LostConnectionCoordinator) Unmarshal(dAtA []byte) error
- type NewNode
- func (*NewNode) Descriptor() ([]byte, []int)
- func (this *NewNode) Equal(that interface{}) bool
- func (m *NewNode) GetNewnode() *actor.PID
- func (this *NewNode) GoString() string
- func (m *NewNode) Marshal() (dAtA []byte, err error)
- func (m *NewNode) MarshalTo(dAtA []byte) (int, error)
- func (*NewNode) ProtoMessage()
- func (m *NewNode) Reset()
- func (m *NewNode) Size() (n int)
- func (this *NewNode) String() string
- func (m *NewNode) Unmarshal(dAtA []byte) error
- type NotAvailable
- func (*NotAvailable) Descriptor() ([]byte, []int)
- func (this *NotAvailable) Equal(that interface{}) bool
- func (this *NotAvailable) GoString() string
- func (m *NotAvailable) Marshal() (dAtA []byte, err error)
- func (m *NotAvailable) MarshalTo(dAtA []byte) (int, error)
- func (*NotAvailable) ProtoMessage()
- func (m *NotAvailable) Reset()
- func (m *NotAvailable) Size() (n int)
- func (this *NotAvailable) String() string
- func (m *NotAvailable) Unmarshal(dAtA []byte) error
- type NotFound
- func (*NotFound) Descriptor() ([]byte, []int)
- func (this *NotFound) Equal(that interface{}) bool
- func (m *NotFound) GetOperation() string
- func (this *NotFound) GoString() string
- func (m *NotFound) Marshal() (dAtA []byte, err error)
- func (m *NotFound) MarshalTo(dAtA []byte) (int, error)
- func (*NotFound) ProtoMessage()
- func (m *NotFound) Reset()
- func (m *NotFound) Size() (n int)
- func (this *NotFound) String() string
- func (m *NotFound) Unmarshal(dAtA []byte) error
- type Ping
- func (*Ping) Descriptor() ([]byte, []int)
- func (this *Ping) Equal(that interface{}) bool
- func (m *Ping) GetPing() int64
- func (this *Ping) GoString() string
- func (m *Ping) Marshal() (dAtA []byte, err error)
- func (m *Ping) MarshalTo(dAtA []byte) (int, error)
- func (*Ping) ProtoMessage()
- func (m *Ping) Reset()
- func (m *Ping) Size() (n int)
- func (this *Ping) String() string
- func (m *Ping) Unmarshal(dAtA []byte) error
- type Pong
- func (*Pong) Descriptor() ([]byte, []int)
- func (this *Pong) Equal(that interface{}) bool
- func (m *Pong) GetPong() int64
- func (this *Pong) GoString() string
- func (m *Pong) Marshal() (dAtA []byte, err error)
- func (m *Pong) MarshalTo(dAtA []byte) (int, error)
- func (*Pong) ProtoMessage()
- func (m *Pong) Reset()
- func (m *Pong) Size() (n int)
- func (this *Pong) String() string
- func (m *Pong) Unmarshal(dAtA []byte) error
- type Register
- func (*Register) Descriptor() ([]byte, []int)
- func (this *Register) Equal(that interface{}) bool
- func (m *Register) GetComputeCapability() int64
- func (this *Register) GoString() string
- func (m *Register) Marshal() (dAtA []byte, err error)
- func (m *Register) MarshalTo(dAtA []byte) (int, error)
- func (*Register) ProtoMessage()
- func (m *Register) Reset()
- func (m *Register) Size() (n int)
- func (this *Register) String() string
- func (m *Register) Unmarshal(dAtA []byte) error
- type RequestForCache
- func (*RequestForCache) Descriptor() ([]byte, []int)
- func (this *RequestForCache) Equal(that interface{}) bool
- func (m *RequestForCache) GetOperation() string
- func (m *RequestForCache) GetSender() *actor.PID
- func (this *RequestForCache) GoString() string
- func (m *RequestForCache) Marshal() (dAtA []byte, err error)
- func (m *RequestForCache) MarshalTo(dAtA []byte) (int, error)
- func (*RequestForCache) ProtoMessage()
- func (m *RequestForCache) Reset()
- func (m *RequestForCache) Size() (n int)
- func (this *RequestForCache) String() string
- func (m *RequestForCache) Unmarshal(dAtA []byte) error
- type RequestForCacheExternal
- func (*RequestForCacheExternal) Descriptor() ([]byte, []int)
- func (this *RequestForCacheExternal) Equal(that interface{}) bool
- func (m *RequestForCacheExternal) GetOperation() string
- func (m *RequestForCacheExternal) GetSender() *actor.PID
- func (this *RequestForCacheExternal) GoString() string
- func (m *RequestForCacheExternal) Marshal() (dAtA []byte, err error)
- func (m *RequestForCacheExternal) MarshalTo(dAtA []byte) (int, error)
- func (*RequestForCacheExternal) ProtoMessage()
- func (m *RequestForCacheExternal) Reset()
- func (m *RequestForCacheExternal) Size() (n int)
- func (this *RequestForCacheExternal) String() string
- func (m *RequestForCacheExternal) Unmarshal(dAtA []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (this *Response) Equal(that interface{}) bool
- func (m *Response) GetResult() string
- func (this *Response) GoString() string
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (this *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- type ResponseFromCache
- func (*ResponseFromCache) Descriptor() ([]byte, []int)
- func (this *ResponseFromCache) Equal(that interface{}) bool
- func (m *ResponseFromCache) GetResult() string
- func (this *ResponseFromCache) GoString() string
- func (m *ResponseFromCache) Marshal() (dAtA []byte, err error)
- func (m *ResponseFromCache) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseFromCache) ProtoMessage()
- func (m *ResponseFromCache) Reset()
- func (m *ResponseFromCache) Size() (n int)
- func (this *ResponseFromCache) String() string
- func (m *ResponseFromCache) Unmarshal(dAtA []byte) error
- type SearchInCache
- func (*SearchInCache) Descriptor() ([]byte, []int)
- func (this *SearchInCache) Equal(that interface{}) bool
- func (m *SearchInCache) GetFromPeer() *actor.PID
- func (m *SearchInCache) GetOperation() string
- func (this *SearchInCache) GoString() string
- func (m *SearchInCache) Marshal() (dAtA []byte, err error)
- func (m *SearchInCache) MarshalTo(dAtA []byte) (int, error)
- func (*SearchInCache) ProtoMessage()
- func (m *SearchInCache) Reset()
- func (m *SearchInCache) Size() (n int)
- func (this *SearchInCache) String() string
- func (m *SearchInCache) Unmarshal(dAtA []byte) error
- type Welcome
- func (*Welcome) Descriptor() ([]byte, []int)
- func (this *Welcome) Equal(that interface{}) bool
- func (m *Welcome) GetNodes() map[string]*actor.PID
- func (this *Welcome) GoString() string
- func (m *Welcome) Marshal() (dAtA []byte, err error)
- func (m *Welcome) MarshalTo(dAtA []byte) (int, error)
- func (*Welcome) ProtoMessage()
- func (m *Welcome) Reset()
- func (m *Welcome) Size() (n int)
- func (this *Welcome) String() string
- func (m *Welcome) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
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) 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) ProtoMessage ¶
func (*Available) ProtoMessage()
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) GetDeadNode ¶
func (*DeadNode) ProtoMessage ¶
func (*DeadNode) ProtoMessage()
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) ProtoMessage ¶
func (*GetPing) ProtoMessage()
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) GetComputeCapability ¶
func (*Hello) ProtoMessage ¶
func (*Hello) ProtoMessage()
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) GetNewnode ¶
func (*NewNode) ProtoMessage ¶
func (*NewNode) ProtoMessage()
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) 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) GetOperation ¶
func (*NotFound) ProtoMessage ¶
func (*NotFound) ProtoMessage()
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) ProtoMessage ¶
func (*Ping) ProtoMessage()
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) ProtoMessage ¶
func (*Pong) ProtoMessage()
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) GetComputeCapability ¶
func (*Register) ProtoMessage ¶
func (*Register) ProtoMessage()
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) 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) ProtoMessage ¶
func (*Response) ProtoMessage()
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) 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 ¶
Message to new node from coordinator containing the peer list
func (*Welcome) Descriptor ¶
func (*Welcome) ProtoMessage ¶
func (*Welcome) ProtoMessage()