com.google.cloud.pubsub.v1

Class OpenCensusUtil

java.lang.Object

com.google.cloud.pubsub.v1.OpenCensusUtil

public class OpenCensusUtil
extends Object

Utilities for propagating OpenCensus TagContext and SpanContext from publishers to subscribers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OpenCensusUtil.OpenCensusMessageReceiver Wrapper class for MessageReceiver that decodes any received trace and tag contexts and puts them in scope.

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.api.core.ApiFunction<com.google.pubsub.v1.PubsubMessage,com.google.pubsub.v1.PubsubMessage>	OPEN_CENSUS_MESSAGE_TRANSFORM Propagates active OpenCensus trace and tag contexts from the Publisher by adding them as attributes to the PubsubMessage.
static String	TAG_CONTEXT_KEY
static String	TRACE_CONTEXT_KEY

Constructor Summary

Constructors

Constructor and Description
OpenCensusUtil()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

TAG_CONTEXT_KEY

public static final String TAG_CONTEXT_KEY

See Also:

Constant Field Values

TRACE_CONTEXT_KEY

public static final String TRACE_CONTEXT_KEY

See Also:

Constant Field Values

OPEN_CENSUS_MESSAGE_TRANSFORM

public static final com.google.api.core.ApiFunction<com.google.pubsub.v1.PubsubMessage,com.google.pubsub.v1.PubsubMessage> OPEN_CENSUS_MESSAGE_TRANSFORM

Propagates active OpenCensus trace and tag contexts from the Publisher by adding them as attributes to the PubsubMessage.

Constructor Detail

OpenCensusUtil

public OpenCensusUtil()