Package org.graylog2.cluster.nodes

Class AbstractNodeService<T extends AbstractNode<? extends NodeDto>,DTO extends NodeDto>

java.lang.Object

org.graylog2.database.PersistedServiceImpl

org.graylog2.cluster.nodes.AbstractNodeService<T,DTO>

All Implemented Interfaces:

NodeService<DTO>, PersistedService

Direct Known Subclasses:

DataNodeClusterService, ServerNodeClusterService

public abstract class AbstractNodeService<T extends AbstractNode<? extends NodeDto>,DTO extends NodeDto>
extends PersistedServiceImpl
implements NodeService<DTO>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LAST_SEEN_FIELD

Fields inherited from class org.graylog2.database.PersistedServiceImpl

mongoConnection

Constructor Summary

Constructors

Constructor	Description
AbstractNodeService(MongoConnection mongoConnection, Configuration configuration, Class<T> nodeClass)

Method Summary

Modifier and Type	Method	Description
Map<String,DTO>	allActive()
DTO	byNodeId(String nodeId)
DTO	byNodeId(NodeId nodeId)
Map<String,DTO>	byNodeIds(Collection<String> nodeIds)
protected T	construct(org.bson.types.ObjectId id, Map map)
void	dropOutdated()
boolean	isAnyLeaderPresent()
boolean	isOnlyLeader(NodeId nodeId)
void	markAsAlive(NodeDto dto)	Mark this node as alive and probably update some settings that may have changed since last server boot.
void	ping(NodeDto dto)	Sets the last seen date of the node, additionally updating the settings.
boolean	registerServer(NodeDto dto)
void	update(NodeDto dto)

Methods inherited from class org.graylog2.database.PersistedServiceImpl

collection, collection, collectionName, count, count, cursorToList, destroy, destroy, destroyAll, destroyAll, destroyAll, embed, fieldTransformations, findOne, findOne, findOne, findOne, get, get, get, mongoCollection, query, query, query, query, query, removeEmbedded, removeEmbedded, save, saveWithoutValidation, totalCount, totalCount, validate, validate, validate

Methods inherited from class java.lang.Object

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

Field Details

LAST_SEEN_FIELD

public static final String LAST_SEEN_FIELD

See Also:

• Constant Field Values

Constructor Details

AbstractNodeService

@Inject
public AbstractNodeService(MongoConnection mongoConnection,
 Configuration configuration,
 Class<T> nodeClass)

Method Details

registerServer

public boolean registerServer(NodeDto dto)

Specified by:

registerServer in interface NodeService<T extends AbstractNode<? extends NodeDto>>

byNodeId

public DTO byNodeId(String nodeId)
             throws NodeNotFoundException

Specified by:

byNodeId in interface NodeService<T extends AbstractNode<? extends NodeDto>>

Throws:

NodeNotFoundException

construct

protected T construct(org.bson.types.ObjectId id,
 Map map)

byNodeId

public DTO byNodeId(NodeId nodeId)
             throws NodeNotFoundException

Specified by:

byNodeId in interface NodeService<T extends AbstractNode<? extends NodeDto>>

Throws:

NodeNotFoundException

byNodeIds

public Map<String,DTO> byNodeIds(Collection<String> nodeIds)

Specified by:

byNodeIds in interface NodeService<T extends AbstractNode<? extends NodeDto>>

allActive

public Map<String,DTO> allActive()

Specified by:

allActive in interface NodeService<T extends AbstractNode<? extends NodeDto>>

dropOutdated

public void dropOutdated()

Specified by:

dropOutdated in interface NodeService<T extends AbstractNode<? extends NodeDto>>

markAsAlive

public void markAsAlive(NodeDto dto)
                 throws NodeNotFoundException

Mark this node as alive and probably update some settings that may have changed since last server boot.

Specified by:

markAsAlive in interface NodeService<T extends AbstractNode<? extends NodeDto>>

Throws:

NodeNotFoundException

isOnlyLeader

public boolean isOnlyLeader(NodeId nodeId)

Specified by:

isOnlyLeader in interface NodeService<T extends AbstractNode<? extends NodeDto>>

isAnyLeaderPresent

public boolean isAnyLeaderPresent()

Specified by:

isAnyLeaderPresent in interface NodeService<T extends AbstractNode<? extends NodeDto>>

ping

public void ping(NodeDto dto)

Description copied from interface: NodeService

Sets the last seen date of the node, additionally updating the settings. If the node hasn't been registered yet, it will be registered.

Specified by:

ping in interface NodeService<T extends AbstractNode<? extends NodeDto>>

Parameters:

dto - Dto of the node to be marked as alive

update

public void update(NodeDto dto)

Specified by:

update in interface NodeService<T extends AbstractNode<? extends NodeDto>>