Package io.opentelemetry.contrib.disk.buffering.storage.impl

Class FileMetricStorage

java.lang.Object

io.opentelemetry.contrib.disk.buffering.storage.impl.FileMetricStorage

All Implemented Interfaces:

SignalStorage<io.opentelemetry.sdk.metrics.data.MetricData>, SignalStorage.Metric, Closeable, AutoCloseable, Iterable<Collection<io.opentelemetry.sdk.metrics.data.MetricData>>

public final class FileMetricStorage
extends Object
implements SignalStorage.Metric

Nested Class Summary

Nested classes/interfaces inherited from interface io.opentelemetry.contrib.disk.buffering.storage.SignalStorage

SignalStorage.LogRecord, SignalStorage.Metric, SignalStorage.Span

Method Summary

Modifier and Type	Method	Description
io.opentelemetry.sdk.common.CompletableResultCode	clear()	Removes all the previously stored items.
void	close()
static FileMetricStorage	create(File destinationDir)
static FileMetricStorage	create(File destinationDir, FileStorageConfiguration configuration)
Iterator<Collection<io.opentelemetry.sdk.metrics.data.MetricData>>	iterator()
io.opentelemetry.sdk.common.CompletableResultCode	write(Collection<io.opentelemetry.sdk.metrics.data.MetricData> items)	Stores signal items.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Method Details

create

public static FileMetricStorage create(File destinationDir)

create

public static FileMetricStorage create(File destinationDir,
 FileStorageConfiguration configuration)

write

public io.opentelemetry.sdk.common.CompletableResultCode write(Collection<io.opentelemetry.sdk.metrics.data.MetricData> items)

Description copied from interface: SignalStorage

Stores signal items.

Specified by:

write in interface SignalStorage<io.opentelemetry.sdk.metrics.data.MetricData>

Parameters:

items - The items to be stored.

Returns:

A CompletableResultCode representing the outcome of the write operation.

clear

public io.opentelemetry.sdk.common.CompletableResultCode clear()

Description copied from interface: SignalStorage

Removes all the previously stored items.

Specified by:

clear in interface SignalStorage<io.opentelemetry.sdk.metrics.data.MetricData>

Returns:

A CompletableResultCode representing the outcome of the clear operation.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

iterator

@Nonnull
public Iterator<Collection<io.opentelemetry.sdk.metrics.data.MetricData>> iterator()

Specified by:

iterator in interface Iterable<Collection<io.opentelemetry.sdk.metrics.data.MetricData>>