org.graylog2.inputs

Class InputServiceImpl

java.lang.Object

org.graylog2.database.PersistedServiceImpl

org.graylog2.inputs.InputServiceImpl

All Implemented Interfaces:

PersistedService, InputService

public class InputServiceImpl
extends PersistedServiceImpl
implements InputService

Field Summary

Fields inherited from class org.graylog2.database.PersistedServiceImpl

mongoConnection

Constructor Summary

Constructors

Constructor and Description
InputServiceImpl(MongoConnection mongoConnection, ExtractorFactory extractorFactory, MessageInputFactory messageInputFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	addExtractor(Input input, Extractor extractor)
void	addStaticField(Input input, String key, String value)
List<Input>	allOfRadio(Node radio)
List<Input>	allOfThisNode(String nodeId)
MessageInput	buildMessageInput(Input io)
Input	find(String id)
Input	findForThisNode(String nodeId, String id)
Input	findForThisNodeOrGlobal(String nodeId, String id)
Input	findForThisRadio(String radioId, String id)
Input	findForThisRadioOrGlobal(String radioId, String id)
List<Extractor>	getExtractors(Input input)
MessageInput	getMessageInput(Input io)
void	removeExtractor(Input input, String extractorId)
void	removeStaticField(Input input, String key)

Methods inherited from class org.graylog2.database.PersistedServiceImpl

collection, collection, count, count, cursorToList, destroy, destroy, destroyAll, destroyAll, destroyAll, embed, findOne, findOne, findOne, findOne, get, get, get, 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

Methods inherited from interface org.graylog2.database.PersistedService

destroy, destroyAll, save, saveWithoutValidation, validate, validate, validate

Constructor Detail

InputServiceImpl

@Inject
public InputServiceImpl(MongoConnection mongoConnection,
                       ExtractorFactory extractorFactory,
                       MessageInputFactory messageInputFactory)

Method Detail

allOfThisNode

public List<Input> allOfThisNode(String nodeId)

Specified by:

allOfThisNode in interface InputService

allOfRadio

public List<Input> allOfRadio(Node radio)

Specified by:

allOfRadio in interface InputService

find

public Input find(String id)

Specified by:

find in interface InputService

findForThisNodeOrGlobal

public Input findForThisNodeOrGlobal(String nodeId,
                            String id)
                              throws NotFoundException

Specified by:

findForThisNodeOrGlobal in interface InputService

Throws:

NotFoundException

findForThisRadioOrGlobal

public Input findForThisRadioOrGlobal(String radioId,
                             String id)
                               throws NotFoundException

Specified by:

findForThisRadioOrGlobal in interface InputService

Throws:

NotFoundException

findForThisNode

public Input findForThisNode(String nodeId,
                    String id)
                      throws NotFoundException,
                             IllegalArgumentException

Specified by:

findForThisNode in interface InputService

Throws:

NotFoundException

IllegalArgumentException

findForThisRadio

public Input findForThisRadio(String radioId,
                     String id)
                       throws NotFoundException

Specified by:

findForThisRadio in interface InputService

Throws:

NotFoundException

addExtractor

public void addExtractor(Input input,
                Extractor extractor)
                  throws ValidationException

Specified by:

addExtractor in interface InputService

Throws:

ValidationException

addStaticField

public void addStaticField(Input input,
                  String key,
                  String value)
                    throws ValidationException

Specified by:

addStaticField in interface InputService

Throws:

ValidationException

getExtractors

public List<Extractor> getExtractors(Input input)

Specified by:

getExtractors in interface InputService

removeExtractor

public void removeExtractor(Input input,
                   String extractorId)

Specified by:

removeExtractor in interface InputService

removeStaticField

public void removeStaticField(Input input,
                     String key)

Specified by:

removeStaticField in interface InputService

buildMessageInput

public MessageInput buildMessageInput(Input io)
                               throws NoSuchInputTypeException

Specified by:

buildMessageInput in interface InputService

Throws:

NoSuchInputTypeException

getMessageInput

public MessageInput getMessageInput(Input io)
                             throws NoSuchInputTypeException

Specified by:

getMessageInput in interface InputService

Throws:

NoSuchInputTypeException