Skip to content
This repository was archived by the owner on Mar 21, 2023. It is now read-only.

Commit adf53e2

Browse files
committed
add missing bindings for syslog functinos and concat
(cherry picked from commit 20a5f05)
1 parent 4fcaf8d commit adf53e2

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

src/main/java/org/graylog/plugins/pipelineprocessor/functions/ProcessorFunctionsModule.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import org.graylog.plugins.pipelineprocessor.functions.messages.SetFields;
5050
import org.graylog.plugins.pipelineprocessor.functions.strings.Abbreviate;
5151
import org.graylog.plugins.pipelineprocessor.functions.strings.Capitalize;
52+
import org.graylog.plugins.pipelineprocessor.functions.strings.Concat;
5253
import org.graylog.plugins.pipelineprocessor.functions.strings.Contains;
5354
import org.graylog.plugins.pipelineprocessor.functions.strings.GrokMatch;
5455
import org.graylog.plugins.pipelineprocessor.functions.strings.Lowercase;
@@ -57,6 +58,10 @@
5758
import org.graylog.plugins.pipelineprocessor.functions.strings.Swapcase;
5859
import org.graylog.plugins.pipelineprocessor.functions.strings.Uncapitalize;
5960
import org.graylog.plugins.pipelineprocessor.functions.strings.Uppercase;
61+
import org.graylog.plugins.pipelineprocessor.functions.syslog.SyslogFacilityConversion;
62+
import org.graylog.plugins.pipelineprocessor.functions.syslog.SyslogLevelConversion;
63+
import org.graylog.plugins.pipelineprocessor.functions.syslog.SyslogPriorityConversion;
64+
import org.graylog.plugins.pipelineprocessor.functions.syslog.SyslogPriorityToStringConversion;
6065
import org.graylog.plugins.pipelineprocessor.functions.urls.UrlConversion;
6166
import org.graylog2.plugin.PluginModule;
6267

@@ -95,6 +100,7 @@ protected void configure() {
95100
addMessageProcessorFunction(Swapcase.NAME, Swapcase.class);
96101
addMessageProcessorFunction(Uncapitalize.NAME, Uncapitalize.class);
97102
addMessageProcessorFunction(Uppercase.NAME, Uppercase.class);
103+
addMessageProcessorFunction(Concat.NAME, Concat.class);
98104

99105
// json
100106
addMessageProcessorFunction(JsonParse.NAME, JsonParse.class);
@@ -126,6 +132,12 @@ protected void configure() {
126132

127133
// URL parsing
128134
addMessageProcessorFunction(UrlConversion.NAME, UrlConversion.class);
135+
136+
// Syslog support
137+
addMessageProcessorFunction(SyslogFacilityConversion.NAME, SyslogFacilityConversion.class);
138+
addMessageProcessorFunction(SyslogLevelConversion.NAME, SyslogLevelConversion.class);
139+
addMessageProcessorFunction(SyslogPriorityConversion.NAME, SyslogPriorityConversion.class);
140+
addMessageProcessorFunction(SyslogPriorityToStringConversion.NAME, SyslogPriorityToStringConversion.class);
129141
}
130142

131143
protected void addMessageProcessorFunction(String name, Class<? extends Function<?>> functionClass) {

0 commit comments

Comments
 (0)