Skip to content

Commit 861071c

Browse files
aaron-steinfeldaaron-steinfeld
authored
chore: add support to disable introspection (#173)
1 parent 650d591 commit 861071c

File tree

35 files changed

+182
-138
lines changed

35 files changed

+182
-138
lines changed

‎hypertrace-core-graphql-attribute-scope-constants/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,6 @@
33
# This file is expected to be part of source control.
44
com.fasterxml.jackson:jackson-bom:2.16.1=compileClasspath,runtimeClasspath
55
io.grpc:grpc-bom:1.60.0=compileClasspath,runtimeClasspath
6-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
6+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
77
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath
88
empty=annotationProcessor

‎hypertrace-core-graphql-attribute-scope/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4949
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
5050
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5151
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
52-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
52+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5353
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5454
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5555
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-attribute-store/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4747
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
4848
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
4949
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
50-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
50+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5151
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=compileClasspath,runtimeClasspath
5252
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=compileClasspath,runtimeClasspath
5353
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=compileClasspath,runtimeClasspath

‎hypertrace-core-graphql-common-schema/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4949
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
5050
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5151
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
52-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
52+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5353
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5454
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5555
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-context/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ javax.servlet:javax.servlet-api:4.0.1=compileClasspath,runtimeClasspath
2828
javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
2929
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
3030
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
31-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
31+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
3232
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath
3333
org.projectlombok:lombok:1.18.28=annotationProcessor
3434
org.projectlombok:lombok:1.18.30=compileClasspath

‎hypertrace-core-graphql-context/src/main/java/org/hypertrace/core/graphql/context/AsyncDataFetcherFactory.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,36 +12,36 @@
1212
import javax.inject.Inject;
1313
import javax.inject.Singleton;
1414
import lombok.AllArgsConstructor;
15-
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
15+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
1616

1717
@Singleton
1818
class AsyncDataFetcherFactory {
1919

2020
private final Injector injector;
21-
private final GraphQlServiceConfig config;
21+
private final GraphQlEndpointConfig endpointConfig;
2222
private final ExecutorService requestExecutor;
2323

2424
@Inject
25-
AsyncDataFetcherFactory(Injector injector, GraphQlServiceConfig config) {
25+
AsyncDataFetcherFactory(Injector injector, GraphQlEndpointConfig endpointConfig) {
2626
this.injector = injector;
27-
this.config = config;
27+
this.endpointConfig = endpointConfig;
2828
this.requestExecutor =
2929
Executors.newFixedThreadPool(
30-
config.getMaxRequestThreads(),
30+
endpointConfig.getMaxRequestThreads(),
3131
new ThreadFactoryBuilder().setDaemon(true).setNameFormat("request-handler-%d").build());
3232
}
3333

3434
<T> DataFetcher<CompletableFuture<T>> buildDataFetcher(
3535
Class<? extends DataFetcher<CompletableFuture<T>>> dataFetcherClass) {
3636
return new AsyncForwardingDataFetcher<>(
37-
this.injector.getInstance(dataFetcherClass), requestExecutor, config);
37+
this.injector.getInstance(dataFetcherClass), requestExecutor, endpointConfig);
3838
}
3939

4040
@AllArgsConstructor
4141
private static class AsyncForwardingDataFetcher<T> implements DataFetcher<CompletableFuture<T>> {
4242
private final DataFetcher<CompletableFuture<T>> delegate;
4343
private final ExecutorService executorService;
44-
private final GraphQlServiceConfig config;
44+
private final GraphQlEndpointConfig config;
4545

4646
@Override
4747
public CompletableFuture<T> get(DataFetchingEnvironment dataFetchingEnvironment)
@@ -52,7 +52,7 @@ public CompletableFuture<T> get(DataFetchingEnvironment dataFetchingEnvironment)
5252
try {
5353
return delegate
5454
.get(dataFetchingEnvironment)
55-
.get(config.getGraphQlTimeout().toMillis(), MILLISECONDS);
55+
.get(config.getTimeout().toMillis(), MILLISECONDS);
5656
} catch (Exception e) {
5757
throw new RuntimeException(e);
5858
}

‎hypertrace-core-graphql-context/src/test/java/org/hypertrace/core/graphql/context/AsyncDataFetcherFactoryTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,22 +7,22 @@
77
import graphql.schema.DataFetcher;
88
import graphql.schema.DataFetchingEnvironment;
99
import java.util.concurrent.CompletableFuture;
10-
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
10+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
1111
import org.junit.jupiter.api.Test;
1212
import org.junit.jupiter.api.extension.ExtendWith;
1313
import org.mockito.Mock;
1414
import org.mockito.junit.jupiter.MockitoExtension;
1515

1616
@ExtendWith(MockitoExtension.class)
1717
class AsyncDataFetcherFactoryTest {
18-
@Mock GraphQlServiceConfig graphQlServiceConfig;
18+
@Mock GraphQlEndpointConfig endpointConfig;
1919
@Mock DataFetchingEnvironment dataFetchingEnvironment;
2020

2121
@Test
2222
void canBuildAsyncDataFetcher() throws Exception {
23-
when(graphQlServiceConfig.getMaxRequestThreads()).thenReturn(1);
23+
when(endpointConfig.getMaxRequestThreads()).thenReturn(1);
2424
DataFetcher<CompletableFuture<Thread>> fetcher =
25-
new AsyncDataFetcherFactory(Guice.createInjector(), graphQlServiceConfig)
25+
new AsyncDataFetcherFactory(Guice.createInjector(), endpointConfig)
2626
.buildDataFetcher(ThreadEchoingDataFetcher.class);
2727

2828
Thread fetcherThread = fetcher.get(dataFetchingEnvironment).get();

‎hypertrace-core-graphql-deserialization/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ io.grpc:grpc-bom:1.60.0=compileClasspath,runtimeClasspath
2222
jakarta.inject:jakarta.inject-api:2.0.1=compileClasspath,runtimeClasspath
2323
javax.inject:javax.inject:1=compileClasspath,runtimeClasspath
2424
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
25-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
25+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
2626
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath
2727
org.projectlombok:lombok:1.18.28=annotationProcessor
2828
org.projectlombok:lombok:1.18.30=compileClasspath

‎hypertrace-core-graphql-gateway-service-utils/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4848
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
4949
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5050
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
51-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
51+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5252
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5353
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5454
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-grpc-utils/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4242
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
4343
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
4444
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
45-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
45+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
4646
org.hypertrace.core.grpcutils:grpc-client-utils:0.13.1=compileClasspath,runtimeClasspath
4747
org.hypertrace.core.grpcutils:grpc-context-utils:0.13.1=compileClasspath,runtimeClasspath
4848
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath

‎hypertrace-core-graphql-impl/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ org.apache.commons:commons-lang3:3.12.0=runtimeClasspath
5252
org.apache.commons:commons-text:1.10.0=runtimeClasspath
5353
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5454
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
55-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
55+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5656
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5757
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5858
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-impl/src/main/java/org/hypertrace/core/graphql/impl/GraphQlFactory.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -5,21 +5,24 @@
55
import graphql.kickstart.servlet.GraphQLConfiguration;
66
import graphql.schema.GraphQLSchema;
77
import org.hypertrace.core.graphql.context.GraphQlRequestContextBuilder;
8+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
89
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
910
import org.hypertrace.core.graphql.spi.lifecycle.GraphQlServiceLifecycle;
1011
import org.hypertrace.core.grpcutils.client.GrpcChannelRegistry;
1112

1213
public class GraphQlFactory {
1314
public static GraphQLConfiguration build(
14-
GraphQlServiceConfig config,
15+
GraphQlServiceConfig serviceConfig,
16+
GraphQlEndpointConfig endpointConfig,
1517
GraphQlServiceLifecycle lifecycle,
1618
GrpcChannelRegistry grpcChannelRegistry) {
1719
final Injector injector =
18-
Guice.createInjector(new GraphQlModule(config, lifecycle, grpcChannelRegistry));
20+
Guice.createInjector(
21+
new GraphQlModule(serviceConfig, endpointConfig, lifecycle, grpcChannelRegistry));
1922

2023
return GraphQLConfiguration.with(injector.getInstance(GraphQLSchema.class))
2124
.with(injector.getInstance(GraphQlRequestContextBuilder.class))
22-
.asyncTimeout(config.getGraphQlTimeout().toMillis())
25+
.asyncTimeout(endpointConfig.getTimeout().toMillis())
2326
.build();
2427
}
2528
}

‎hypertrace-core-graphql-impl/src/main/java/org/hypertrace/core/graphql/impl/GraphQlModule.java

Lines changed: 9 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import org.hypertrace.core.graphql.rx.RxUtilModule;
1414
import org.hypertrace.core.graphql.schema.registry.GraphQlSchemaRegistryModule;
1515
import org.hypertrace.core.graphql.span.SpanSchemaModule;
16+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
1617
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
1718
import org.hypertrace.core.graphql.spi.lifecycle.GraphQlServiceLifecycle;
1819
import org.hypertrace.core.graphql.trace.TraceSchemaModule;
@@ -23,22 +24,26 @@
2324

2425
class GraphQlModule extends AbstractModule {
2526

26-
private final GraphQlServiceConfig config;
27+
private final GraphQlServiceConfig serviceConfig;
28+
private final GraphQlEndpointConfig endpointConfig;
2729
private final GraphQlServiceLifecycle lifecycle;
2830
private final GrpcChannelRegistry grpcChannelRegistry;
2931

3032
public GraphQlModule(
31-
final GraphQlServiceConfig config,
33+
final GraphQlServiceConfig serviceConfig,
34+
final GraphQlEndpointConfig endpointConfig,
3235
final GraphQlServiceLifecycle lifecycle,
3336
final GrpcChannelRegistry grpcChannelRegistry) {
34-
this.config = config;
37+
this.serviceConfig = serviceConfig;
38+
this.endpointConfig = endpointConfig;
3539
this.lifecycle = lifecycle;
3640
this.grpcChannelRegistry = grpcChannelRegistry;
3741
}
3842

3943
@Override
4044
protected void configure() {
41-
bind(GraphQlServiceConfig.class).toInstance(this.config);
45+
bind(GraphQlServiceConfig.class).toInstance(this.serviceConfig);
46+
bind(GraphQlEndpointConfig.class).toInstance(this.endpointConfig);
4247
bind(GraphQlServiceLifecycle.class).toInstance(this.lifecycle);
4348
bind(GrpcChannelRegistry.class).toInstance(this.grpcChannelRegistry);
4449
install(new GraphQlRequestContextModule());

‎hypertrace-core-graphql-impl/src/test/java/org/hypertrace/core/graphql/impl/GraphQlModuleTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55

66
import com.google.inject.Guice;
77
import graphql.schema.GraphQLSchema;
8+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
89
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
910
import org.hypertrace.core.graphql.spi.lifecycle.GraphQlServiceLifecycle;
1011
import org.hypertrace.core.grpcutils.client.GrpcChannelRegistry;
@@ -19,6 +20,7 @@ public void testResolveBindings() {
1920
Guice.createInjector(
2021
new GraphQlModule(
2122
mock(GraphQlServiceConfig.class),
23+
mock(GraphQlEndpointConfig.class),
2224
mock(GraphQlServiceLifecycle.class),
2325
mock(GrpcChannelRegistry.class)))
2426
.getAllBindings());
@@ -31,6 +33,7 @@ public void testResolveSchema() {
3133
Guice.createInjector(
3234
new GraphQlModule(
3335
mock(GraphQlServiceConfig.class),
36+
mock(GraphQlEndpointConfig.class),
3437
mock(GraphQlServiceLifecycle.class),
3538
mock(GrpcChannelRegistry.class)))
3639
.getInstance(GraphQLSchema.class));

‎hypertrace-core-graphql-log-event-schema/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
5050
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
5151
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5252
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
53-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
53+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5454
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5555
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5656
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-metadata-schema/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4949
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
5050
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5151
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
52-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
52+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5353
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5454
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5555
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-request-transformation/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
4949
javax.websocket:javax.websocket-api:1.1=compileClasspath,runtimeClasspath
5050
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
5151
org.codehaus.mojo:animal-sniffer-annotations:1.23=runtimeClasspath
52-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
52+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
5353
org.hypertrace.core.attribute.service:attribute-service-api:0.14.35=runtimeClasspath
5454
org.hypertrace.core.attribute.service:caching-attribute-service-client:0.14.35=runtimeClasspath
5555
org.hypertrace.core.grpcutils:grpc-client-rx-utils:0.13.1=runtimeClasspath

‎hypertrace-core-graphql-rx-utils/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ jakarta.inject:jakarta.inject-api:2.0.1=compileClasspath,runtimeClasspath
2121
javax.inject:javax.inject:1=compileClasspath,runtimeClasspath
2222
javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
2323
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
24-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
24+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
2525
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath
2626
org.reactivestreams:reactive-streams:1.0.4=compileClasspath,runtimeClasspath
2727
org.slf4j:slf4j-api:2.0.7=compileClasspath,runtimeClasspath

‎hypertrace-core-graphql-rx-utils/src/main/java/org/hypertrace/core/graphql/rx/BoundedIoSchedulerProvider.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import java.util.concurrent.ThreadFactory;
99
import javax.inject.Inject;
1010
import javax.inject.Provider;
11-
import org.hypertrace.core.graphql.spi.config.GraphQlServiceConfig;
11+
import org.hypertrace.core.graphql.spi.config.GraphQlEndpointConfig;
1212

1313
/**
1414
* A scheduler using up to a configuration-based number of threads.
@@ -19,11 +19,11 @@
1919
class BoundedIoSchedulerProvider implements Provider<Scheduler> {
2020

2121
private final Scheduler scheduler;
22-
private final GraphQlServiceConfig serviceConfig;
22+
private final GraphQlEndpointConfig endpointConfig;
2323

2424
@Inject
25-
BoundedIoSchedulerProvider(GraphQlServiceConfig serviceConfig) {
26-
this.serviceConfig = serviceConfig;
25+
BoundedIoSchedulerProvider(GraphQlEndpointConfig endpointConfig) {
26+
this.endpointConfig = endpointConfig;
2727
this.scheduler = Schedulers.from(this.buildExecutor());
2828
}
2929

@@ -34,7 +34,7 @@ public Scheduler get() {
3434

3535
private Executor buildExecutor() {
3636
return Executors.newFixedThreadPool(
37-
this.serviceConfig.getMaxIoThreads(), this.buildThreadFactory());
37+
this.endpointConfig.getMaxIoThreads(), this.buildThreadFactory());
3838
}
3939

4040
private ThreadFactory buildThreadFactory() {

‎hypertrace-core-graphql-schema-registry/gradle.lockfile

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ jakarta.inject:jakarta.inject-api:2.0.1=compileClasspath,runtimeClasspath
2020
javax.inject:javax.inject:1=compileClasspath,runtimeClasspath
2121
javax.validation:validation-api:1.1.0.Final=compileClasspath,runtimeClasspath
2222
org.checkerframework:checker-qual:3.33.0=compileClasspath,runtimeClasspath
23-
org.hypertrace.bom:hypertrace-bom:0.3.17=compileClasspath,runtimeClasspath
23+
org.hypertrace.bom:hypertrace-bom:0.3.18=compileClasspath,runtimeClasspath
2424
org.hypertrace.core.kafkastreams.framework:kafka-bom:0.4.7=compileClasspath,runtimeClasspath
2525
org.reactivestreams:reactive-streams:1.0.3=compileClasspath,runtimeClasspath
2626
org.slf4j:slf4j-api:2.0.7=compileClasspath,runtimeClasspath

0 commit comments

Comments
 (0)