com.launchdarkly.sdk.server.integrations

Class FDv2StreamingSynchronizerBuilder

java.lang.Object

com.launchdarkly.sdk.server.integrations.FDv2StreamingSynchronizerBuilder

All Implemented Interfaces:

DataSourceBuilder<Synchronizer>, DiagnosticDescription

public abstract class FDv2StreamingSynchronizerBuilder
extends java.lang.Object
implements DataSourceBuilder<Synchronizer>, DiagnosticDescription

Contains methods for configuring the streaming synchronizer.

This class is not stable, and not subject to any backwards compatibility guarantees or semantic versioning. It is in early access. If you want access to this feature please join the EAP. https://launchdarkly.com/docs/sdk/features/data-saving-mode

Example:

     LDConfig config = new LDConfig.Builder("my-sdk-key")
         .dataSystem(Components.dataSystem().custom()
             .initializers(DataSystemComponents.pollingInitializer())
             // DataSystemComponents.streamingSynchronizer() returns an instance of this builder.
             .synchronizers(DataSystemComponents.streamingSynchronizer()
                 .initialReconnectDelay(Duration.ofSeconds(5)), DataSystemComponents.pollingSynchronizer())
             .fDv1FallbackSynchronizer(DataSystemComponents.fDv1Polling()));
 

Field Summary

Fields

Modifier and Type	Field and Description
static java.time.Duration	DEFAULT_INITIAL_RECONNECT_DELAY The default value for initialReconnectDelay(Duration): 1000 milliseconds.
protected java.time.Duration	initialReconnectDelay
protected java.lang.String	payloadFilter
protected ServiceEndpoints	serviceEndpointsOverride

Constructor Summary

Constructors

Constructor and Description
FDv2StreamingSynchronizerBuilder()

Method Summary

Modifier and Type	Method and Description
LDValue	describeConfiguration(ClientContext context) Used internally by the SDK to inspect the configuration.
FDv2StreamingSynchronizerBuilder	initialReconnectDelay(java.time.Duration initialReconnectDelay) Sets the initial reconnect delay for the streaming connection.
FDv2StreamingSynchronizerBuilder	payloadFilter(java.lang.String payloadFilter) Sets the Payload Filter that will be used to filter the objects (flags, segments, etc.) from this synchronizer.
FDv2StreamingSynchronizerBuilder	serviceEndpointsOverride(ServiceEndpointsBuilder serviceEndpointsOverride) Sets overrides for the service endpoints.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.launchdarkly.sdk.server.subsystems.DataSourceBuilder

build

Field Detail

DEFAULT_INITIAL_RECONNECT_DELAY

public static final java.time.Duration DEFAULT_INITIAL_RECONNECT_DELAY

The default value for initialReconnectDelay(Duration): 1000 milliseconds.

initialReconnectDelay

protected java.time.Duration initialReconnectDelay

serviceEndpointsOverride

protected ServiceEndpoints serviceEndpointsOverride

payloadFilter

protected java.lang.String payloadFilter

Constructor Detail

FDv2StreamingSynchronizerBuilder

public FDv2StreamingSynchronizerBuilder()

Method Detail

initialReconnectDelay

public FDv2StreamingSynchronizerBuilder initialReconnectDelay(java.time.Duration initialReconnectDelay)

Sets the initial reconnect delay for the streaming connection.

The streaming service uses a backoff algorithm (with jitter) every time the connection needs to be reestablished. The delay for the first reconnection will start near this value, and then increase exponentially for any subsequent connection failures.

The default value is DEFAULT_INITIAL_RECONNECT_DELAY.

Parameters:

initialReconnectDelay - the reconnect time base value

Returns:

the builder

serviceEndpointsOverride

public FDv2StreamingSynchronizerBuilder serviceEndpointsOverride(ServiceEndpointsBuilder serviceEndpointsOverride)

Sets overrides for the service endpoints. In typical usage, the synchronizer will use the commonly defined service endpoints, but for cases where they need to be controlled at the source level, this method can be used. This synchronizer will only use the endpoints applicable to it.

Parameters:

serviceEndpointsOverride - the service endpoints to override the base endpoints

Returns:

the builder

payloadFilter

public FDv2StreamingSynchronizerBuilder payloadFilter(java.lang.String payloadFilter)

Sets the Payload Filter that will be used to filter the objects (flags, segments, etc.) from this synchronizer.

Parameters:

payloadFilter - the filter to be used

Returns:

the builder

describeConfiguration

public LDValue describeConfiguration(ClientContext context)

Description copied from interface: DiagnosticDescription

Used internally by the SDK to inspect the configuration.

Specified by:

describeConfiguration in interface DiagnosticDescription

Parameters:

context - allows access to the client configuration

Returns:

an LDValue or null