scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

export NodeEvent

Browse source
This commit is contained in:
Matt Jaffee 2018-07-05 09:26:58 -05:00
parent d2ec463b4e
commit 1b2aaa26bf
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
5 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
broadcast.go
View file

@ -148,7 +148,7 @@ func encode(m Message) proto.Message {
return encodeNodeStateMessage(mt)
case *RecalculateCaches:
return encodeRecalculateCaches(mt)
case *nodeEvent:
case *NodeEvent:
return encodeNodeEventMessage(mt)
case *NodeStatus:
return encodeNodeStatus(mt)

14
cluster.go
View file

@ -856,7 +856,7 @@ func (c *cluster) waitForStarted() error {
// TODO: Because the normal code path already sends a NodeJoin event (via
// memberlist), this it a bit redundant in most cases. Perhaps determine
// that the node has been restarted and don't do this step.
msg := &nodeEvent{
msg := &NodeEvent{
Event: NodeJoin,
Node: c.Node,
}
@ -1540,7 +1540,7 @@ func (c *cluster) considerTopology() error {
}
// ReceiveEvent represents an implementation of EventHandler.
func (c *cluster) ReceiveEvent(e *nodeEvent) error {
func (c *cluster) ReceiveEvent(e *NodeEvent) error {
// Ignore events sent from this node.
if e.Node.ID == c.Node.ID {
return nil
@ -1966,8 +1966,8 @@ func DecodeNode(node *internal.Node) *Node {
}
}
func DecodeNodeEvent(ne *internal.NodeEventMessage) *nodeEvent {
return &nodeEvent{
func DecodeNodeEvent(ne *internal.NodeEventMessage) *NodeEvent {
return &NodeEvent{
Event: NodeEventType(ne.Event),
Node: DecodeNode(ne.Node),
}
@ -2223,15 +2223,15 @@ func decodeNodeStateMessage(pb *internal.NodeStateMessage) *NodeStateMessage {
}
}
func encodeNodeEventMessage(m *nodeEvent) *internal.NodeEventMessage {
func encodeNodeEventMessage(m *NodeEvent) *internal.NodeEventMessage {
return &internal.NodeEventMessage{
Event: uint32(m.Event),
Node: EncodeNode(m.Node),
}
}
func decodeNodeEventMessage(pb *internal.NodeEventMessage) *nodeEvent {
return &nodeEvent{
func decodeNodeEventMessage(pb *internal.NodeEventMessage) *NodeEvent {
return &NodeEvent{
Event: NodeEventType(pb.Event),
Node: DecodeNode(pb.Node),
}

4
event.go
View file

@ -23,8 +23,8 @@ const (
NodeUpdate
)
// nodeEvent is a single event related to node activity in the cluster.
type nodeEvent struct {
// NodeEvent is a single event related to node activity in the cluster.
type NodeEvent struct {
Event NodeEventType
Node *Node
}

2
server.go
View file

@ -506,7 +506,7 @@ func (s *Server) receiveMessage(m Message) error {
}
case *RecalculateCaches:
s.holder.RecalculateCaches()
case *nodeEvent:
case *NodeEvent:
s.cluster.ReceiveEvent(obj)
case *NodeStatus:
s.handleRemoteStatus(obj)

2
utils_internal_test.go
View file

@ -161,7 +161,7 @@ func (t *ClusterCluster) addNode() error {
// Send NodeJoin event to coordinator.
if id > 0 {
coord := t.Clusters[0]
ev := &nodeEvent{
ev := &NodeEvent{
Event: NodeJoin,
Node: c.Node,
}