I’m trying to create a pipeline processor function that I can use to lookup a value from another stream and use that value to enrich the current message with a new field.
The project is located here and will compile and load in 2.1.3 as of this writing.
I am stuck at the point where I conduct the search which would provide the SearchResult. It appears I am not properly instantiating org.graylog2.indexer.searches.Searches to use the search method and I am not quite sure how to do so.
For something like Configuration and Client, how do I specify or obtain the current configuration and client that is being utilized. Also, for IndexRangeService I am wanting to start off with a relative value, how do I do the conversion to get the right range.
public Searches(Configuration configuration, Deflector deflector, IndexRangeService indexRangeService, Client client, MetricRegistry metricRegistry)
Maybe I’m overlooking something or over-complicating things.
Any help you can provide is appreciated. Thanks in advance.