public class HttpRemoteConfigurationSource extends PollingRemoteConfigurationSource
Modifier and Type | Field and Description |
---|---|
static String |
V1_CONFIGURATION_ENDPOINT |
Constructor and Description |
---|
HttpRemoteConfigurationSource(io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.confluent.telemetry.config.remote.RemoteConfigurationRequest,io.confluent.telemetry.config.remote.RemoteConfigurationResponse> builder,
long refreshIntervalMs,
Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback,
io.opentelemetry.proto.resource.v1.Resource resource) |
Modifier and Type | Method and Description |
---|---|
void |
setCredentials(io.confluent.telemetry.client.Credentials credentials) |
void |
setProxyConfig(io.confluent.telemetry.client.ProxyConfig proxyConfig) |
void |
stop() |
getConfig, setConfigurationChangeCallback, start
public static final String V1_CONFIGURATION_ENDPOINT
public HttpRemoteConfigurationSource(io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.confluent.telemetry.config.remote.RemoteConfigurationRequest,io.confluent.telemetry.config.remote.RemoteConfigurationResponse> builder, long refreshIntervalMs, Consumer<io.confluent.telemetry.config.remote.v1.RemoteConfiguration> callback, io.opentelemetry.proto.resource.v1.Resource resource)
public void stop()
stop
in interface RemoteConfigurationSource
stop
in class PollingRemoteConfigurationSource
public void setCredentials(io.confluent.telemetry.client.Credentials credentials)
public void setProxyConfig(io.confluent.telemetry.client.ProxyConfig proxyConfig)