Package 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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	V1_CONFIGURATION_ENDPOINT

Constructor Summary

Constructors

Constructor	Description
HttpRemoteConfigurationSource(io.confluent.telemetry.client.TelemetryHttpClient.Builder<io.confluent.telemetry.config.v2.remote.RemoteConfigurationRequest,io.confluent.telemetry.config.v2.remote.RemoteConfigurationResponse> builder, long refreshIntervalMs, Consumer<io.confluent.telemetry.config.v2.remote.RemoteConfiguration> callback, io.opentelemetry.proto.resource.v1.Resource resource)

Method Summary

Modifier and Type	Method	Description
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

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

Field Details

V1_CONFIGURATION_ENDPOINT

public static final String V1_CONFIGURATION_ENDPOINT

See Also:

• Constant Field Values

Constructor Details

HttpRemoteConfigurationSource

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

Method Details

stop

public void stop()

Specified by:

stop in interface RemoteConfigurationSource

Overrides:

stop in class PollingRemoteConfigurationSource

setCredentials

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

setProxyConfig

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