Package datadog.trace.api.experimental

Interface DataStreamsCheckpointer

All Known Implementing Classes:

DataStreamsCheckpointer.NoOp

public interface DataStreamsCheckpointer

An interface to Data Streams checkpointer, allowing passing the context manually.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final class	DataStreamsCheckpointer.NoOp

Method Summary

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

Method Details

get

static DataStreamsCheckpointer get()

setConsumeCheckpoint

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

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.

trackTransaction

void trackTransaction(String transactionId,
 String checkpointName)

Parameters:

transactionId - Transaction ID to track.

checkpointName - Unique checkpoint name.

setProduceCheckpoint

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

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.