Skip to content

Commit 63f66c3

Browse files
tamassoltesztamassoltesz
committed
backport: logs to otel
fix: add implementationDependencies.json dependencies chore: build version and changelog fix: add missing config and devConfig entries fix: remove accidentally merged lines
1 parent b947894 commit 63f66c3

10 files changed

Lines changed: 351 additions & 122 deletions

File tree

‎CHANGELOG.md‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,10 @@ to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
77

88
## [Unreleased]
99

10+
## [10.0.4]
11+
12+
- Adds internal opentelemetry support for logging
13+
1014
## [10.0.3]
1115

1216
- Fixes `StorageTransactionLogicException` in bulk import when not using userRoles and totpDevices in import json.

‎build.gradle‎

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,13 @@ compileTestJava { options.encoding = "UTF-8" }
1919
// }
2020
//}
2121

22-
version = "10.0.3"
22+
version = "10.0.4"
2323

2424
repositories {
2525
mavenCentral()
2626
}
2727

28+
2829
dependencies {
2930

3031
// https://mvnrepository.com/artifact/com.google.code.gson/gson
@@ -37,9 +38,6 @@ dependencies {
3738
// https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core
3839
implementation group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.16.1'
3940

40-
// https://mvnrepository.com/artifact/ch.qos.logback/logback-classic
41-
implementation group: 'ch.qos.logback', name: 'logback-classic', version: '1.4.14'
42-
4341
// https://mvnrepository.com/artifact/org.apache.tomcat.embed/tomcat-embed-core
4442
implementation group: 'org.apache.tomcat.embed', name: 'tomcat-embed-core', version: '10.1.18'
4543

@@ -73,6 +71,20 @@ dependencies {
7371
// https://mvnrepository.com/artifact/com.googlecode.libphonenumber/libphonenumber/
7472
implementation group: 'com.googlecode.libphonenumber', name: 'libphonenumber', version: '8.13.25'
7573

74+
75+
implementation platform("io.opentelemetry.instrumentation:opentelemetry-instrumentation-bom-alpha:2.17.0-alpha")
76+
77+
implementation("ch.qos.logback:logback-core:1.5.18")
78+
implementation("ch.qos.logback:logback-classic:1.5.18")
79+
80+
// OpenTelemetry core
81+
implementation("io.opentelemetry:opentelemetry-sdk")
82+
implementation("io.opentelemetry:opentelemetry-exporter-otlp")
83+
implementation("io.opentelemetry:opentelemetry-exporter-logging")
84+
implementation("io.opentelemetry:opentelemetry-api")
85+
86+
implementation("io.opentelemetry.semconv:opentelemetry-semconv")
87+
7688
compileOnly project(":supertokens-plugin-interface")
7789
testImplementation project(":supertokens-plugin-interface")
7890

‎config.yaml‎

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,3 +174,8 @@ core_config_version: 0
174174
# (DIFFERENT_ACROSS_APPS | OPTIONAL | Default: number of available processor cores) int value. If specified,
175175
# the supertokens core will use the specified number of threads to complete the migration of users.
176176
# bulk_migration_parallelism:
177+
178+
# (OPTIONAL | Default: http://localhost:4317) string value. The URL of the OpenTelemetry collector to which the core
179+
# will send telemetry data. This should be in the format http://<host>:<port> or https://<host>:<port>.
180+
# otel_collector_connection_uri:
181+

‎devConfig.yaml‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -175,3 +175,6 @@ disable_telemetry: true
175175
# the supertokens core will use the specified number of threads to complete the migration of users.
176176
# bulk_migration_parallelism:
177177

178+
# (OPTIONAL | Default: http://localhost:4317) string value. The URL of the OpenTelemetry collector to which the core
179+
# will send telemetry data. This should be in the format http://<host>:<port> or https://<host>:<port>.
180+
# otel_collector_connection_uri:

‎implementationDependencies.json‎

Lines changed: 123 additions & 118 deletions
Original file line numberDiff line numberDiff line change
@@ -1,120 +1,125 @@
11
{
2-
"_comment": "Contains list of implementation dependencies URL for this project",
3-
"list": [
4-
{
5-
"jar": "https://repo1.maven.org/maven2/com/google/code/gson/gson/2.3.1/gson-2.3.1.jar",
6-
"name": "Gson 2.3.1",
7-
"src": "https://repo1.maven.org/maven2/com/google/code/gson/gson/2.3.1/gson-2.3.1-sources.jar"
8-
},
9-
{
10-
"jar": "https://repo1.maven.org/maven2/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.16.1/jackson-dataformat-yaml-2.16.1.jar",
11-
"name": "Jackson Dataformat 2.16.1",
12-
"src": "https://repo1.maven.org/maven2/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.16.1/jackson-dataformat-yaml-2.16.1-sources.jar"
13-
},
14-
{
15-
"jar": "https://repo1.maven.org/maven2/org/yaml/snakeyaml/2.2/snakeyaml-2.2.jar",
16-
"name": "SnakeYAML 2.2",
17-
"src": "https://repo1.maven.org/maven2/org/yaml/snakeyaml/2.2/snakeyaml-2.2-sources.jar"
18-
},
19-
{
20-
"jar": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-core/2.16.1/jackson-core-2.16.1.jar",
21-
"name": "Jackson core 2.16.1",
22-
"src": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-core/2.16.1/jackson-core-2.16.1-sources.jar"
23-
},
24-
{
25-
"jar": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-databind/2.16.1/jackson-databind-2.16.1.jar",
26-
"name": "Jackson databind 2.16.1",
27-
"src": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-databind/2.16.1/jackson-databind-2.16.1-sources.jar"
28-
},
29-
{
30-
"jar": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-annotations/2.16.1/jackson-annotations-2.16.1.jar",
31-
"name": "Jackson annotation 2.16.1",
32-
"src": "https://repo1.maven.org/maven2/com/fasterxml/jackson/core/jackson-annotations/2.16.1/jackson-annotations-2.16.1-sources.jar"
33-
},
34-
{
35-
"jar": "https://repo1.maven.org/maven2/ch/qos/logback/logback-classic/1.4.14/logback-classic-1.4.14.jar",
36-
"name": "Logback classic 1.4.14",
37-
"src": "https://repo1.maven.org/maven2/ch/qos/logback/logback-classic/1.4.14/logback-classic-1.4.14-sources.jar"
38-
},
39-
{
40-
"jar": "https://repo1.maven.org/maven2/ch/qos/logback/logback-core/1.4.14/logback-core-1.4.14.jar",
41-
"name": "Logback core 1.4.14",
42-
"src": "https://repo1.maven.org/maven2/ch/qos/logback/logback-core/1.4.14/logback-core-1.4.14-sources.jar"
43-
},
44-
{
45-
"jar": "https://repo1.maven.org/maven2/org/slf4j/slf4j-api/2.0.7/slf4j-api-2.0.7.jar",
46-
"name": "SLF4j API 2.0.7",
47-
"src": "https://repo1.maven.org/maven2/org/slf4j/slf4j-api/2.0.7/slf4j-api-2.0.7-sources.jar"
48-
},
49-
{
50-
"jar": "https://repo1.maven.org/maven2/org/apache/tomcat/tomcat-annotations-api/10.1.18/tomcat-annotations-api-10.1.18.jar",
51-
"name": "Tomcat annotations API 10.1.18",
52-
"src": "https://repo1.maven.org/maven2/org/apache/tomcat/tomcat-annotations-api/10.1.18/tomcat-annotations-api-10.1.18-sources.jar"
53-
},
54-
{
55-
"jar": "https://repo1.maven.org/maven2/org/apache/tomcat/embed/tomcat-embed-core/10.1.18/tomcat-embed-core-10.1.18.jar",
56-
"name": "Tomcat embed core API 10.1.1",
57-
"src": "https://repo1.maven.org/maven2/org/apache/tomcat/embed/tomcat-embed-core/10.1.18/tomcat-embed-core-10.1.18-sources.jar"
58-
},
59-
{
60-
"jar": "https://repo1.maven.org/maven2/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar",
61-
"name": "JSR305 3.0.2",
62-
"src": "https://repo1.maven.org/maven2/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2-sources.jar"
63-
},
64-
{
65-
"jar": "https://repo1.maven.org/maven2/org/jetbrains/annotations/13.0/annotations-13.0.jar",
66-
"name": "JSR305 3.0.2",
67-
"src": "https://repo1.maven.org/maven2/org/jetbrains/annotations/13.0/annotations-13.0-sources.jar"
68-
},
69-
{
70-
"jar": "https://repo1.maven.org/maven2/org/xerial/sqlite-jdbc/3.45.1.0/sqlite-jdbc-3.45.1.0.jar",
71-
"name": "SQLite JDBC Driver 3.45.1.0",
72-
"src": "https://repo1.maven.org/maven2/org/xerial/sqlite-jdbc/3.45.1.0/sqlite-jdbc-3.45.1.0-sources.jar"
73-
},
74-
{
75-
"jar": "https://repo1.maven.org/maven2/org/mindrot/jbcrypt/0.4/jbcrypt-0.4.jar",
76-
"name": "JBCrypt 0.4",
77-
"src": "https://repo1.maven.org/maven2/org/mindrot/jbcrypt/0.4/jbcrypt-0.4-sources.jar"
78-
},
79-
{
80-
"jar": "https://repo1.maven.org/maven2/com/auth0/java-jwt/4.4.0/java-jwt-4.4.0.jar",
81-
"name": "Auth0 Java JWT",
82-
"src": "https://repo1.maven.org/maven2/com/auth0/java-jwt/4.4.0/java-jwt-4.4.0-sources.jar"
83-
},
84-
{
85-
"jar": "https://repo1.maven.org/maven2/de/mkammerer/argon2-jvm/2.11/argon2-jvm-2.11.jar",
86-
"name": "Argon2-jvm 2.11",
87-
"src": "https://repo1.maven.org/maven2/de/mkammerer/argon2-jvm/2.11/argon2-jvm-2.11-sources.jar"
88-
},
89-
{
90-
"jar": "https://repo1.maven.org/maven2/de/mkammerer/argon2-jvm-nolibs/2.11/argon2-jvm-nolibs-2.11.jar",
91-
"name": "Argon2-jvm no libs 2.11",
92-
"src": "https://repo1.maven.org/maven2/de/mkammerer/argon2-jvm-nolibs/2.11/argon2-jvm-nolibs-2.11-sources.jar"
93-
},
94-
{
95-
"jar": "https://repo1.maven.org/maven2/net/java/dev/jna/jna/5.8.0/jna-5.8.0.jar",
96-
"name": "JNA 5.8.0",
97-
"src": "https://repo1.maven.org/maven2/net/java/dev/jna/jna/5.8.0/jna-5.8.0-sources.jar"
98-
},
99-
{
100-
"jar": "https://repo1.maven.org/maven2/com/lambdaworks/scrypt/1.4.0/scrypt-1.4.0.jar",
101-
"name": "Scrypt 1.4.0",
102-
"src": "https://repo1.maven.org/maven2/com/lambdaworks/scrypt/1.4.0/scrypt-1.4.0-sources.jar"
103-
},
104-
{
105-
"jar": "https://repo1.maven.org/maven2/com/eatthepath/java-otp/0.4.0/java-otp-0.4.0.jar",
106-
"name": "Java OTP 0.4.0",
107-
"src": "https://repo1.maven.org/maven2/com/eatthepath/java-otp/0.4.0/java-otp-0.4.0-sources.jar"
108-
},
109-
{
110-
"jar": "https://repo1.maven.org/maven2/commons-codec/commons-codec/1.15/commons-codec-1.15.jar",
111-
"name": "Commons Codec 1.15",
112-
"src": "https://repo1.maven.org/maven2/commons-codec/commons-codec/1.15/commons-codec-1.15-sources.jar"
113-
},
114-
{
115-
"jar": "https://repo1.maven.org/maven2/com/googlecode/libphonenumber/libphonenumber/8.13.25/libphonenumber-8.13.25.jar",
116-
"name": "Libphonenumber 8.13.25",
117-
"src": "https://repo1.maven.org/maven2/com/googlecode/libphonenumber/libphonenumber/8.13.25/libphonenumber-8.13.25-sources.jar"
118-
}
119-
]
2+
"_comment": "Contains list of implementation dependencies URL for this project. This is a generated file, don't modify the contents by hand.",
3+
"list": [
4+
{
5+
"jar":"https://repo.maven.apache.org/maven2/com/google/code/gson/gson/2.3.1/gson-2.3.1.jar",
6+
"name":"gson 2.3.1",
7+
"src":"https://repo.maven.apache.org/maven2/com/google/code/gson/gson/2.3.1/gson-2.3.1-sources.jar"
8+
},
9+
{
10+
"jar":"https://repo.maven.apache.org/maven2/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.16.1/jackson-dataformat-yaml-2.16.1.jar",
11+
"name":"jackson-dataformat-yaml 2.16.1",
12+
"src":"https://repo.maven.apache.org/maven2/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.16.1/jackson-dataformat-yaml-2.16.1-sources.jar"
13+
},
14+
{
15+
"jar":"https://repo.maven.apache.org/maven2/org/yaml/snakeyaml/2.2/snakeyaml-2.2.jar",
16+
"name":"snakeyaml 2.2",
17+
"src":"https://repo.maven.apache.org/maven2/org/yaml/snakeyaml/2.2/snakeyaml-2.2-sources.jar"
18+
},
19+
{
20+
"jar":"https://repo.maven.apache.org/maven2/com/fasterxml/jackson/core/jackson-databind/2.16.1/jackson-databind-2.16.1.jar",
21+
"name":"jackson-databind 2.16.1",
22+
"src":"https://repo.maven.apache.org/maven2/com/fasterxml/jackson/core/jackson-databind/2.16.1/jackson-databind-2.16.1-sources.jar"
23+
},
24+
{
25+
"jar":"https://repo.maven.apache.org/maven2/org/apache/tomcat/embed/tomcat-embed-core/10.1.18/tomcat-embed-core-10.1.18.jar",
26+
"name":"tomcat-embed-core 10.1.18",
27+
"src":"https://repo.maven.apache.org/maven2/org/apache/tomcat/embed/tomcat-embed-core/10.1.18/tomcat-embed-core-10.1.18-sources.jar"
28+
},
29+
{
30+
"jar":"https://repo.maven.apache.org/maven2/org/apache/tomcat/tomcat-annotations-api/10.1.18/tomcat-annotations-api-10.1.18.jar",
31+
"name":"tomcat-annotations-api 10.1.18",
32+
"src":"https://repo.maven.apache.org/maven2/org/apache/tomcat/tomcat-annotations-api/10.1.18/tomcat-annotations-api-10.1.18-sources.jar"
33+
},
34+
{
35+
"jar":"https://repo.maven.apache.org/maven2/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2.jar",
36+
"name":"jsr305 3.0.2",
37+
"src":"https://repo.maven.apache.org/maven2/com/google/code/findbugs/jsr305/3.0.2/jsr305-3.0.2-sources.jar"
38+
},
39+
{
40+
"jar":"https://repo.maven.apache.org/maven2/org/xerial/sqlite-jdbc/3.45.1.0/sqlite-jdbc-3.45.1.0.jar",
41+
"name":"sqlite-jdbc 3.45.1.0",
42+
"src":"https://repo.maven.apache.org/maven2/org/xerial/sqlite-jdbc/3.45.1.0/sqlite-jdbc-3.45.1.0-sources.jar"
43+
},
44+
{
45+
"jar":"https://repo.maven.apache.org/maven2/org/slf4j/slf4j-api/2.0.17/slf4j-api-2.0.17.jar",
46+
"name":"slf4j-api 2.0.17",
47+
"src":"https://repo.maven.apache.org/maven2/org/slf4j/slf4j-api/2.0.17/slf4j-api-2.0.17-sources.jar"
48+
},
49+
{
50+
"jar":"https://repo.maven.apache.org/maven2/org/mindrot/jbcrypt/0.4/jbcrypt-0.4.jar",
51+
"name":"jbcrypt 0.4",
52+
"src":"https://repo.maven.apache.org/maven2/org/mindrot/jbcrypt/0.4/jbcrypt-0.4-sources.jar"
53+
},
54+
{
55+
"jar":"https://repo.maven.apache.org/maven2/org/jetbrains/annotations/13.0/annotations-13.0.jar",
56+
"name":"annotations 13.0",
57+
"src":"https://repo.maven.apache.org/maven2/org/jetbrains/annotations/13.0/annotations-13.0-sources.jar"
58+
},
59+
{
60+
"jar":"https://repo.maven.apache.org/maven2/de/mkammerer/argon2-jvm/2.11/argon2-jvm-2.11.jar",
61+
"name":"argon2-jvm 2.11",
62+
"src":"https://repo.maven.apache.org/maven2/de/mkammerer/argon2-jvm/2.11/argon2-jvm-2.11-sources.jar"
63+
},
64+
{
65+
"jar":"https://repo.maven.apache.org/maven2/com/auth0/java-jwt/4.4.0/java-jwt-4.4.0.jar",
66+
"name":"java-jwt 4.4.0",
67+
"src":"https://repo.maven.apache.org/maven2/com/auth0/java-jwt/4.4.0/java-jwt-4.4.0-sources.jar"
68+
},
69+
{
70+
"jar":"https://repo.maven.apache.org/maven2/com/lambdaworks/scrypt/1.4.0/scrypt-1.4.0.jar",
71+
"name":"scrypt 1.4.0",
72+
"src":"https://repo.maven.apache.org/maven2/com/lambdaworks/scrypt/1.4.0/scrypt-1.4.0-sources.jar"
73+
},
74+
{
75+
"jar":"https://repo.maven.apache.org/maven2/com/eatthepath/java-otp/0.4.0/java-otp-0.4.0.jar",
76+
"name":"java-otp 0.4.0",
77+
"src":"https://repo.maven.apache.org/maven2/com/eatthepath/java-otp/0.4.0/java-otp-0.4.0-sources.jar"
78+
},
79+
{
80+
"jar":"https://repo.maven.apache.org/maven2/commons-codec/commons-codec/1.15/commons-codec-1.15.jar",
81+
"name":"commons-codec 1.15",
82+
"src":"https://repo.maven.apache.org/maven2/commons-codec/commons-codec/1.15/commons-codec-1.15-sources.jar"
83+
},
84+
{
85+
"jar":"https://repo.maven.apache.org/maven2/com/googlecode/libphonenumber/libphonenumber/8.13.25/libphonenumber-8.13.25.jar",
86+
"name":"libphonenumber 8.13.25",
87+
"src":"https://repo.maven.apache.org/maven2/com/googlecode/libphonenumber/libphonenumber/8.13.25/libphonenumber-8.13.25-sources.jar"
88+
},
89+
{
90+
"jar":"https://repo.maven.apache.org/maven2/ch/qos/logback/logback-core/1.5.18/logback-core-1.5.18.jar",
91+
"name":"logback-core 1.5.18",
92+
"src":"https://repo.maven.apache.org/maven2/ch/qos/logback/logback-core/1.5.18/logback-core-1.5.18-sources.jar"
93+
},
94+
{
95+
"jar":"https://repo.maven.apache.org/maven2/ch/qos/logback/logback-classic/1.5.18/logback-classic-1.5.18.jar",
96+
"name":"logback-classic 1.5.18",
97+
"src":"https://repo.maven.apache.org/maven2/ch/qos/logback/logback-classic/1.5.18/logback-classic-1.5.18-sources.jar"
98+
},
99+
{
100+
"jar":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-api/1.51.0/opentelemetry-api-1.51.0.jar",
101+
"name":"opentelemetry-api 1.51.0",
102+
"src":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-api/1.51.0/opentelemetry-api-1.51.0-sources.jar"
103+
},
104+
{
105+
"jar":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-exporter-logging/1.51.0/opentelemetry-exporter-logging-1.51.0.jar",
106+
"name":"opentelemetry-exporter-logging 1.51.0",
107+
"src":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-exporter-logging/1.51.0/opentelemetry-exporter-logging-1.51.0-sources.jar"
108+
},
109+
{
110+
"jar":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-sdk/1.51.0/opentelemetry-sdk-1.51.0.jar",
111+
"name":"opentelemetry-sdk 1.51.0",
112+
"src":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-sdk/1.51.0/opentelemetry-sdk-1.51.0-sources.jar"
113+
},
114+
{
115+
"jar":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-exporter-otlp/1.51.0/opentelemetry-exporter-otlp-1.51.0.jar",
116+
"name":"opentelemetry-exporter-otlp 1.51.0",
117+
"src":"https://repo.maven.apache.org/maven2/io/opentelemetry/opentelemetry-exporter-otlp/1.51.0/opentelemetry-exporter-otlp-1.51.0-sources.jar"
118+
},
119+
{
120+
"jar":"https://repo.maven.apache.org/maven2/io/opentelemetry/semconv/opentelemetry-semconv/1.34.0/opentelemetry-semconv-1.34.0.jar",
121+
"name":"opentelemetry-semconv 1.34.0",
122+
"src":"https://repo.maven.apache.org/maven2/io/opentelemetry/semconv/opentelemetry-semconv/1.34.0/opentelemetry-semconv-1.34.0-sources.jar"
123+
}
124+
]
120125
}

‎src/main/java/io/supertokens/Main.java‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import io.supertokens.pluginInterface.exceptions.StorageQueryException;
4343
import io.supertokens.pluginInterface.multitenancy.TenantIdentifier;
4444
import io.supertokens.storageLayer.StorageLayer;
45+
import io.supertokens.telemetry.TelemetryProvider;
4546
import io.supertokens.version.Version;
4647
import io.supertokens.webserver.Webserver;
4748
import org.jetbrains.annotations.TestOnly;
@@ -162,6 +163,8 @@ private void init() throws IOException, StorageQueryException {
162163

163164
Logging.info(this, TenantIdentifier.BASE_TENANT, "Completed config.yaml loading.", true);
164165

166+
TelemetryProvider.initialize(this);
167+
165168
// loading storage layer
166169
try {
167170
StorageLayer.initPrimary(this, CLIOptions.get(this).getInstallationPath() + "plugin/",
@@ -433,6 +436,7 @@ private void stopApp() {
433436
StorageLayer.close(this);
434437
removeDotStartedFileForThisProcess();
435438
Logging.stopLogging(this);
439+
TelemetryProvider.closeTelemetry(this);
436440
// uncomment this when you want to confirm that processes are actually shut.
437441
// printRunningThreadNames();
438442

‎src/main/java/io/supertokens/config/CoreConfig.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,15 @@ public static void setDisableOAuthValidationForTest(boolean val) {
361361
disableOAuthValidationForTest = val;
362362
}
363363

364+
@ConfigYamlOnly
365+
@JsonProperty
366+
@ConfigDescription(
367+
"The URL of the OpenTelemetry collector to which the core will send telemetry data. " +
368+
"This should be in the format http://<host>:<port> or https://<host>:<port>. (Default: " +
369+
"http://localhost:4317)")
370+
private String otel_collector_connection_uri = "http://localhost:4317";
371+
372+
364373
public static Set<String> getValidFields() {
365374
CoreConfig coreConfig = new CoreConfig();
366375
JsonObject coreConfigObj = new GsonBuilder().serializeNulls().create().toJsonTree(coreConfig).getAsJsonObject();
@@ -589,6 +598,10 @@ public int getBulkMigrationParallelism() {
589598
return bulk_migration_parallelism;
590599
}
591600

601+
public String getOtelCollectorConnectionURI() {
602+
return otel_collector_connection_uri;
603+
}
604+
592605
private String getConfigFileLocation(Main main) {
593606
return new File(CLIOptions.get(main).getConfigFilePath() == null
594607
? CLIOptions.get(main).getInstallationPath() + "config.yaml"

0 commit comments

Comments
 (0)