Package datadog.trace.api.experimental

Class DataStreamsCheckpointer.NoOp

java.lang.Object

datadog.trace.api.experimental.DataStreamsCheckpointer.NoOp

All Implemented Interfaces:

DataStreamsCheckpointer

Enclosing interface:

DataStreamsCheckpointer

public static final class DataStreamsCheckpointer.NoOp
extends Object
implements DataStreamsCheckpointer

Nested Class Summary

Nested classes/interfaces inherited from interface datadog.trace.api.experimental.DataStreamsCheckpointer

DataStreamsCheckpointer.NoOp

Field Summary

Fields

Modifier and Type	Field	Description
static final DataStreamsCheckpointer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
NoOp()

Method Summary

Modifier and Type	Method	Description
void	setConsumeCheckpoint(String type, String source, DataStreamsContextCarrier carrier)
void	setProduceCheckpoint(String type, String target, DataStreamsContextCarrier carrier)
void	trackTransaction(String transactionId, String checkpointName)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final DataStreamsCheckpointer INSTANCE

Constructor Details

NoOp

public NoOp()

Method Details

setConsumeCheckpoint

public void setConsumeCheckpoint(String type,
 String source,
 DataStreamsContextCarrier carrier)

Specified by:

setConsumeCheckpoint in interface DataStreamsCheckpointer

Parameters:

type - The type of the checkpoint, usually the streaming technology being used. Examples: kafka, kinesis, sns etc.

source - The source of data. For instance: topic, exchange or stream name.

carrier - An interface to the context carrier, from which the context will be extracted. I.e. wrapper around message headers.

setProduceCheckpoint

public void setProduceCheckpoint(String type,
 String target,
 DataStreamsContextCarrier carrier)

Specified by:

setProduceCheckpoint in interface DataStreamsCheckpointer

Parameters:

type - The type of the checkpoint, usually the streaming technology being used. Examples: kafka, kinesis, sns etc.

target - The destination to which the data is being sent. For instance: topic, exchange or stream name.

carrier - An interface to the context carrier, to which the context will be injected. I.e. wrapper around message headers.

trackTransaction

public void trackTransaction(String transactionId,
 String checkpointName)

Specified by:

trackTransaction in interface DataStreamsCheckpointer

Parameters:

transactionId - Transaction ID to track.

checkpointName - Unique checkpoint name.