yo/graylog-plugin-redis-lookup
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 6 Wiki Activity

Compare commits

base: yo:9f068b84787c5fb36347e4e6daac3726f267e639
Branches Tags
yo:main yo:streams
yo:v1.0.4-g6.1 yo:v1.0.4 yo:v1.0.3 yo:v1.0.2 yo:v1.0.1 yo:v1.0.0
..
compare: yo:main
Branches Tags
yo:main yo:streams
yo:v1.0.4-g6.1 yo:v1.0.4 yo:v1.0.3 yo:v1.0.2 yo:v1.0.1 yo:v1.0.0

11 Commits
9f068b8478 ... main

Author SHA1 Message Date
yo000
3c23663521 Update dependencies 2025-02-09 18:42:11 +01:00
yo000
a935b53b15 update to graylog 6.1.0, disable license check, use node & yarn versions from graylog2-server parent pom 2025-02-09 18:42:01 +01:00
yo000
5dcd438e73 Comment on usage of name 2025-02-09 18:41:57 +01:00
yo000
601e0730a2 update pom to v1.0.4 2025-02-08 10:28:53 +01:00
yo000
efbd25c2a6 update dependancies 2025-02-08 10:22:23 +01:00
yo000
4d575579cd Update to graylog 6 2025-02-08 10:22:20 +01:00
yo000
a984d4800f Rename metadata && lookup 2025-02-08 10:20:51 +01:00
yo000
43d91b9bd1 reformat jsx files 2025-02-08 10:20:40 +01:00
yo000
3544104196 Move buid config to pom.xml 2025-02-08 10:19:45 +01:00
yo000
89e9aefc69 Move buid config to pom.xml 2025-02-08 10:19:45 +01:00
yo000
433cdd3f56 rename plugin descriptin files 2025-02-08 09:23:31 +01:00
18 changed files with 3332 additions and 4150 deletions
Expand all files Collapse all files

10
.mvn/jvm.config
View File

@ -1,10 +0,0 @@
--add-exports jdk.compiler/com.sun.tools.javac.api=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.main=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.model=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.processing=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED
--add-exports jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED
--add-opens jdk.compiler/com.sun.tools.javac.code=ALL-UNNAMED
--add-opens jdk.compiler/com.sun.tools.javac.comp=ALL-UNNAMED

9
README.md
View File

@ -28,11 +28,6 @@ dramatically by making use of hot reloading. To do this, do the following:
Usage Usage
----- -----
### About data types
* "Strings" lookup table will use GET/SET redis commands. Designed to set, get, expire, delete keys.
* "Streams" is designed for a "fire-and-forget" usage. Only "lookup_set_value" will work. Please note there is currently no TTL on stream, so you need to have an external process to purge your stream if you do not want it to grow indefinitely.
### Usage in pipelines
* Create data adapter, cache (or not), lookup table * Create data adapter, cache (or not), lookup table
* Use 'lookup_set_value(lookup_table, key, value, [ttl])' to create or update key in redis * Use 'lookup_set_value(lookup_table, key, value, [ttl])' to create or update key in redis
@ -51,8 +46,8 @@ Be aware that only setting TTL with 'lookup_assign_ttl' of 'lookup_set_string_li
Known bugs Known bugs
---------- ----------
* Deletion via lookup_remove_string_list, lookup_clear_key or keep_duplicates=false sometimes not done. Deletion via lookup_remove_string_list, lookup_clear_key or keep_duplicates=false sometimes not done.
* lookup_add_string_list : Each character of a string list is considered an item
Getting started Getting started
--------------- ---------------

1016
dependency-reduced-pom.xml
View File

File diff suppressed because it is too large Load Diff

180
pom.xml
View File

