Package dev.restate.sdk.interceptor

Interface RunInterceptor.Factory

All Known Implementing Classes:

GlobalOpenTelemetryInterceptorFactory, MicrometerInterceptorFactory, OpenTelemetryInterceptorFactory

Enclosing interface:

RunInterceptor

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@Experimental
@FunctionalInterface
public static interface RunInterceptor.Factory

Factory for RunInterceptor.

Factories are discovered via ServiceLoader (global defaults) or registered explicitly via HandlerRunner.Options.addRunInterceptorFactory(RunInterceptor.Factory).

Method Summary

Modifier and Type	Method	Description
static RunInterceptor	combine(Collection<? extends RunInterceptor.Factory> factories)
static RunInterceptor	combine(Stream<? extends RunInterceptor.Factory> factories)	Combine multiple factories into a single RunInterceptor.
@Nullable RunInterceptor	createRunInterceptor()	Create RunInterceptor.

Method Details

createRunInterceptor

@Nullable RunInterceptor createRunInterceptor()

Create RunInterceptor. Invoked once at endpoint initialization, hence the resulting interceptor is cached and reused across all invocations.

Return null to skip this factory.

combine

static RunInterceptor combine(Stream<? extends RunInterceptor.Factory> factories)

Combine multiple factories into a single RunInterceptor.

The first is outermost, the last is innermost.

combine

static RunInterceptor combine(Collection<? extends RunInterceptor.Factory> factories)