org.springframework.cloud.sleuth.instrument.reactor

Class ReactorSleuth

java.lang.Object

org.springframework.cloud.sleuth.instrument.reactor.ReactorSleuth

public abstract class ReactorSleuth
extends Object

Reactive Span pointcuts factories.

Since:

2.0.0

Author:

Stephane Maldini

Method Summary

Modifier and Type	Method and Description
static Function<Runnable,Runnable>	scopePassingOnScheduleHook(org.springframework.context.ConfigurableApplicationContext springContext)
static <T> Function<? super org.reactivestreams.Publisher<T>,? extends org.reactivestreams.Publisher<T>>	scopePassingSpanOperator(org.springframework.context.ConfigurableApplicationContext springContext) Return a span operator pointcut given a Tracing.

Methods inherited from class java.lang.Object

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

Method Detail

scopePassingSpanOperator

public static <T> Function<? super org.reactivestreams.Publisher<T>,? extends org.reactivestreams.Publisher<T>> scopePassingSpanOperator(org.springframework.context.ConfigurableApplicationContext springContext)

Return a span operator pointcut given a Tracing. This can be used in reactor via Flux.transform(Function), Mono.transform(Function), Hooks.onLastOperator(Function) or Hooks.onLastOperator(Function). The Span operator pointcut will pass the Scope of the Span without ever creating any new spans.

Type Parameters:

T - an arbitrary type that is left unchanged by the span operator

Parameters:

springContext - the Spring context.

Returns:

a new lazy span operator pointcut

scopePassingOnScheduleHook

public static Function<Runnable,Runnable> scopePassingOnScheduleHook(org.springframework.context.ConfigurableApplicationContext springContext)