Package org.apache.beam.sdk.extensions.gcp.util

Class LatencyRecordingHttpRequestInitializer

java.lang.Object

org.apache.beam.sdk.extensions.gcp.util.LatencyRecordingHttpRequestInitializer

All Implemented Interfaces:

com.google.api.client.http.HttpRequestInitializer

public class LatencyRecordingHttpRequestInitializer
extends Object
implements com.google.api.client.http.HttpRequestInitializer

HttpRequestInitializer for recording request to response latency of Http-based API calls.

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.beam.sdk.util.HistogramData.BucketType	HISTOGRAM_BUCKET_TYPE

Constructor Summary

Constructors

Constructor	Description
LatencyRecordingHttpRequestInitializer(Map<String,String> labels)
LatencyRecordingHttpRequestInitializer(Histogram histogram)

Method Summary

Modifier and Type	Method	Description
void	initialize(com.google.api.client.http.HttpRequest request)

Methods inherited from class java.lang.Object

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

Field Details

HISTOGRAM_BUCKET_TYPE

public static final org.apache.beam.sdk.util.HistogramData.BucketType HISTOGRAM_BUCKET_TYPE

Constructor Details

LatencyRecordingHttpRequestInitializer

public LatencyRecordingHttpRequestInitializer(Histogram histogram)

LatencyRecordingHttpRequestInitializer

public LatencyRecordingHttpRequestInitializer(Map<String,String> labels)

Method Details

initialize

public void initialize(com.google.api.client.http.HttpRequest request)
                throws IOException

Specified by:

initialize in interface com.google.api.client.http.HttpRequestInitializer

Throws:

IOException