org.corfudb.protocols.wireprotocol

Class NodeState

java.lang.Object

org.corfudb.protocols.wireprotocol.NodeState

All Implemented Interfaces:

ICorfuPayload<NodeState>

public class NodeState
extends Object
implements ICorfuPayload<NodeState>

Contains a Node's state: Sequencer state - ready/not_ready. connectivity status - Node's connectivity with every other node in the layout.

For instance, node a fully connected to all nodes: {"a": {"endpoint": "a", "connectivity":{"a": true, "b": true, "c": true}}}

Created by zlokhandwala on 11/2/18.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodeState.HeartbeatTimestamp Heartbeat timestamp is a tuple of the heartbeat counter and the epoch.

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

ICorfuPayload.PayloadConstructor<T>

Field Summary

Fields

Modifier and Type	Field and Description
static long	INVALID_HEARTBEAT_COUNTER

Fields inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

constructorMap, lookup

Constructor Summary

Constructors

Constructor and Description
NodeState(io.netty.buffer.ByteBuf buf)

Method Summary

Modifier and Type	Method and Description
void	doSerialize(io.netty.buffer.ByteBuf buf)
static NodeState	getNotReadyNodeState(String endpoint, long epoch, long counter)
static NodeState	getUnavailableNodeState(String endpoint)
boolean	isConnected()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

enumMapFromBuffer, fromBuffer, fromBuffer, listFromBuffer, mapFromBuffer, rangeFromBuffer, rangeSetFromBuffer, serialize, setFromBuffer

Field Detail

INVALID_HEARTBEAT_COUNTER

public static final long INVALID_HEARTBEAT_COUNTER

See Also:

Constant Field Values

Constructor Detail

NodeState

public NodeState(io.netty.buffer.ByteBuf buf)

Method Detail

doSerialize

public void doSerialize(io.netty.buffer.ByteBuf buf)

Specified by:

doSerialize in interface ICorfuPayload<NodeState>

getUnavailableNodeState

public static NodeState getUnavailableNodeState(String endpoint)

getNotReadyNodeState

public static NodeState getNotReadyNodeState(String endpoint,
                                             long epoch,
                                             long counter)

isConnected

public boolean isConnected()