Skip to content

Grd 104227 merge capella in public #839

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
JingqiuDu wants to merge 2 commits into
base: main
Choose a base branch
from
Open

Grd 104227 merge capella in public #839

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a7b06da
fix the path
JingqiuDu Jul 21, 2025
5ff8db5
fix unittest hanging issue
JingqiuDu Jul 21, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions filter-plugin/logstash-filter-capella-guardium/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,7 @@ enforcements. Configure Guardium to read the native audit/data_access logs by cu
the [logstash-input-couchbase_capella_input](../../input-plugin/logstash-input-couchbase-capella/logstash-input-couchbase_capella_input.zip)
plug-in.
* Download
the [logstash-filter-capella_guardium_filter](capellaCouchbaseOverCapellaPackage/capella/logstash-filter-capella_guardium_filter.zip)
the [logstash-filter-capella_guardium_filter](logstash-filter-capella_guardium_filter.zip)
plug-in.
* Capella-Guardium Logstash filter plug-in is automatically available with Guardium Data Protection versions 12.x, 11.4
with appliance bundle 11.0p490 or later or Guardium Data Protection version 11.5 with appliance bundle 11.0p540 or
Expand All @@ -129,15 +129,15 @@ enforcements. Configure Guardium to read the native audit/data_access logs by cu
1. On the collector, go to ```Setup``` > ```Tools and Views``` > ```Configure Universal Connector```.
2. Enable the universal connector if it is disabled.
3. Click ```Upload File``` and select the
offline [logstash-filter-capella_guardium_filter](capellaCouchbaseOverCapellaPackage/capella/logstash-filter-capella_guardium_filter.zip)
offline [logstash-filter-capella_guardium_filter](logstash-filter-capella_guardium_filter.zip)
plug-in. After it is uploaded, click ```OK```.
4. Click the Plus sign to open the Connector Configuration dialog box.
5. Type a name in the Connector name field.
6. Update the input section to add the details from
the [capellaCouchbase.conf](capellaCouchbaseOverCapellaPackage/capella/capellaCouchbase.conf) file's input part,
the [capellaCouchbase.conf](capellaCouchbaseOverCapellaPackage/capellaCouchbase.conf) file's input part,
omitting the keyword "input{" at the beginning and its corresponding "}" at the end.
7. Update the filter section to add the details from
the [capellaCouchbase.conf](capellaCouchbaseOverCapellaPackage/capella/capellaCouchbase.conf) file's filter part,
the [capellaCouchbase.conf](capellaCouchbaseOverCapellaPackage/capellaCouchbase.conf) file's filter part,
omitting the keyword "filter{" at the beginning and its corresponding "}" at the end.
8. The 'type' fields should match in the input and filter configuration sections. This field should be unique for every
individual connector added.
Expand Down
0 ...ellaPackage/capella/capellaCouchbase.conf → ...eOverCapellaPackage/capellaCouchbase.conf
View file
Open in desktop
File renamed without changes.
0 ...gstash-filter-capella_guardium_filter.zip → ...gstash-filter-capella_guardium_filter.zip
View file
Open in desktop
File renamed without changes.
4 changes: 2 additions & 2 deletions input-plugin/logstash-input-couchbase-capella/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -47,8 +47,8 @@ https://docs.couchbase.com/server/current/manage/manage-security/manage-auditing
3. Click ```Upload File``` and select the offline [logstash-input-couchbase_capella_input](logstash-input-couchbase_capella_input.zip) plug-in. After it is uploaded, click ```OK```.
4. Click the Plus sign to open the Connector Configuration dialog box.
5. Type a name in the Connector name field.
6. Update the input section to add the details from the [capellaCouchbase.conf](../../filter-plugin/logstash-filter-capella-guardium/capellaCouchbaseOverCapellaPackage/capella/capellaCouchbase.conf) file's input part, omitting the keyword "input{" at the beginning and its corresponding "}" at the end.
7. Update the filter section to add the details from the [capellaCouchbase.conf](../../filter-plugin/logstash-filter-capella-guardium/capellaCouchbaseOverCapellaPackage/capella/capellaCouchbase.conf) file's filter part, omitting the keyword "filter{" at the beginning and its corresponding "}" at the end.
6. Update the input section to add the details from the [capellaCouchbase.conf](../../filter-plugin/logstash-filter-capella-guardium/capellaCouchbaseOverCapellaPackage/capellaCouchbase.conf) file's input part, omitting the keyword "input{" at the beginning and its corresponding "}" at the end.
7. Update the filter section to add the details from the [capellaCouchbase.conf](../../filter-plugin/logstash-filter-capella-guardium/capellaCouchbaseOverCapellaPackage/capellaCouchbase.conf) file's filter part, omitting the keyword "filter{" at the beginning and its corresponding "}" at the end.
8. The 'type' fields should match in the input and filter configuration sections. This field should be unique for every individual connector added.
9. Click ```Save```. Guardium validates the new connector and displays it in the Configure Universal Connector page.
10. After the offline plug-in is installed and the configuration is uploaded and saved in the Guardium machine, restart the Universal Connector using the ```Disable/Enable``` button.
Expand Down
Binary file modified input-plugin/logstash-input-couchbase-capella/logstash-input-couchbase_capella_input.zip
View file
Open in desktop
Binary file not shown.
14 changes: 7 additions & 7 deletions ...-input-couchbase-capella/src/test/java/org/logstashplugins/CouchbaseCapellaInputTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ public void testCouchbaseCapellaInputTest() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand Down Expand Up @@ -109,7 +109,7 @@ public void testCouchbaseCapellaInput_EpochToISO8601() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand All @@ -128,7 +128,7 @@ public void testCouchbaseCapellaInput_EmptyBaseUrl() {

Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), "");
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand All @@ -147,7 +147,7 @@ public void testCouchbaseCapellaInput_EmptyOrgID() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand All @@ -166,7 +166,7 @@ public void testCouchbaseCapellaInput_EmptyProjectID() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "");
Expand All @@ -185,7 +185,7 @@ public void testCouchbaseCapellaInput_EmptyClusterID() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand All @@ -204,7 +204,7 @@ public void testCouchbaseCapellaInput_EmptyAuthToken() {
var baseUrl = String.format("http://%s:%d/%s", mockServerHost, mockServerPort, mockServerApiBasePath);
Map<String, Object> configValues = new HashMap<>();
configValues.put(CouchbaseCapellaInput.INTERVAL_CONFIG.name(), 2L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 1L);
configValues.put(CouchbaseCapellaInput.QUERY_LENGTH_CONFIG.name(), 20 * 60L);
configValues.put(CouchbaseCapellaInput.API_BASE_URL_CONFIG.name(), baseUrl);
configValues.put(CouchbaseCapellaInput.ORG_ID_CONFIG.name(), "success-org");
configValues.put(CouchbaseCapellaInput.PROJECT_ID_CONFIG.name(), "success-project");
Expand Down
Binary file modified input-plugin/logstash-input-couchbase-capella/src/test/resources/mocks/mock-audit-log.tar.gz
View file
Open in desktop
Binary file not shown.
Loading