Skip to content

Commit cab6e75

Browse files
authored
Remove dependency on splunk key value store. (#98)
1 parent 6e639aa commit cab6e75

File tree

19 files changed

+307
-578
lines changed

19 files changed

+307
-578
lines changed

.gitignore

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,4 +20,5 @@ licenses.json
2020
functional-temp
2121
splunktional-temp
2222

23-
output/
23+
output/
24+
logs/

compose.yml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ services:
99
environment:
1010
- SPLUNK_START_ARGS=--accept-license
1111
- SPLUNK_PASSWORD=a_password
12-
- IS_LOCAL_BUILD=true
1312
volumes:
1413
- ./output/flare:/opt/splunk/etc/apps/flare
15-
- ./splunk/default.yml:/tmp/defaults/default.yml
14+
- ./splunk/default.yml:/tmp/defaults/default.yml
15+
- ./logs:/opt/splunk/var/log/splunk

packages/flare/bin/__init__.py

Whitespace-only changes.

packages/flare/bin/constants.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@
66
HOST = "localhost"
77
SPLUNK_PORT = 8089
88
REALM = APP_NAME + "_realm"
9-
KV_COLLECTION_NAME = "event_ingestion_collection"
109
CRON_JOB_THRESHOLD_SINCE_LAST_FETCH = timedelta(minutes=10)
1110

1211

@@ -18,11 +17,11 @@ class PasswordKeys(Enum):
1817
SOURCE_TYPES_FILTER = "source_types_filter"
1918

2019

21-
class CollectionKeys(Enum):
20+
class DataStoreKeys(Enum):
2221
LAST_INGESTED_TENANT_ID = "last_ingested_tenant_id"
2322
START_DATE = "start_date"
2423
TIMESTAMP_LAST_FETCH = "timestamp_last_fetch"
2524

2625
@staticmethod
27-
def get_next_token(tenantId: int) -> str:
28-
return f"next_{tenantId}"
26+
def get_next_token(tenant_id: int) -> str:
27+
return f"next_{tenant_id}"

0 commit comments

Comments
 (0)