org.graylog2.collectors

Class CollectorServiceImpl

java.lang.Object

org.graylog2.collectors.CollectorServiceImpl

All Implemented Interfaces:

CollectorService

public class CollectorServiceImpl
extends Object
implements CollectorService

Constructor Summary

Constructors

Constructor and Description
CollectorServiceImpl(MongoConnection mongoConnection, MongoJackObjectMapperProvider mapperProvider, javax.validation.Validator validator)

Method Summary

Methods

Modifier and Type	Method and Description
List<Collector>	all()
long	count()
int	destroy(Collector collector)
int	destroyExpired(int time, TimeUnit unit)
Collector	findById(String id)
List<Collector>	findByNodeId(String nodeId)
Collector	fromRequest(String collectorId, CollectorRegistrationRequest request, String collectorVersion)
Collector	save(Collector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectorServiceImpl

@Inject
public CollectorServiceImpl(MongoConnection mongoConnection,
                           MongoJackObjectMapperProvider mapperProvider,
                           javax.validation.Validator validator)

Method Detail

count

public long count()

Specified by:

count in interface CollectorService

save

public Collector save(Collector collector)

Specified by:

save in interface CollectorService

all

public List<Collector> all()

Specified by:

all in interface CollectorService

findById

public Collector findById(String id)

Specified by:

findById in interface CollectorService

findByNodeId

public List<Collector> findByNodeId(String nodeId)

Specified by:

findByNodeId in interface CollectorService

destroy

public int destroy(Collector collector)

Specified by:

destroy in interface CollectorService

destroyExpired

public int destroyExpired(int time,
                 TimeUnit unit)

Specified by:

destroyExpired in interface CollectorService

fromRequest

public Collector fromRequest(String collectorId,
                    CollectorRegistrationRequest request,
                    String collectorVersion)

Specified by:

fromRequest in interface CollectorService