Class NodeDescriptor

java.lang.Object

services.moleculer.transporter.tcp.NodeDescriptor

public class NodeDescriptor
extends Object

Node descriptor of all (remote and local) nodes.

Field Summary

Fields

Modifier and Type	Field	Description
int	cpu
long	cpuSeq
long	cpuWhen
String	host
io.datatree.Tree	info
final boolean	local
final String	nodeID
long	offlineSince
int	port
protected final boolean	preferHostname
final Lock	readLock
long	seq
final Lock	writeLock

Constructor Summary

Constructors

Constructor	Description
NodeDescriptor(String nodeID, boolean preferHostname, boolean local)
NodeDescriptor(String nodeID, boolean preferHostname, boolean local, io.datatree.Tree info)
NodeDescriptor(String nodeID, boolean preferHostname, String host, int port)

Method Summary

Modifier and Type	Method	Description
boolean	markAsOffline()
boolean	markAsOffline(long seq)
boolean	markAsOnline(io.datatree.Tree info)
void	updateCpu(int cpu)
void	updateCpu(long cpuSeq, int cpu)

Methods inherited from class Object

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

Field Details

nodeID

public final String nodeID

local

public final boolean local

preferHostname

protected final boolean preferHostname

host

public volatile String host

port

public volatile int port

info

public volatile io.datatree.Tree info

seq

public volatile long seq

offlineSince

public volatile long offlineSince

cpu

public volatile int cpu

cpuSeq

public volatile long cpuSeq

cpuWhen

public volatile long cpuWhen

readLock

public final Lock readLock

writeLock

public final Lock writeLock

Constructor Details

NodeDescriptor

public NodeDescriptor(String nodeID,
 boolean preferHostname,
 boolean local)

NodeDescriptor

public NodeDescriptor(String nodeID,
 boolean preferHostname,
 String host,
 int port)

NodeDescriptor

public NodeDescriptor(String nodeID,
 boolean preferHostname,
 boolean local,
 io.datatree.Tree info)

Method Details

updateCpu

public void updateCpu(int cpu)

updateCpu

public void updateCpu(long cpuSeq,
 int cpu)

markAsOffline

public boolean markAsOffline()

markAsOffline

public boolean markAsOffline(long seq)

markAsOnline

public boolean markAsOnline(io.datatree.Tree info)