org.graylog2.plugin

Class ServerStatus

java.lang.Object

org.graylog2.plugin.ServerStatus

@Singleton
public class ServerStatus
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ServerStatus.Capability
static class	ServerStatus.MessageDetailRecordingStrategy

Constructor Summary

Constructors

Constructor and Description
ServerStatus(BaseConfiguration configuration, Set<ServerStatus.Capability> capabilities, com.google.common.eventbus.EventBus eventBus)

Method Summary

Modifier and Type	Method and Description
ServerStatus	addCapabilities(ServerStatus.Capability... capabilities)
ServerStatus	addCapability(ServerStatus.Capability capability)
void	awaitRunning(Runnable runnable)
void	fail()
ServerStatus.MessageDetailRecordingStrategy	getDetailedMessageRecordingStrategy()
Lifecycle	getLifecycle()
NodeId	getNodeId()
org.joda.time.DateTime	getStartedAt()
org.joda.time.DateTimeZone	getTimezone()
boolean	hasCapabilities(ServerStatus.Capability... capabilities)
boolean	hasCapability(ServerStatus.Capability capability)
void	initialize()
boolean	isProcessing()
void	overrideLoadBalancerAlive()
void	overrideLoadBalancerDead()
void	pauseMessageProcessing()
void	pauseMessageProcessing(boolean locked)
boolean	processingPauseLocked()
void	resumeMessageProcessing()
void	setLocalMode(boolean localMode)
void	shutdown()
void	shutdown(boolean forceProcessing)
void	start()
void	unlockProcessingPause()

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerStatus

@Inject
public ServerStatus(BaseConfiguration configuration,
                            Set<ServerStatus.Capability> capabilities,
                            com.google.common.eventbus.EventBus eventBus)

Method Detail

getDetailedMessageRecordingStrategy

public ServerStatus.MessageDetailRecordingStrategy getDetailedMessageRecordingStrategy()

getNodeId

public NodeId getNodeId()

getLifecycle

public Lifecycle getLifecycle()

initialize

public void initialize()

start

public void start()

shutdown

public void shutdown(boolean forceProcessing)

shutdown

public void shutdown()

fail

public void fail()

overrideLoadBalancerDead

public void overrideLoadBalancerDead()

overrideLoadBalancerAlive

public void overrideLoadBalancerAlive()

awaitRunning

public void awaitRunning(Runnable runnable)

getStartedAt

public org.joda.time.DateTime getStartedAt()

getTimezone

public org.joda.time.DateTimeZone getTimezone()

addCapability

public ServerStatus addCapability(ServerStatus.Capability capability)

addCapabilities

public ServerStatus addCapabilities(ServerStatus.Capability... capabilities)

hasCapability

public boolean hasCapability(ServerStatus.Capability capability)

hasCapabilities

public boolean hasCapabilities(ServerStatus.Capability... capabilities)

isProcessing

public boolean isProcessing()

pauseMessageProcessing

public void pauseMessageProcessing()

pauseMessageProcessing

public void pauseMessageProcessing(boolean locked)

resumeMessageProcessing

public void resumeMessageProcessing()
                             throws ProcessingPauseLockedException

Throws:

ProcessingPauseLockedException

processingPauseLocked

public boolean processingPauseLocked()

unlockProcessingPause

public void unlockProcessingPause()

setLocalMode

public void setLocalMode(boolean localMode)