org.graylog2.indexer.fieldtypes

Class IndexFieldTypesService

java.lang.Object

org.graylog2.indexer.fieldtypes.IndexFieldTypesService

public class IndexFieldTypesService
extends Object

Manages the "index_field_Types" MongoDB collection.

Constructor Summary

Constructors

Constructor and Description
IndexFieldTypesService(MongoConnection mongoConnection, MongoJackObjectMapperProvider objectMapperProvider)

Method Summary

Modifier and Type	Method and Description
void	delete(String idOrIndexName)
Optional<IndexFieldTypesDTO>	get(String idOrIndexName)
IndexFieldTypesDTO	save(IndexFieldTypesDTO dto)
Stream<IndexFieldTypesDTO>	streamAll()
Stream<IndexFieldTypesDTO>	streamForFieldNames(Collection<String> fieldNames)
Stream<IndexFieldTypesDTO>	streamForFieldNamesAndIndices(Collection<String> fieldNames, Collection<String> indexNames)
Stream<IndexFieldTypesDTO>	streamForIndexSet(String indexSetId)
Optional<IndexFieldTypesDTO>	upsert(IndexFieldTypesDTO dto)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexFieldTypesService

@Inject
public IndexFieldTypesService(MongoConnection mongoConnection,
                                      MongoJackObjectMapperProvider objectMapperProvider)

Method Detail

get

public Optional<IndexFieldTypesDTO> get(String idOrIndexName)

save

public IndexFieldTypesDTO save(IndexFieldTypesDTO dto)

upsert

public Optional<IndexFieldTypesDTO> upsert(IndexFieldTypesDTO dto)

delete

public void delete(String idOrIndexName)

streamForIndexSet

public Stream<IndexFieldTypesDTO> streamForIndexSet(String indexSetId)

streamForFieldNames

public Stream<IndexFieldTypesDTO> streamForFieldNames(Collection<String> fieldNames)

streamForFieldNamesAndIndices

public Stream<IndexFieldTypesDTO> streamForFieldNamesAndIndices(Collection<String> fieldNames,
                                                                Collection<String> indexNames)

streamAll

public Stream<IndexFieldTypesDTO> streamAll()