Package com.launchdarkly.sdk.server.integrations.reactor

Class LDReactorClient

java.lang.Object

com.launchdarkly.sdk.server.integrations.reactor.LDReactorClient

All Implemented Interfaces:

LDReactorClientInterface

public final class LDReactorClient
extends java.lang.Object
implements LDReactorClientInterface

A thin wrapper of the LDClient that aims to adapt it to reactive stream programming. Methods that are potentially long running or that use IO have been wrapped to return Monos and will be executed on the scheduler provided. Methods that do not have a risk of blocking have not been wrapped and are pass through.

Constructor Summary

Constructors

Constructor	Description
LDReactorClient(java.lang.String sdkKey, LDConfig config, reactor.core.scheduler.Scheduler scheduler)	Creates a client that uses the provided scheduler to execute functionality in a non-blocking manner.
LDReactorClient(java.lang.String sdkKey, reactor.core.scheduler.Scheduler scheduler)	Creates a client that uses the provided scheduler to execute functionality in a non-blocking manner.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<FeatureFlagsState>	allFlagsState(LDContext context, FlagsStateOption... options)	See LDClient.allFlagsState(LDContext, FlagsStateOption...).
reactor.core.publisher.Mono<java.lang.Boolean>	boolVariation(java.lang.String featureKey, LDContext context, boolean defaultValue)	See LDClient.boolVariation(String, LDContext, boolean).
reactor.core.publisher.Mono<EvaluationDetail<java.lang.Boolean>>	boolVariationDetail(java.lang.String featureKey, LDContext context, boolean defaultValue)	See LDClient.boolVariationDetail(String, LDContext, boolean).
reactor.core.publisher.Mono<java.lang.Void>	close()	See LDClient.close().
reactor.core.publisher.Mono<java.lang.Double>	doubleVariation(java.lang.String featureKey, LDContext context, double defaultValue)	See LDClient.doubleVariation(String, LDContext, double)
reactor.core.publisher.Mono<EvaluationDetail<java.lang.Double>>	doubleVariationDetail(java.lang.String featureKey, LDContext context, double defaultValue)	See LDClient.doubleVariationDetail(String, LDContext, double).
void	flush()	See LDClient.flush().
BigSegmentStoreStatusProvider	getBigSegmentStoreStatusProvider()	See LDClient.getBigSegmentStoreStatusProvider().
DataSourceStatusProvider	getDataSourceStatusProvider()	See LDClient.getDataSourceStatusProvider().
DataStoreStatusProvider	getDataStoreStatusProvider()	See LDClient.getDataStoreStatusProvider().
FlagTracker	getFlagTracker()	See LDClient.getFlagTracker().
void	identify(LDContext context)	See LDClient.identify(LDContext).
reactor.core.publisher.Mono<java.lang.Integer>	intVariation(java.lang.String featureKey, LDContext context, int defaultValue)	See LDClient.intVariation(String, LDContext, int).
reactor.core.publisher.Mono<EvaluationDetail<java.lang.Integer>>	intVariationDetail(java.lang.String featureKey, LDContext context, int defaultValue)	See LDClient.intVariationDetail(String, LDContext, int).
boolean	isFlagKnown(java.lang.String featureKey)	See LDClient.isFlagKnown(String).
boolean	isInitialized()	See LDClient.isInitialized().
boolean	isOffline()	See LDClient.isOffline().
reactor.core.publisher.Mono<LDValue>	jsonValueVariation(java.lang.String featureKey, LDContext context, LDValue defaultValue)	See LDClient.jsonValueVariation(String, LDContext, LDValue).
reactor.core.publisher.Mono<EvaluationDetail<LDValue>>	jsonValueVariationDetail(java.lang.String featureKey, LDContext context, LDValue defaultValue)	See LDClient.jsonValueVariationDetail(String, LDContext, LDValue).
java.lang.String	secureModeHash(LDContext context)	See LDClient.secureModeHash(LDContext).
reactor.core.publisher.Mono<java.lang.String>	stringVariation(java.lang.String featureKey, LDContext context, java.lang.String defaultValue)	See LDClient.stringVariation(String, LDContext, String).
reactor.core.publisher.Mono<EvaluationDetail<java.lang.String>>	stringVariationDetail(java.lang.String featureKey, LDContext context, java.lang.String defaultValue)	See LDClient.stringVariationDetail(String, LDContext, String).
void	track(java.lang.String eventName, LDContext context)	See LDClient.track(String, LDContext).
void	trackData(java.lang.String eventName, LDContext context, LDValue data)	See LDClient.trackData(String, LDContext, LDValue).
void	trackMetric(java.lang.String eventName, LDContext context, LDValue data, double metricValue)	See LDClient.trackMetric(String, LDContext, LDValue, double).
java.lang.String	version()	See LDClient.version().

