Package org.apache.beam.sdk.io.datadog

Class DatadogEventPublisher

java.lang.Object

org.apache.beam.sdk.io.datadog.DatadogEventPublisher

public abstract class DatadogEventPublisher
extends Object

DatadogEventPublisher is a utility class that helps write DatadogEvents to a Datadog Logs API endpoint.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	DD_URL_PATH

Constructor Summary

Constructors

Constructor	Description
DatadogEventPublisher()

Method Summary

Modifier and Type	Method	Description
void	close()	Shutdown connection manager and releases all resources.
com.google.api.client.http.HttpResponse	execute(List<DatadogEvent> events)	Executes a POST for the list of DatadogEvent objects into Datadog's Logs API.
com.google.api.client.http.HttpResponse	execute(DatadogEvent event)	Same as execute(List) but with a single DatadogEvent.
protected com.google.api.client.util.ExponentialBackOff	getConfiguredBackOff()	Return an ExponentialBackOff with the right settings.
protected com.google.api.client.http.HttpContent	getContent(List<DatadogEvent> events)	Utility method to marshall a list of DatadogEvents into an HttpContent object that can be used to create an HttpRequest.
static org.apache.beam.sdk.io.datadog.DatadogEventPublisher.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Field Details

DD_URL_PATH

protected static final String DD_URL_PATH

See Also:

• Constant Field Values

Constructor Details

DatadogEventPublisher

public DatadogEventPublisher()

Method Details

newBuilder

public static org.apache.beam.sdk.io.datadog.DatadogEventPublisher.Builder newBuilder()

execute

public com.google.api.client.http.HttpResponse execute(List<DatadogEvent> events)
                                                throws IOException

Executes a POST for the list of DatadogEvent objects into Datadog's Logs API.

Parameters:

events - List of DatadogEvents

Returns:

HttpResponse for the POST.

Throws:

IOException

execute

public com.google.api.client.http.HttpResponse execute(DatadogEvent event)
                                                throws IOException

Same as execute(List) but with a single DatadogEvent.

Parameters:

event - DatadogEvent object.

Throws:

IOException

getConfiguredBackOff

protected com.google.api.client.util.ExponentialBackOff getConfiguredBackOff()

Return an ExponentialBackOff with the right settings.

Returns:

ExponentialBackOff object.

close

public void close()
           throws IOException

Shutdown connection manager and releases all resources.

Throws:

IOException

getContent

protected com.google.api.client.http.HttpContent getContent(List<DatadogEvent> events)

Utility method to marshall a list of DatadogEvents into an HttpContent object that can be used to create an HttpRequest.

Parameters:

events - List of DatadogEvents

Returns:

HttpContent that can be used to create an HttpRequest.