io.lettuce.core

Class AbstractRedisReactiveCommands.ReactorTraceContext

java.lang.Object

io.lettuce.core.AbstractRedisReactiveCommands.ReactorTraceContext

Enclosing class:

AbstractRedisReactiveCommands<K,V>

public static final class AbstractRedisReactiveCommands.ReactorTraceContext
extends Object

Helpers for propagating a TraceContextProvider through a Reactor Context on the reactive command path.

Since:

7.8

Author:

Aleksandar Todorov

Method Summary

Modifier and Type	Method and Description
static Function<reactor.util.context.Context,reactor.util.context.Context>	clearContext() Returns a Function that clears the TraceContextProvider from a Reactor Context.
static reactor.core.publisher.Mono<TraceContextProvider>	getContext() Gets the TraceContextProvider from the Reactor Context.
static reactor.util.context.Context	withTraceContextProvider(TraceContextProvider provider) Creates a Reactor Context holding the given TraceContextProvider that can be merged into another Context.

Methods inherited from class java.lang.Object

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

Method Detail

getContext

public static reactor.core.publisher.Mono<TraceContextProvider> getContext()

Gets the TraceContextProvider from the Reactor Context.

Returns:

a Mono emitting the TraceContextProvider held in the subscriber Context, if any.

clearContext

public static Function<reactor.util.context.Context,reactor.util.context.Context> clearContext()

Returns a Function that clears the TraceContextProvider from a Reactor Context.

Returns:

a Function that removes the TraceContextProvider from a Context.

withTraceContextProvider

public static reactor.util.context.Context withTraceContextProvider(TraceContextProvider provider)

Creates a Reactor Context holding the given TraceContextProvider that can be merged into another Context.

Parameters:

provider - the TraceContextProvider to place into the returned Reactor Context.

Returns:

a Reactor Context containing the TraceContextProvider.