org.graylog2.streams

Class OutputServiceImpl

java.lang.Object

org.graylog2.database.PersistedServiceImpl

org.graylog2.streams.OutputServiceImpl

All Implemented Interfaces:

PersistedService, OutputService

public class OutputServiceImpl
extends PersistedServiceImpl
implements OutputService

Field Summary

Fields inherited from class org.graylog2.database.PersistedServiceImpl

mongoConnection

Constructor Summary

Constructors

Constructor and Description
OutputServiceImpl(MongoConnection mongoConnection, StreamService streamService, OutputRegistry outputRegistry)

Method Summary

Methods

Modifier and Type	Method and Description
long	count()
Map<String,Long>	countByType()
Output	create(CreateOutputRequest request, String userId)
Output	create(Output request)
void	destroy(Output output)
Output	load(String streamOutputId)
Set<Output>	loadAll()
protected Set<Output>	loadAll(Map<String,Object> additionalQueryOpts)
Output	update(String id, Map<String,Object> deltas)

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

Constructor Detail

OutputServiceImpl

@Inject
public OutputServiceImpl(MongoConnection mongoConnection,
                        StreamService streamService,
                        OutputRegistry outputRegistry)

Method Detail

load

public Output load(String streamOutputId)
            throws NotFoundException

Specified by:

load in interface OutputService

Throws:

NotFoundException

loadAll

public Set<Output> loadAll()

Specified by:

loadAll in interface OutputService

loadAll

protected Set<Output> loadAll(Map<String,Object> additionalQueryOpts)

create

public Output create(Output request)
              throws ValidationException

Specified by:

create in interface OutputService

Throws:

ValidationException

create

public Output create(CreateOutputRequest request,
            String userId)
              throws ValidationException

Specified by:

create in interface OutputService

Throws:

ValidationException

destroy

public void destroy(Output output)
             throws NotFoundException

Specified by:

destroy in interface OutputService

Throws:

NotFoundException

update

public Output update(String id,
            Map<String,Object> deltas)

Specified by:

update in interface OutputService

count

public long count()

Specified by:

count in interface OutputService

Returns:

the total number of outputs

countByType

public Map<String,Long> countByType()

Specified by:

countByType in interface OutputService

Returns:

the total number of outputs grouped by type