Methods inherited from class java.lang.Object

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

Constructor Detail

LDReactorClient

public LDReactorClient(java.lang.String sdkKey,
                       reactor.core.scheduler.Scheduler scheduler)

Creates a client that uses the provided scheduler to execute functionality in a non-blocking manner.

Parameters:

sdkKey - the SDK key for your LaunchDarkly environment

scheduler - that will execute wrapped client methods

LDReactorClient

public LDReactorClient(java.lang.String sdkKey,
                       LDConfig config,
                       reactor.core.scheduler.Scheduler scheduler)

Creates a client that uses the provided scheduler to execute functionality in a non-blocking manner.

Parameters:

sdkKey - the SDK key for your LaunchDarkly environment

config - a client configuration object

scheduler - that will execute wrapped client methods

Method Detail

isInitialized

public boolean isInitialized()

Description copied from interface: LDReactorClientInterface

See LDClient.isInitialized().

Specified by:

isInitialized in interface LDReactorClientInterface

Returns:

see linked reference.

track

public void track(java.lang.String eventName,
                  LDContext context)

Description copied from interface: LDReactorClientInterface

See LDClient.track(String, LDContext).

Specified by:

track in interface LDReactorClientInterface

Parameters:

eventName - see linked reference.

context - see linked reference.

trackData

public void trackData(java.lang.String eventName,
                      LDContext context,
                      LDValue data)

Description copied from interface: LDReactorClientInterface

See LDClient.trackData(String, LDContext, LDValue).

Specified by:

trackData in interface LDReactorClientInterface

Parameters:

eventName - see linked reference.

context - see linked reference.

data - see linked reference.

trackMetric

public void trackMetric(java.lang.String eventName,
                        LDContext context,
                        LDValue data,
                        double metricValue)

Description copied from interface: LDReactorClientInterface

See LDClient.trackMetric(String, LDContext, LDValue, double).

Specified by:

trackMetric in interface LDReactorClientInterface

Parameters:

eventName - see linked reference.

context - see linked reference.

data - see linked reference.

metricValue - see linked reference.

identify

public void identify(LDContext context)

Description copied from interface: LDReactorClientInterface

See LDClient.identify(LDContext).

Specified by:

identify in interface LDReactorClientInterface

Parameters:

context - see linked reference.

allFlagsState

public reactor.core.publisher.Mono<FeatureFlagsState> allFlagsState(LDContext context,
                                                                    FlagsStateOption... options)

Description copied from interface: LDReactorClientInterface

See LDClient.allFlagsState(LDContext, FlagsStateOption...).

Specified by:

allFlagsState in interface LDReactorClientInterface

Parameters:

context - see linked reference.

options - see linked reference.

Returns:

a Mono that will emit the FeatureFlagsState.

boolVariation

