org.graylog2.streams

Class StreamImpl

java.lang.Object

org.graylog2.database.PersistedImpl

org.graylog2.streams.StreamImpl

All Implemented Interfaces:

Persisted, Stream

public class StreamImpl
extends PersistedImpl
implements Stream

Representing a single stream from the streams collection. Also provides method to get all streams of this collection.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	EMBEDDED_ALERT_CONDITIONS
static java.lang.String	FIELD_ALERT_RECEIVERS
static java.lang.String	FIELD_CONTENT_PACK
static java.lang.String	FIELD_CREATED_AT
static java.lang.String	FIELD_CREATOR_USER_ID
static java.lang.String	FIELD_DESCRIPTION
static java.lang.String	FIELD_DISABLED
static java.lang.String	FIELD_OUTPUTS
static java.lang.String	FIELD_RULES
static java.lang.String	FIELD_TITLE

Fields inherited from class org.graylog2.database.PersistedImpl

fields, id

Constructor Summary

Constructors

Modifier	Constructor and Description
	StreamImpl(java.util.Map<java.lang.String,java.lang.Object> fields)
protected	StreamImpl(org.bson.types.ObjectId id, java.util.Map<java.lang.String,java.lang.Object> fields)
	StreamImpl(org.bson.types.ObjectId id, java.util.Map<java.lang.String,java.lang.Object> fields, java.util.List<StreamRule> streamRules, java.util.Set<Output> outputs)

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.Object>	asMap()
java.util.Map<java.lang.String,java.lang.Object>	asMap(java.util.List<StreamRule> streamRules)
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getAlertReceivers()
java.lang.String	getContentPack()
java.lang.String	getDescription()
java.lang.Boolean	getDisabled()
java.util.Map<java.lang.String,Validator>	getEmbeddedValidations(java.lang.String key)
java.util.Set<Output>	getOutputs()
java.util.List<StreamRule>	getStreamRules()
java.lang.String	getTitle()
java.util.Map<java.lang.String,Validator>	getValidations()
java.lang.Boolean	isPaused()
void	setContentPack(java.lang.String contentPack)
void	setDescription(java.lang.String description)
void	setDisabled(java.lang.Boolean disabled)
void	setTitle(java.lang.String title)
java.lang.String	toString()

Methods inherited from class org.graylog2.database.PersistedImpl

equals, getFields, getId, getObjectId, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.graylog2.plugin.streams.Stream

getId

Methods inherited from interface org.graylog2.plugin.database.Persisted

getFields

Field Detail

FIELD_TITLE

public static final java.lang.String FIELD_TITLE

See Also:

Constant Field Values

FIELD_DESCRIPTION

public static final java.lang.String FIELD_DESCRIPTION

See Also:

Constant Field Values

FIELD_RULES

public static final java.lang.String FIELD_RULES

See Also:

Constant Field Values

FIELD_OUTPUTS

public static final java.lang.String FIELD_OUTPUTS

See Also:

Constant Field Values

FIELD_CONTENT_PACK

public static final java.lang.String FIELD_CONTENT_PACK

See Also:

Constant Field Values

FIELD_ALERT_RECEIVERS

public static final java.lang.String FIELD_ALERT_RECEIVERS

See Also:

Constant Field Values

FIELD_DISABLED

public static final java.lang.String FIELD_DISABLED

See Also:

Constant Field Values

FIELD_CREATED_AT

public static final java.lang.String FIELD_CREATED_AT

See Also:

Constant Field Values

FIELD_CREATOR_USER_ID

public static final java.lang.String FIELD_CREATOR_USER_ID

See Also:

Constant Field Values

EMBEDDED_ALERT_CONDITIONS

public static final java.lang.String EMBEDDED_ALERT_CONDITIONS

See Also:

Constant Field Values

Constructor Detail

StreamImpl

public StreamImpl(java.util.Map<java.lang.String,java.lang.Object> fields)

StreamImpl

protected StreamImpl(org.bson.types.ObjectId id,
                     java.util.Map<java.lang.String,java.lang.Object> fields)

StreamImpl

public StreamImpl(org.bson.types.ObjectId id,
                  java.util.Map<java.lang.String,java.lang.Object> fields,
                  java.util.List<StreamRule> streamRules,
                  java.util.Set<Output> outputs)

Method Detail

toString

public java.lang.String toString()

Specified by:

toString in interface Stream

Overrides:

toString in class PersistedImpl

getStreamRules

public java.util.List<StreamRule> getStreamRules()

Specified by:

getStreamRules in interface Stream

getOutputs

public java.util.Set<Output> getOutputs()

Specified by:

getOutputs in interface Stream

getTitle

public java.lang.String getTitle()

Specified by:

getTitle in interface Stream

getDescription

public java.lang.String getDescription()

Specified by:

getDescription in interface Stream

setTitle

public void setTitle(java.lang.String title)

Specified by:

setTitle in interface Stream

setDescription

public void setDescription(java.lang.String description)

Specified by:

setDescription in interface Stream

getDisabled

public java.lang.Boolean getDisabled()

Specified by:

getDisabled in interface Stream

setDisabled

public void setDisabled(java.lang.Boolean disabled)

Specified by:

setDisabled in interface Stream

getContentPack

public java.lang.String getContentPack()

Specified by:

getContentPack in interface Stream

setContentPack

public void setContentPack(java.lang.String contentPack)

Specified by:

setContentPack in interface Stream

isPaused

public java.lang.Boolean isPaused()

Specified by:

isPaused in interface Stream

asMap

public java.util.Map<java.lang.String,java.lang.Object> asMap(java.util.List<StreamRule> streamRules)

Specified by:

asMap in interface Stream

asMap

public java.util.Map<java.lang.String,java.lang.Object> asMap()

Specified by:

asMap in interface Persisted

Overrides:

asMap in class PersistedImpl

getValidations

public java.util.Map<java.lang.String,Validator> getValidations()

Specified by:

getValidations in interface Persisted

getEmbeddedValidations

public java.util.Map<java.lang.String,Validator> getEmbeddedValidations(java.lang.String key)

Specified by:

getEmbeddedValidations in interface Persisted

getAlertReceivers

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getAlertReceivers()

Specified by:

getAlertReceivers in interface Stream