Class UploadCountingInputStreamMetrics
- java.lang.Object
-
- java.io.InputStream
-
- java.io.FilterInputStream
-
- org.apache.commons.io.input.ProxyInputStream
-
- org.apache.commons.io.input.CountingInputStream
-
- fr.gouv.vitam.storage.engine.common.metrics.UploadCountingInputStreamMetrics
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
public class UploadCountingInputStreamMetrics extends org.apache.commons.io.input.CountingInputStream
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
dataCategory
protected java.lang.String
offerId
protected java.lang.String
origin
protected java.lang.String
strategy
protected java.lang.String
tenant
static io.prometheus.client.Summary
UPLOAD_BYTES
-
Constructor Summary
Constructors Constructor Description UploadCountingInputStreamMetrics(java.lang.Integer tenant, java.lang.String strategy, java.lang.String offerId, java.lang.String origin, DataCategory dataCategory, int attempt, java.io.InputStream inputStream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
afterRead(int n)
protected void
onEndOfFileReached()
-
Methods inherited from class org.apache.commons.io.input.CountingInputStream
getByteCount, getCount, resetByteCount, resetCount, skip
-
Methods inherited from class org.apache.commons.io.input.ProxyInputStream
available, beforeRead, close, handleIOException, mark, markSupported, read, read, read, reset
-
-
-
-
Field Detail
-
UPLOAD_BYTES
public static final io.prometheus.client.Summary UPLOAD_BYTES
-
tenant
protected final java.lang.String tenant
-
strategy
protected final java.lang.String strategy
-
offerId
protected final java.lang.String offerId
-
origin
protected final java.lang.String origin
-
dataCategory
protected final java.lang.String dataCategory
-
-
Constructor Detail
-
UploadCountingInputStreamMetrics
public UploadCountingInputStreamMetrics(java.lang.Integer tenant, java.lang.String strategy, java.lang.String offerId, java.lang.String origin, DataCategory dataCategory, int attempt, java.io.InputStream inputStream)
-
-