@ -25,13 +25,13 @@
<parent> <parent>
<groupId>org.graylog.plugins</groupId> <groupId>org.graylog.plugins</groupId>
<artifactId>graylog-plugin-web-parent</artifactId> <artifactId>graylog-plugin-web-parent</artifactId>
<version>5.0.0</version> <version>6.1.0</version>
<relativePath>../graylog2-server/graylog-plugin-parent/graylog-plugin-web-parent</relativePath> <relativePath>../graylog2-server/graylog-plugin-parent/graylog-plugin-web-parent</relativePath>
</parent> </parent>
<groupId>in.nosd.redis</groupId> <groupId>in.nosd.redis</groupId>
<artifactId>graylog-plugin-redis-lookup</artifactId> <artifactId>graylog-plugin-redis-lookup</artifactId>
<version>1.0.3</version> <version>1.0.4</version>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>${project.artifactId}</name> <name>${project.artifactId}</name>
@ -54,56 +54,65 @@
<properties> <properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>17</maven.compiler.source> <maven.compiler.release>11</maven.compiler.release>
<maven.compiler.target>17</maven.compiler.target> <maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
<maven.compiler.useIncrementalCompilation>false</maven.compiler.useIncrementalCompilation>
<!-- Plugins will not be deployed by default - set to `false` if you actually want to deploy it --> <!-- Plugins will not be deployed by default - set to `false` if you actually want to deploy it -->
<maven.deploy.skip>true</maven.deploy.skip> <maven.deploy.skip>true</maven.deploy.skip>
<graylog.version>${project.parent.version}</graylog.version> <graylog.plugin-dir>/usr/local/share/graylog/plugin</graylog.plugin-dir>
<graylog.plugin-dir>/usr/share/graylog-server/plugin</graylog.plugin-dir>
<graylog.version>6.0.0</graylog.version>
<guice.version>7.0.0</guice.version>
<auto-value.version>1.10.4</auto-value.version>
<auto-value-javabean.version>2.5.2</auto-value-javabean.version>
<jackson.version>2.17.1</jackson.version>
<validation-api.version>3.0.2</validation-api.version>
<joda-time.version>2.12.7</joda-time.version>
<commons-lang3.version>3.14.0</commons-lang3.version>
<metrics.version>4.2.25</metrics.version>
<javax.annotation-api.version>1.3.2</javax.annotation-api.version>
<license-maven.version>4.3</license-maven.version>
<!-- Plugin versions -->
<license-maven.version>4.3</license-maven.version>
<download-maven-plugin.version>1.6.8.1</download-maven-plugin.version>
</properties> </properties>
<!-- <distributionManagement>
<snapshotRepository>
<id>sonatype-nexus-snapshots</id>
<name>Sonatype Nexus Snapshots</name>
<url>https://oss.sonatype.org/content/repositories/snapshots</url>
</snapshotRepository>
<repository>
<id>sonatype-nexus-staging</id>
<name>Nexus Release Repository</name>
<url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
</repository>
</distributionManagement>
<repositories>
--> <!-- to make our snapshot releases work with Travis et al -->
<!-- <repository>
<id>sonatype-nexus-snapshots</id>
<name>Sonatype Nexus Snapshots</name>
<url>https://oss.sonatype.org/content/repositories/snapshots</url>
<releases>
<enabled>false</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
</repository>
<repository>
<id>sonatype-nexus-releases</id>
<name>Sonatype Nexus Releases</name>
<url>https://oss.sonatype.org/content/repositories/releases</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
-->
<dependencies> <dependencies>
<!-- com.codahale.metrics -->
<dependency>
<groupId>io.dropwizard.metrics</groupId>
<artifactId>metrics-core</artifactId>
<version>${metrics.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>jakarta.validation</groupId>
<artifactId>jakarta.validation-api</artifactId>
<version>${validation-api.version}</version>
</dependency>
<dependency>
<groupId>joda-time</groupId>
<artifactId>joda-time</artifactId>
<version>${joda-time.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>${commons-lang3.version}</version>
</dependency>
<dependency>
<groupId>com.google.auto.value</groupId>
<artifactId>auto-value-annotations</artifactId>
<version>${auto-value.version}</version>
</dependency>
<dependency> <dependency>
<groupId>org.graylog2</groupId> <groupId>org.graylog2</groupId>
<artifactId>graylog2-server</artifactId> <artifactId>graylog2-server</artifactId>
@ -118,6 +127,24 @@
<type>test-jar</type> <type>test-jar</type>
<scope>test</scope> <scope>test</scope>
</dependency> </dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-jdk14</artifactId>
<version>1.7.21</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.google.inject</groupId>
<artifactId>guice</artifactId>
<version>${guice.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>com.google.inject.extensions</groupId>
<artifactId>guice-assistedinject</artifactId>
<version>${guice.version}</version>
<scope>provided</scope>
</dependency>
<dependency> <dependency>
<groupId>com.google.auto.value</groupId> <groupId>com.google.auto.value</groupId>
<artifactId>auto-value</artifactId> <artifactId>auto-value</artifactId>
@ -146,43 +173,20 @@
</resource> </resource>
</resources> </resources>
<plugins> <plugins>
<plugin>
<groupId>de.thetaphi</groupId>
<artifactId>forbiddenapis</artifactId>
<configuration>
<skip>true</skip>
</configuration>
</plugin>
<plugin> <plugin>
<groupId>com.mycila</groupId> <groupId>com.mycila</groupId>
<artifactId>license-maven-plugin</artifactId> <artifactId>license-maven-plugin</artifactId>
<configuration> <configuration>
<licenseSets> <skip>true</skip>
<licenseSet>
<header>com/mycila/maven/plugin/license/templates/SSPL-1.txt</header>
<properties>
<project.inceptionYear>2024</project.inceptionYear>
<owner>johan@nosd.in</owner>
</properties>
<includes>
<include>**/src/main/java/**</include>
<include>**/src/test/java/**</include>
<include>**/pom.xml</include>
<include>*.js</include>
<include>src/web/**/*.js</include>
<include>src/web/**/*.jsx</include>
<include>src/web/**/*.ts</include>
<include>src/web/**/*.tsx</include>
<include>src/web/**/*.css</include>
</includes>
<excludes>
<exclude>*.config.js</exclude>
</excludes>
</licenseSet>
</licenseSets>
</configuration> </configuration>
<executions>
<execution>
<goals>
<goal>check</goal>
</goals>
</execution>
</executions>
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-assembly-plugin</artifactId> <artifactId>maven-assembly-plugin</artifactId>
<configuration> <configuration>
@ -193,12 +197,25 @@
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<version>3.10.1</version> <version>3.13.0</version>
<configuration> <configuration>
<release>17</release> <release>17</release>
<showWarnings>true</showWarnings> <showWarnings>true</showWarnings>
<showDeprecation>true</showDeprecation> <showDeprecation>true</showDeprecation>
<forceJavacCompilerUse>true</forceJavacCompilerUse> <forceJavacCompilerUse>false</forceJavacCompilerUse>
<fork>true</fork>
<compilerArgs>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.code=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.comp=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.file=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.main=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.model=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.parser=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.processing=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.tree=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.util=ALL-UNNAMED</arg>
<arg>-J--add-opens=jdk.compiler/com.sun.tools.javac.jvm=ALL-UNNAMED</arg>
</compilerArgs>
<annotationProcessors> <annotationProcessors>
<annotationProcessor>com.google.auto.value.processor.AutoValueProcessor</annotationProcessor> <annotationProcessor>com.google.auto.value.processor.AutoValueProcessor</annotationProcessor>
</annotationProcessors> </annotationProcessors>
@ -224,6 +241,12 @@
<version>2.4.1</version> <version>2.4.1</version>
<configuration> <configuration>
<minimizeJar>false</minimizeJar> <minimizeJar>false</minimizeJar>
<artifactSet>
<excludes>
<exclude>com.fasterxml.jackson.core:*</exclude>
<exclude>joda-time:joda-time</exclude>
</excludes>
</artifactSet>
</configuration> </configuration>
<executions> <executions>
<execution> <execution>
@ -322,6 +345,7 @@
<plugin> <plugin>
<groupId>com.github.eirslett</groupId> <groupId>com.github.eirslett</groupId>
<artifactId>frontend-maven-plugin</artifactId> <artifactId>frontend-maven-plugin</artifactId>
<version>1.15.0</version>
<executions> <executions>
<execution> <execution>

6
src/main/java/in/nosd/redis/RedisLookupPluginMetaData.java → src/main/java/in/nosd/redis/RedisLookupMetaData.java
View File

@ -27,17 +27,17 @@ import java.util.Set;
/** /**
* Implement the PluginMetaData interface here. * Implement the PluginMetaData interface here.
*/ */
public class RedisLookupPluginMetaData implements PluginMetaData { public class RedisLookupMetaData implements PluginMetaData {
private static final String PLUGIN_PROPERTIES = "in.nosd.redis.graylog-plugin-redis-lookup/graylog-plugin.properties"; private static final String PLUGIN_PROPERTIES = "in.nosd.redis.graylog-plugin-redis-lookup/graylog-plugin.properties";
@Override @Override
public String getUniqueId() { public String getUniqueId() {
return "in.nosd.redis.RedisLookupPluginPlugin"; return "in.nosd.redis.RedisLookupPlugin";
} }
@Override @Override
public String getName() { public String getName() {
return "RedisLookupPlugin"; return "Redis Lookup";
} }
@Override @Override

16
src/main/java/in/nosd/redis/RedisLookupPluginModule.java → src/main/java/in/nosd/redis/RedisLookupModule.java
View File

@ -16,17 +16,17 @@
*/ */
package in.nosd.redis; package in.nosd.redis;
import com.google.inject.Binder;
import com.google.inject.TypeLiteral;
import com.google.inject.multibindings.MapBinder;
import org.graylog.plugins.pipelineprocessor.ast.functions.Function; import org.graylog.plugins.pipelineprocessor.ast.functions.Function;
import org.graylog2.plugin.PluginConfigBean; import org.graylog2.plugin.PluginConfigBean;
import org.graylog2.plugin.PluginModule; import org.graylog2.plugin.PluginModule;
import com.google.inject.multibindings.MapBinder;
import com.google.inject.Binder;
import com.google.inject.TypeLiteral;
import in.nosd.redis.dataadapters.RedisLookupDataAdapter; import in.nosd.redis.dataadapters.RedisLookupDataAdapter;
import in.nosd.redis.functions.RedisLookupPluginFunction; import in.nosd.redis.functions.RedisLookupPluginFunction;
import in.nosd.redis.migrations.V104_MigrateRedisType;
import java.util.Collections; import java.util.Collections;
import java.util.Set; import java.util.Set;
@ -34,7 +34,7 @@ import java.util.Set;
/** /**
* Extend the PluginModule abstract class here to add you plugin to the system. * Extend the PluginModule abstract class here to add you plugin to the system.
*/ */
public class RedisLookupPluginModule extends PluginModule { public class RedisLookupModule extends PluginModule {
/** /**
* Returns all configuration beans required by this plugin. * Returns all configuration beans required by this plugin.
* *
@ -56,7 +56,7 @@ public class RedisLookupPluginModule extends PluginModule {
* addMessageFilter(Class<? extends MessageFilter>); * addMessageFilter(Class<? extends MessageFilter>);
* addMessageOutput(Class<? extends MessageOutput>); * addMessageOutput(Class<? extends MessageOutput>);
* addPeriodical(Class<? extends Periodical>); * addPeriodical(Class<? extends Periodical>);
* addAlarmCallback(Class<? extends AlarmCallback>); // * addAlarmCallback(Class<? extends AlarmCallback>);
* addInitializer(Class<? extends Service>); * addInitializer(Class<? extends Service>);
* addRestResource(Class<? extends PluginRestResource>); * addRestResource(Class<? extends PluginRestResource>);
* *
@ -66,13 +66,11 @@ public class RedisLookupPluginModule extends PluginModule {
* addConfigBeans(); * addConfigBeans();
*/ */
addMigration(V104_MigrateRedisType.class);
addMessageProcessorFunction(RedisLookupPluginFunction.NAME, RedisLookupPluginFunction.class); addMessageProcessorFunction(RedisLookupPluginFunction.NAME, RedisLookupPluginFunction.class);
installLookupDataAdapter2(RedisLookupDataAdapter.NAME, RedisLookupDataAdapter.class, installLookupDataAdapter2(RedisLookupDataAdapter.NAME, RedisLookupDataAdapter.class,
RedisLookupDataAdapter.Factory.class, RedisLookupDataAdapter.Config.class); RedisLookupDataAdapter.Factory.class, RedisLookupDataAdapter.Config.class);
addConfigBeans(); addConfigBeans();
} }

4
src/main/java/in/nosd/redis/RedisLookupPlugin.java
View File

@ -30,11 +30,11 @@ import java.util.Collections;
public class RedisLookupPlugin implements Plugin { public class RedisLookupPlugin implements Plugin {
@Override @Override
public PluginMetaData metadata() { public PluginMetaData metadata() {
return new RedisLookupPluginMetaData(); return new RedisLookupMetaData();
} }
@Override @Override
public Collection<PluginModule> modules () { public Collection<PluginModule> modules () {
return Collections.<PluginModule>singletonList(new RedisLookupPluginModule()); return Collections.<PluginModule>singletonList(new RedisLookupModule());
} }
} }

39
src/main/java/in/nosd/redis/RedisLookupPluginPlugin.java
View File

@ -1,39 +0,0 @@
/*
* Copyright (C) 2024 johan@nosd.in
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details.
*
* You should have received a copy of the Server Side Public License
* along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>.
*/
package in.nosd.redis;
import org.graylog2.plugin.Plugin;
import org.graylog2.plugin.PluginMetaData;
import org.graylog2.plugin.PluginModule;
import java.util.Collection;
import java.util.Collections;
/**
* Implement the Plugin interface here.
*/
public class RedisLookupPluginPlugin implements Plugin {
@Override
public PluginMetaData metadata() {
return new RedisLookupPluginMetaData();
}
@Override
public Collection<PluginModule> modules () {
return Collections.<PluginModule>singletonList(new RedisLookupPluginModule());
}
}

71
src/main/java/in/nosd/redis/dataadapters/RedisLookupDataAdapter.java
View File

@ -16,6 +16,20 @@
*/ */
package in.nosd.redis.dataadapters; package in.nosd.redis.dataadapters;
import java.util.List;
import java.util.Optional;
import org.apache.commons.lang3.StringUtils;
import org.graylog.autovalue.WithBeanGetter;
import org.graylog2.lookup.dto.DataAdapterDto;
import org.graylog2.plugin.lookup.LookupCachePurge;
import org.graylog2.plugin.lookup.LookupDataAdapter;
import org.graylog2.plugin.lookup.LookupDataAdapterConfiguration;
import org.graylog2.plugin.lookup.LookupResult;
import org.joda.time.Duration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.codahale.metrics.Meter; import com.codahale.metrics.Meter;
import com.codahale.metrics.MetricRegistry; import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.Timer; import com.codahale.metrics.Timer;
@ -26,41 +40,23 @@ import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonTypeName; import com.fasterxml.jackson.annotation.JsonTypeName;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize; import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.google.auto.value.AutoValue; import com.google.auto.value.AutoValue;
import org.graylog2.lookup.dto.DataAdapterDto;
import com.google.common.collect.ArrayListMultimap; import com.google.common.collect.ArrayListMultimap;
import com.google.common.collect.Multimap; import com.google.common.collect.Multimap;
import com.google.inject.Inject;
import com.google.inject.assistedinject.Assisted; import com.google.inject.assistedinject.Assisted;
import org.apache.commons.lang3.StringUtils;
import io.lettuce.core.RedisClient; import io.lettuce.core.RedisClient;
import io.lettuce.core.RedisURI; import io.lettuce.core.RedisURI;
import io.lettuce.core.api.StatefulRedisConnection; import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisCommands; import io.lettuce.core.api.sync.RedisCommands;
import in.nosd.redis.dataadapters.AutoValue_RedisLookupDataAdapter_Config; import jakarta.validation.constraints.Min;
import org.graylog2.plugin.lookup.LookupCachePurge; import jakarta.validation.constraints.NotEmpty;
import org.graylog2.plugin.lookup.LookupDataAdapter; import reactor.util.annotation.Nullable;
import org.graylog2.plugin.lookup.LookupDataAdapterConfiguration;
import org.graylog2.plugin.lookup.LookupResult;
import org.joda.time.Duration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
import com.google.inject.Inject;
import com.google.inject.assistedinject.Assisted;
import javax.validation.constraints.Min;
import javax.validation.constraints.NotEmpty;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.StringJoiner;
public class RedisLookupDataAdapter extends LookupDataAdapter { public class RedisLookupDataAdapter extends LookupDataAdapter {
private static final Logger LOG = LoggerFactory.getLogger(RedisLookupDataAdapter.class); private static final Logger LOG = LoggerFactory.getLogger(RedisLookupDataAdapter.class);
// Should be same as lookupTableAdapters type in index.jsx
public static final String NAME = "RedisLookup"; public static final String NAME = "RedisLookup";
private static final Duration REFRESH_INTERVAL_DURATION = Duration.ZERO; private static final Duration REFRESH_INTERVAL_DURATION = Duration.ZERO;
@ -90,8 +86,8 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
public RedisLookupDataAdapter(@Assisted("dto") DataAdapterDto dto, public RedisLookupDataAdapter(@Assisted("dto") DataAdapterDto dto,
MetricRegistry metricRegistry) { MetricRegistry metricRegistry) {
super(dto, metricRegistry); super(dto, metricRegistry);
this.config = (Config) dto.config(); this.config = (Config) dto.config();
RedisURI redisUri ; RedisURI redisUri ;
redisUri = RedisURI.Builder.redis(this.config.redisHost(),this.config.redisPort()) redisUri = RedisURI.Builder.redis(this.config.redisHost(),this.config.redisPort())
.withPort(this.config.redisPort()) .withPort(this.config.redisPort())
@ -187,7 +183,6 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
// This is deprecated, see setValue // This is deprecated, see setValue
@Deprecated @Deprecated
public void set(Object key, Object value) { public void set(Object key, Object value) {
return;
} }
@Override @Override
@ -195,6 +190,7 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
return setValueWithTtl(key, value, this.config.redisKeyTTL()); return setValueWithTtl(key, value, this.config.redisKeyTTL());
} }
@Override
public LookupResult setValueWithTtl(Object key, Object value, Long ttlSec) { public LookupResult setValueWithTtl(Object key, Object value, Long ttlSec) {
final Timer.Context time = redisSetRequestTimer.time(); final Timer.Context time = redisSetRequestTimer.time();
final String trimmedKey = StringUtils.trimToNull(key.toString()); final String trimmedKey = StringUtils.trimToNull(key.toString());
@ -273,6 +269,7 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
} }
// TTL -1 = never expire // TTL -1 = never expire
@Override
public LookupResult assignTtl(Object key, Long ttlSec) { public LookupResult assignTtl(Object key, Long ttlSec) {
final Timer.Context time = redisAssignTtlRequestTimer.time(); final Timer.Context time = redisAssignTtlRequestTimer.time();
final String trimmedKey = StringUtils.trimToNull(key.toString()); final String trimmedKey = StringUtils.trimToNull(key.toString());
@ -347,11 +344,12 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
} }
} }
@Override
public LookupResult setStringListWithTtl(Object key, List<String> listValue, Long ttlSec) { public LookupResult setStringListWithTtl(Object key, List<String> listValue, Long ttlSec) {
final Timer.Context time = redisSetStringListWithTtlRequestTimer.time(); final Timer.Context time = redisSetStringListWithTtlRequestTimer.time();
try { try {
setStringList(key, listValue); setStringList(key, listValue);
return(assignTtl(key, ttlSec)); return assignTtl(key, ttlSec);
} catch (Exception e) { } catch (Exception e) {
// This exception comes from assignTtl // This exception comes from assignTtl
if (e.getMessage().startsWith("WRONGTYPE Operation against a key holding the wrong kind of value")) { if (e.getMessage().startsWith("WRONGTYPE Operation against a key holding the wrong kind of value")) {
@ -410,7 +408,6 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
.redisHost("127.0.0.1") .redisHost("127.0.0.1")
.redisPort(6379) .redisPort(6379)
.redisDB(0) .redisDB(0)
.redisType("strings")
.redisKeyTTL(-1) .redisKeyTTL(-1)
.redisUsername("") .redisUsername("")
.redisPassword("") .redisPassword("")
@ -421,11 +418,12 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
@AutoValue @AutoValue
@WithBeanGetter
@JsonAutoDetect @JsonAutoDetect
@JsonDeserialize(builder = RedisLookupDataAdapter.Config.Builder.class) @JsonDeserialize(builder = AutoValue_RedisLookupDataAdapter_Config.Builder.class)
@JsonTypeName(NAME) @JsonTypeName(NAME)
@JsonInclude(JsonInclude.Include.NON_EMPTY) @JsonInclude(JsonInclude.Include.NON_EMPTY)
public abstract static class Config implements LookupDataAdapterConfiguration { public static abstract class Config implements LookupDataAdapterConfiguration {
@Override @Override
@JsonProperty(TYPE_FIELD) @JsonProperty(TYPE_FIELD)
@ -442,13 +440,6 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
@JsonProperty("redis_database") @JsonProperty("redis_database")
@Min(0) @Min(0)
public abstract int redisDB(); public abstract int redisDB();
@JsonProperty("redis_type")
/* FIXME: This should be notEmpty, but migration crash when dbDataAdapterService.findAll() with error
* "Missing required properties: redisType"
* so dont flag NoteEmpty and put Nullable. */
@Nullable
public abstract String redisType();
@JsonProperty("redis_ttl") @JsonProperty("redis_ttl")
@Min(0) @Min(0)
@ -480,11 +471,6 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
@AutoValue.Builder @AutoValue.Builder
public abstract static class Builder { public abstract static class Builder {
@JsonCreator
public static Builder create() {
return Config.builder();
}
@JsonProperty(TYPE_FIELD) @JsonProperty(TYPE_FIELD)
public abstract Builder type(String type); public abstract Builder type(String type);
@ -496,9 +482,6 @@ public class RedisLookupDataAdapter extends LookupDataAdapter {
@JsonProperty("redis_database") @JsonProperty("redis_database")
public abstract Builder redisDB(int redisDB); public abstract Builder redisDB(int redisDB);
@JsonProperty("redis_type")
public abstract Builder redisType(String redisType);
@JsonProperty("redis_ttl") @JsonProperty("redis_ttl")
public abstract Builder redisKeyTTL(long redisKeyTTL); public abstract Builder redisKeyTTL(long redisKeyTTL);

2
src/main/java/in/nosd/redis/functions/RedisLookupPluginFunction.java
View File

@ -30,7 +30,7 @@ import org.graylog2.plugin.lookup.LookupResult;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import javax.inject.Inject; import com.google.inject.Inject;
public class RedisLookupPluginFunction extends LookupTableFunction<GenericLookupResult> { public class RedisLookupPluginFunction extends LookupTableFunction<GenericLookupResult> {

140
src/main/java/in/nosd/redis/migrations/V104_MigrateRedisType.java
View File

@ -1,140 +0,0 @@
/*
* Copyright (C) 2024 johan@nosd.in
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details.
*
* You should have received a copy of the Server Side Public License
* along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>.
*/
package in.nosd.redis.migrations;
import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.google.auto.value.AutoValue;
import com.google.common.collect.ImmutableSet;
import org.graylog.autovalue.WithBeanGetter;
import in.nosd.redis.dataadapters.RedisLookupDataAdapter;
import in.nosd.redis.dataadapters.RedisLookupDataAdapter.Config;
import org.graylog2.events.ClusterEventBus;
import org.graylog2.lookup.db.DBDataAdapterService;
import org.graylog2.lookup.dto.DataAdapterDto;
import org.graylog2.lookup.events.DataAdaptersUpdated;
import org.graylog2.migrations.Migration;
import org.graylog2.plugin.cluster.ClusterConfigService;
import org.graylog2.plugin.lookup.LookupDataAdapterConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.inject.Inject;
import java.time.ZonedDateTime;
import java.util.Collections;
import java.util.Collection;
import java.util.Set;
import java.util.stream.Collectors;
import static com.google.common.base.Strings.isNullOrEmpty;
// From graylog-plugin-threatintel/src/main/java/org/graylog/plugins/threatintel/migrations/V20170821100300_MigrateOTXAPIToken.java
/* Manually :
*
* Go into mongodb instance
* Locate "lut_data_adapters" table
* Edit every entry for which "config.type" == "RedisLookup"
* Add "redis_type" key with value "strings"
*/
public class V104_MigrateRedisType extends Migration {
private static final Logger LOG = LoggerFactory.getLogger(V104_MigrateRedisType.class);
private static final ImmutableSet<String> REDIS_DATA_ADAPTER_NAMES = ImmutableSet.of("redis-lookup");
private final ClusterConfigService clusterConfigService;
private final DBDataAdapterService dbDataAdapterService;
private final ClusterEventBus clusterBus;
@Inject
public V104_MigrateRedisType(ClusterConfigService clusterConfigService,
DBDataAdapterService dbDataAdapterService,
ClusterEventBus clusterBus) {
this.clusterConfigService = clusterConfigService;
this.dbDataAdapterService = dbDataAdapterService;
this.clusterBus = clusterBus;
}
@Override
public ZonedDateTime createdAt() {
return ZonedDateTime.parse("2024-03-03T15:42:42Z");
}
@Override
public void upgrade() {
Config redisConf;
// List every instance of lookup DB adapter, and find instance with Config.type == "RedisLookup" (RedisLookupDataAdapter.NAME)
Collection<DataAdapterDto> DataAdapters = dbDataAdapterService.findAll();
for (DataAdapterDto dataAdapterDto : DataAdapters) {
if (dataAdapterDto.config().type().equals(RedisLookupDataAdapter.NAME)) {
redisConf = (Config) dataAdapterDto.config();
final Config newConf = Config.builder()
.type(redisConf.type())
.redisHost(redisConf.redisHost())
.redisPort(redisConf.redisPort())
.redisDB(redisConf.redisDB())
.redisType("strings")
.redisKeyTTL(redisConf.redisKeyTTL())
.redisUsername(redisConf.redisUsername())
.redisPassword(redisConf.redisPassword())
.build();
final DataAdapterDto newDto = DataAdapterDto.builder()
.id(dataAdapterDto.id())
.config(newConf)
.title(dataAdapterDto.title())
.description(dataAdapterDto.description())
.name(dataAdapterDto.name())
.build();
final DataAdapterDto saved = dbDataAdapterService.save(newDto);
clusterBus.post(DataAdaptersUpdated.create(saved.id()));
LOG.debug("Redis data adapter <{}> migrated: data_type added", dataAdapterDto.name());
}
}
}
@JsonAutoDetect
@AutoValue
@WithBeanGetter
public static abstract class MigrationCompleted {
@JsonProperty("converted_redis_type")
public abstract boolean convertedRedisType();
@JsonProperty("data_adapter_ids")
public abstract Set<String> dataAdapterIds();
@JsonCreator
public static MigrationCompleted create(@JsonProperty("data_adapter_ids") final Set<String> dataAdapterIds,
@JsonProperty("converted_redis_type") final boolean convertedRedisType) {
return new AutoValue_V104_MigrateRedisType_MigrationCompleted(convertedRedisType, dataAdapterIds);
}
public static MigrationCompleted convertedType(@JsonProperty("data_adapter_ids") final Set<String> dataAdapterIds) {
return create(dataAdapterIds, true);
}
public static MigrationCompleted notConvertedType() {
return create(Collections.emptySet(), false);
}
}
}

2
src/main/resources/META-INF/services/org.graylog2.plugin.Plugin
View File

@ -1 +1 @@
in.nosd.redis.RedisLookupPluginPlugin in.nosd.redis.RedisLookupPlugin

71
src/web/dataadapters/RedisLookupAdapterDocumentation.jsx
View File

@ -1,36 +1,35 @@
/* /*
* Copyright (C) 2024 johan@nosd.in * Copyright (C) 2024 johan@nosd.in
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1, * it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc. * as published by MongoDB, Inc.
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details. * Server Side Public License for more details.
* *
* You should have received a copy of the Server Side Public License * You should have received a copy of the Server Side Public License
* along with this program. If not, see * along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>. * <http://www.mongodb.com/licensing/server-side-public-license>.
*/ */
/* eslint-disable react/no-unescaped-entities, no-template-curly-in-string */ import React from 'react';
import React from 'react';
class RedisLookupAdapterDocumentation extends React.Component {
class RedisLookupAdapterDocumentation extends React.Component { render() {
render() { const style = { marginBottom: 10 };
const style = { marginBottom: 10 }; return (
return ( <div>
<div> <p style={style}>
<p style={style}> The Redis Lookup data adapter lookup redis for the given key and returns the values.<br/>
The Redis Lookup data adapter lookup redis for the given key and returns the values.<br/> It supports writing key/values to Redis (SET command). <br/>
It supports writing key/values to Redis (SET command). <br/> All created keys will have the TTL configured for the data adapter.
All created keys will have the TTL configured for the data adapter. </p>
</p> </div>
</div> )
) ;
; }
} }
}
export default RedisLookupAdapterDocumentation;
export default RedisLookupAdapterDocumentation;

253
src/web/dataadapters/RedisLookupAdapterFieldSet.jsx
View File

@ -1,138 +1,115 @@
/* /*
* Copyright (C) 2024 johan@nosd.in * Copyright (C) 2024 johan@nosd.in
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1, * it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc. * as published by MongoDB, Inc.
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details. * Server Side Public License for more details.
* *
* You should have received a copy of the Server Side Public License * You should have received a copy of the Server Side Public License
* along with this program. If not, see * along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>. * <http://www.mongodb.com/licensing/server-side-public-license>.
*/ */
import React, { useCallback, useEffect, useRef, useState } from 'react'; import React, { useCallback, useEffect, useRef, useState } from 'react';
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
//import { Button } from 'components/graylog';
//import ObjectUtils from 'util/ObjectUtils'; import { Input } from 'components/bootstrap';
import { Input } from 'components/bootstrap';
// "Missing or invalid plugin" in "dataAdapter create/Data adapter type" list when imported class RedisLookupAdapterFieldSet extends React.Component {
//import { Select } from './components/common'; static propTypes = {
//import { Select } from '../../../../graylog2-server/graylog2-web-interface/src/components/common'; config: PropTypes.shape({
redis_host: PropTypes.string.isRequired,
class RedisLookupAdapterFieldSet extends React.Component { }).isRequired,
static propTypes = { updateConfig: PropTypes.func.isRequired,
config: PropTypes.shape({ handleFormEvent: PropTypes.func.isRequired,
redis_host: PropTypes.string.isRequired, validationState: PropTypes.func.isRequired,
redis_port: PropTypes.number.isRequired, validationMessage: PropTypes.func.isRequired,
redis_database: PropTypes.number.isRequired, };
redis_type: PropTypes.string.isRequired,
redis_ttl: PropTypes.number.isRequired, handleSelect = (fieldName) => {
redis_username: PropTypes.string, return (selectedIndicator) => {
redis_password: PropTypes.string, const config = lodash.cloneDeep(this.props.config);
}).isRequired, config[fieldName] = selectedIndicator;
updateConfig: PropTypes.func.isRequired, this.props.updateConfig(config);
handleFormEvent: PropTypes.func.isRequired, };
validationState: PropTypes.func.isRequired, };
validationMessage: PropTypes.func.isRequired,
}; render() {
const { config } = this.props;
/* _onRedisTypeSelect = (type) => {
const { config, updateConfig } = this.props; return (
const newConfig = ObjectUtils.clone(config); <fieldset>
<Input type="text"
newConfig.redis_type = type; id="redis_host"
updateConfig(newConfig); name="redis_host"
}; label="Redis host"
*/ required
render() { onChange={this.props.handleFormEvent}
const { config } = this.props; help={this.props.validationMessage('redis_host', 'Your Redis Host')}
bsStyle={this.props.validationState('redis_host')}
return ( value={config.redis_host}
<fieldset> labelClassName="col-sm-3"
<Input type="text" wrapperClassName="col-sm-9" />
id="redis_host" <Input type="text"
name="redis_host" id="redis_port"
label="Redis host" name="redis_port"
required label="Redis port"
onChange={this.props.handleFormEvent} required
help={this.props.validationMessage('redis_host', 'Your Redis Host')} onChange={this.props.handleFormEvent}
bsStyle={this.props.validationState('redis_host')} help={this.props.validationMessage('redis_port', 'Redis port instance is listening on')}
value={config.redis_host} bsStyle={this.props.validationState('redis_port')}
labelClassName="col-sm-3" value={config.redis_port}
wrapperClassName="col-sm-9" /> labelClassName="col-sm-3"
<Input type="text" wrapperClassName="col-sm-9" />
id="redis_port" <Input type="text"
name="redis_port" id="redis_database"
label="Redis port" name="redis_database"
required label="Redis database"
onChange={this.props.handleFormEvent} required
help={this.props.validationMessage('redis_port', 'Redis port instance is listening on')} onChange={this.props.handleFormEvent}
bsStyle={this.props.validationState('redis_port')} help={this.props.validationMessage('redis_database', 'Redis database')}
value={config.redis_port} bsStyle={this.props.validationState('redis_database')}
labelClassName="col-sm-3" value={config.redis_database}
wrapperClassName="col-sm-9" /> labelClassName="col-sm-3"
<Input type="text" wrapperClassName="col-sm-9" />
id="redis_database" <Input type="text"
name="redis_database" id="redis_ttl"
label="Redis database" name="redis_ttl"
required label="Redis key TTL"
onChange={this.props.handleFormEvent} required
help={this.props.validationMessage('redis_database', 'Redis database')} onChange={this.props.handleFormEvent}
bsStyle={this.props.validationState('redis_database')} help={this.props.validationMessage('redis_ttl', 'Redis key TTL in seconds. Set -1 to not expire keys')}
value={config.redis_database} bsStyle={this.props.validationState('redis_ttl')}
labelClassName="col-sm-3" value={config.redis_ttl}
wrapperClassName="col-sm-9" /> labelClassName="col-sm-3"
<Input type="text" wrapperClassName="col-sm-9" />
id="redis_type" <Input type="text"
name="redis_type" id="redis_username"
label="Redis data type" name="redis_username"
required label="Redis username"
onChange={this.props.handleFormEvent} onChange={this.props.handleFormEvent}
help={this.props.validationMessage('redis_type', 'Redis data type used for lookups. Should be one of "strings", "streams".')} help={this.props.validationMessage('redis_username', 'Redis username. Leave empty for no auth or "requirepass" authentication')}
bsStyle={this.props.validationState('redis_type')} bsStyle={this.props.validationState('redis_username')}
value={config.redis_type} value={config.redis_username}
labelClassName="col-sm-3" labelClassName="col-sm-3"
wrapperClassName="col-sm-9"> wrapperClassName="col-sm-9" />
</Input> <Input type="password"
<Input type="text" id="redis_password"
id="redis_ttl" label="Redis password"
name="redis_ttl" onChange={this.props.handleFormEvent}
label="Redis key TTL" help={this.props.validationMessage('redis_password', 'Redis password. Leave empty for no auth')}
required bsStyle={this.props.validationState('redis_password')}
onChange={this.props.handleFormEvent} value={config.redis_password}
help={this.props.validationMessage('redis_ttl', 'Redis key TTL in seconds. Set -1 to not expire keys')} labelClassName="col-sm-3"
bsStyle={this.props.validationState('redis_ttl')} wrapperClassName="col-sm-9">
value={config.redis_ttl} </Input>
labelClassName="col-sm-3" </fieldset>
wrapperClassName="col-sm-9" /> );
<Input type="text" }
id="redis_username" }
name="redis_username"
label="Redis username" export default RedisLookupAdapterFieldSet;
onChange={this.props.handleFormEvent}
help={this.props.validationMessage('redis_username', 'Redis username. Leave empty for no auth or "requirepass" authentication')}
bsStyle={this.props.validationState('redis_username')}
value={config.redis_username}
labelClassName="col-sm-3"
wrapperClassName="col-sm-9" />
<Input type="password"
id="redis_password"
label="Redis password"
onChange={this.props.handleFormEvent}
help={this.props.validationMessage('redis_password', 'Redis password. Leave empty for no auth')}
bsStyle={this.props.validationState('redis_password')}
value={config.redis_password}
labelClassName="col-sm-3"
wrapperClassName="col-sm-9">
</Input>
</fieldset>
);
}
}
export default RedisLookupAdapterFieldSet;

106
src/web/dataadapters/RedisLookupAdapterSummary.jsx
View File

@ -1,54 +1,52 @@
/* /*
* Copyright (C) 2024 johan@nosd.in * Copyright (C) 2024 johan@nosd.in
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1, * it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc. * as published by MongoDB, Inc.
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details. * Server Side Public License for more details.
* *
* You should have received a copy of the Server Side Public License * You should have received a copy of the Server Side Public License
* along with this program. If not, see * along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>. * <http://www.mongodb.com/licensing/server-side-public-license>.
*/ */
// eslint-disable-next-line react/prefer-stateless-function // eslint-disable-next-line react/prefer-stateless-function
import React from 'react'; import React from 'react';
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
class RedisLookupAdapterSummary extends React.Component { class RedisLookupAdapterSummary extends React.Component {
static propTypes = { static propTypes = {
dataAdapter: PropTypes.shape({ dataAdapter: PropTypes.shape({
config: PropTypes.shape({ config: PropTypes.shape({
redis_host: PropTypes.string.isRequired, redis_host: PropTypes.string.isRequired,
}), }),
}), }),
}; };
render() { render() {
const { config } = this.props.dataAdapter; const { config } = this.props.dataAdapter;
return ( return (
<dl> <dl>
<dt>Redis host</dt> <dt>Redis host</dt>
<dd>{config.redis_host || 'n/a'}</dd> <dd>{config.redis_host || 'n/a'}</dd>
<dt>Redis port</dt> <dt>Redis port</dt>
<dd>{config.redis_port || 'n/a'}</dd> <dd>{config.redis_port || 'n/a'}</dd>
<dt>Redis database</dt> <dt>Redis database</dt>
<dd>{config.redis_database}</dd> <dd>{config.redis_database}</dd>
<dt>Redis key TTL</dt> <dt>Redis key TTL</dt>
<dd>{config.redis_type || 'n/a'}</dd> <dd>{config.redis_ttl || 'n/a'}</dd>
<dt>Redis data type</dt> <dt>Redis username</dt>
<dd>{config.redis_ttl || 'n/a'}</dd> <dd>{config.redis_username || 'n/a'}</dd>
<dt>Redis username</dt> <dt>Redis password</dt>
<dd>{config.redis_username || 'n/a'}</dd> <dd>******</dd>
<dt>Redis password</dt> </dl>
<dd>******</dd> );
</dl> }
); }
}
} export default RedisLookupAdapterSummary;
export default RedisLookupAdapterSummary;

78
src/web/index.jsx
View File

@ -1,39 +1,39 @@
/* /*
* Copyright (C) 2024 johan@nosd.in * Copyright (C) 2024 johan@nosd.in
* *
* This program is free software: you can redistribute it and/or modify * This program is free software: you can redistribute it and/or modify
* it under the terms of the Server Side Public License, version 1, * it under the terms of the Server Side Public License, version 1,
* as published by MongoDB, Inc. * as published by MongoDB, Inc.
* *
* This program is distributed in the hope that it will be useful, * This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of * but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* Server Side Public License for more details. * Server Side Public License for more details.
* *
* You should have received a copy of the Server Side Public License * You should have received a copy of the Server Side Public License
* along with this program. If not, see * along with this program. If not, see
* <http://www.mongodb.com/licensing/server-side-public-license>. * <http://www.mongodb.com/licensing/server-side-public-license>.
*/ */
// eslint-disable-next-line no-unused-vars // eslint-disable-next-line no-unused-vars
import webpackEntry from 'webpack-entry'; import webpackEntry from 'webpack-entry';
import { PluginManifest, PluginStore } from 'graylog-web-plugin/plugin'; import { PluginManifest, PluginStore } from 'graylog-web-plugin/plugin';
import packageJson from '../../package.json'; import packageJson from '../../package.json';
import RedisLookupAdapterDocumentation from './dataadapters/RedisLookupAdapterDocumentation'; import RedisLookupAdapterDocumentation from './dataadapters/RedisLookupAdapterDocumentation';
import RedisLookupAdapterFieldSet from './dataadapters/RedisLookupAdapterFieldSet'; import RedisLookupAdapterFieldSet from './dataadapters/RedisLookupAdapterFieldSet';
import RedisLookupAdapterSummary from './dataadapters/RedisLookupAdapterSummary'; import RedisLookupAdapterSummary from './dataadapters/RedisLookupAdapterSummary';
const manifest = new PluginManifest(packageJson, { const manifest = new PluginManifest(packageJson, {
lookupTableAdapters: [ lookupTableAdapters: [
{ {
type: 'RedisLookup', type: 'RedisLookup',
displayName: 'Redis Lookup', displayName: 'Redis Lookup',
formComponent: RedisLookupAdapterFieldSet, formComponent: RedisLookupAdapterFieldSet,
summaryComponent: RedisLookupAdapterSummary, summaryComponent: RedisLookupAdapterSummary,
documentationComponent: RedisLookupAdapterDocumentation, documentationComponent: RedisLookupAdapterDocumentation,
}, },
], ],
}); });
PluginStore.register(manifest); PluginStore.register(manifest);

2
webpack.config.js
View File

@ -19,6 +19,6 @@ const { PluginWebpackConfig } = require('graylog-web-plugin');
const { loadBuildConfig } = require('graylog-web-plugin'); const { loadBuildConfig } = require('graylog-web-plugin');
// Remember to use the same name here and in `getUniqueId()` in the java MetaData class // Remember to use the same name here and in `getUniqueId()` in the java MetaData class
module.exports = new PluginWebpackConfig(__dirname, 'in.nosd.redis.RedisLookupPluginPlugin', loadBuildConfig(path.resolve(__dirname, './build.config')), { module.exports = new PluginWebpackConfig(__dirname, 'in.nosd.redis.RedisLookupPlugin', loadBuildConfig(path.resolve(__dirname, './build.config')), {
// Here goes your additional webpack configuration. // Here goes your additional webpack configuration.
}); });

5477
yarn.lock
View File

File diff suppressed because it is too large Load Diff