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
CompletableFuture<WriteResult>	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()
CompletableFuture<WriteResult>	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 CompletableFuture<WriteResult> 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 future with WriteResult.

clear

public CompletableFuture<WriteResult> 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 future with WriteResult.

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>>