io.confluent.telemetry.config.remote.polling

Class HttpRemoteConfigurationSource

java.lang.Object

io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

io.confluent.telemetry.config.remote.polling.HttpRemoteConfigurationSource

All Implemented Interfaces:

RemoteConfigurationSource

public class HttpRemoteConfigurationSource
extends PollingRemoteConfigurationSource

Constructor Summary

Constructors

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, io.opentelemetry.proto.resource.v1.Resource resource)

Method Summary

Modifier and Type	Method and Description
protected Optional<io.confluent.telemetry.config.remote.RemoteConfigurationResponse>	requestConfig()
void	setCredentials(io.confluent.telemetry.client.Credentials credentials)
void	setProxyConfig(io.confluent.telemetry.client.ProxyConfig proxyConfig)
void	stop()

Methods inherited from class io.confluent.telemetry.config.remote.polling.PollingRemoteConfigurationSource

getConfig, setConfigurationChangeCallback, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpRemoteConfigurationSource

public HttpRemoteConfigurationSource(io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.confluent.telemetry.config.remote.RemoteConfigurationRequest,io.confluent.telemetry.config.remote.RemoteConfigurationResponse> builder,
                                     long refreshIntervalMs,
                                     io.opentelemetry.proto.resource.v1.Resource resource)

Method Detail

stop

public void stop()

Specified by:

stop in interface RemoteConfigurationSource

Overrides:

stop in class PollingRemoteConfigurationSource

requestConfig

protected Optional<io.confluent.telemetry.config.remote.RemoteConfigurationResponse> requestConfig()

Specified by:

requestConfig in class PollingRemoteConfigurationSource

setCredentials

public void setCredentials(io.confluent.telemetry.client.Credentials credentials)

setProxyConfig

public void setProxyConfig(io.confluent.telemetry.client.ProxyConfig proxyConfig)