reactor.netty.observability.contextpropagation.propagator

Class ChannelContextContainerPropagator

java.lang.Object

reactor.netty.observability.contextpropagation.propagator.ChannelContextContainerPropagator

All Implemented Interfaces:

io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

public final class ChannelContextContainerPropagator
extends Object
implements io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

Abstraction to tell context propagation how to read from and write to Channel attributes.

Since:

1.1.0

Author:

Marcin Grzejszczak

Field Summary

Fields inherited from interface io.micrometer.contextpropagation.ContextContainerPropagator

NOOP

Constructor Summary

Constructors

Constructor and Description
ChannelContextContainerPropagator()

Method Summary

Modifier and Type	Method and Description
io.micrometer.contextpropagation.ContextContainer	get(Channel channel)
Class<?>	getSupportedContextClassForGet()
Class<?>	getSupportedContextClassForSet()
Channel	remove(Channel channel)
Channel	set(Channel channel, io.micrometer.contextpropagation.ContextContainer value)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelContextContainerPropagator

public ChannelContextContainerPropagator()

Method Detail

get

public io.micrometer.contextpropagation.ContextContainer get(Channel channel)

Specified by:

get in interface io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

getSupportedContextClassForGet

public Class<?> getSupportedContextClassForGet()

Specified by:

getSupportedContextClassForGet in interface io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

getSupportedContextClassForSet

public Class<?> getSupportedContextClassForSet()

Specified by:

getSupportedContextClassForSet in interface io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

remove

public Channel remove(Channel channel)

Specified by:

remove in interface io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>

set

public Channel set(Channel channel,
                   io.micrometer.contextpropagation.ContextContainer value)

Specified by:

set in interface io.micrometer.contextpropagation.ContextContainerPropagator<Channel,Channel>