public reactor.core.publisher.Mono<java.lang.Boolean> boolVariation(java.lang.String featureKey,
                                                                    LDContext context,
                                                                    boolean defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.boolVariation(String, LDContext, boolean).

Specified by:

boolVariation in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

intVariation

public reactor.core.publisher.Mono<java.lang.Integer> intVariation(java.lang.String featureKey,
                                                                   LDContext context,
                                                                   int defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.intVariation(String, LDContext, int).

Specified by:

intVariation in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

doubleVariation

public reactor.core.publisher.Mono<java.lang.Double> doubleVariation(java.lang.String featureKey,
                                                                     LDContext context,
                                                                     double defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.doubleVariation(String, LDContext, double)

Specified by:

doubleVariation in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

stringVariation

public reactor.core.publisher.Mono<java.lang.String> stringVariation(java.lang.String featureKey,
                                                                     LDContext context,
                                                                     java.lang.String defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.stringVariation(String, LDContext, String).

Specified by:

stringVariation in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

jsonValueVariation

public reactor.core.publisher.Mono<LDValue> jsonValueVariation(java.lang.String featureKey,
                                                               LDContext context,
                                                               LDValue defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.jsonValueVariation(String, LDContext, LDValue).

Specified by:

jsonValueVariation in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

boolVariationDetail

public reactor.core.publisher.Mono<EvaluationDetail<java.lang.Boolean>> boolVariationDetail(java.lang.String featureKey,
                                                                                            LDContext context,
                                                                                            boolean defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.boolVariationDetail(String, LDContext, boolean).

Specified by:

boolVariationDetail in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

intVariationDetail

public reactor.core.publisher.Mono<EvaluationDetail<java.lang.Integer>> intVariationDetail(java.lang.String featureKey,
                                                                                           LDContext context,
                                                                                           int defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.intVariationDetail(String, LDContext, int).

Specified by:

intVariationDetail in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

doubleVariationDetail

public reactor.core.publisher.Mono<EvaluationDetail<java.lang.Double>> doubleVariationDetail(java.lang.String featureKey,
                                                                                             LDContext context,
                                                                                             double defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.doubleVariationDetail(String, LDContext, double).

Specified by:

doubleVariationDetail in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

stringVariationDetail

public reactor.core.publisher.Mono<EvaluationDetail<java.lang.String>> stringVariationDetail(java.lang.String featureKey,
                                                                                             LDContext context,
                                                                                             java.lang.String defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.stringVariationDetail(String, LDContext, String).

Specified by:

stringVariationDetail in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

jsonValueVariationDetail

public reactor.core.publisher.Mono<EvaluationDetail<LDValue>> jsonValueVariationDetail(java.lang.String featureKey,
                                                                                       LDContext context,
                                                                                       LDValue defaultValue)

Description copied from interface: LDReactorClientInterface

See LDClient.jsonValueVariationDetail(String, LDContext, LDValue).

Specified by:

jsonValueVariationDetail in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

context - see linked reference.

defaultValue - see linked reference.

Returns:

a Mono that will emit the evaluation result.

isFlagKnown

public boolean isFlagKnown(java.lang.String featureKey)

Description copied from interface: LDReactorClientInterface

See LDClient.isFlagKnown(String).

Specified by:

isFlagKnown in interface LDReactorClientInterface

Parameters:

featureKey - see linked reference.

Returns:

see linked reference.

getFlagTracker

public FlagTracker getFlagTracker()

Description copied from interface: LDReactorClientInterface

See LDClient.getFlagTracker().

Specified by:

getFlagTracker in interface LDReactorClientInterface

Returns:

see linked reference.

getBigSegmentStoreStatusProvider

public BigSegmentStoreStatusProvider getBigSegmentStoreStatusProvider()

Description copied from interface: LDReactorClientInterface

See LDClient.getBigSegmentStoreStatusProvider(). Getting the BigSegmentStoreStatusProvider is not a blocking operation, but function calls on the BigSegmentStoreStatusProvider may be.

Specified by:

getBigSegmentStoreStatusProvider in interface LDReactorClientInterface

Returns:

see linked reference.

getDataStoreStatusProvider

public DataStoreStatusProvider getDataStoreStatusProvider()

Description copied from interface: LDReactorClientInterface

See LDClient.getDataStoreStatusProvider(). Getting the DataStoreStatusProvider is not a blocking operation, but function calls on the DataStoreStatusProvider may be.

Specified by:

getDataStoreStatusProvider in interface LDReactorClientInterface

Returns:

see linked reference.

getDataSourceStatusProvider

public DataSourceStatusProvider getDataSourceStatusProvider()

Description copied from interface: LDReactorClientInterface

See LDClient.getDataSourceStatusProvider(). Getting the DataSourceStatusProvider is not a blocking operation, but function calls on the DataSourceStatusProvider may be.

Specified by:

getDataSourceStatusProvider in interface LDReactorClientInterface

Returns:

see linked reference.

close

public reactor.core.publisher.Mono<java.lang.Void> close()

Description copied from interface: LDReactorClientInterface

See LDClient.close().

Specified by:

close in interface LDReactorClientInterface

Returns:

a Mono that completes when LDClient.close() completes.

flush

public void flush()

Description copied from interface: LDReactorClientInterface

See LDClient.flush().

Specified by:

flush in interface LDReactorClientInterface

isOffline

public boolean isOffline()

Description copied from interface: LDReactorClientInterface

See LDClient.isOffline().

Specified by:

isOffline in interface LDReactorClientInterface

Returns:

see linked reference.

secureModeHash

public java.lang.String secureModeHash(LDContext context)

Description copied from interface: LDReactorClientInterface

See LDClient.secureModeHash(LDContext).

Specified by:

secureModeHash in interface LDReactorClientInterface

Parameters:

context - see linked reference.

Returns:

see linked reference.

version

public java.lang.String version()

Description copied from interface: LDReactorClientInterface

See LDClient.version().

Specified by:

version in interface LDReactorClientInterface

Returns:

see linked reference.