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

Class FileSpanStorage

java.lang.Object

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

All Implemented Interfaces:

SignalStorage<io.opentelemetry.sdk.trace.data.SpanData>, SignalStorage.Span, Closeable, AutoCloseable, Iterable<Collection<io.opentelemetry.sdk.trace.data.SpanData>>

public final class FileSpanStorage
extends Object
implements SignalStorage.Span

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 FileSpanStorage	create(File destinationDir)
static FileSpanStorage	create(File destinationDir, FileStorageConfiguration configuration)
Iterator<Collection<io.opentelemetry.sdk.trace.data.SpanData>>	iterator()
CompletableFuture<WriteResult>	write(Collection<io.opentelemetry.sdk.trace.data.SpanData> 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 FileSpanStorage create(File destinationDir)

create

public static FileSpanStorage create(File destinationDir,
 FileStorageConfiguration configuration)

write

public CompletableFuture<WriteResult> write(Collection<io.opentelemetry.sdk.trace.data.SpanData> items)

Description copied from interface: SignalStorage

Stores signal items.

Specified by:

write in interface SignalStorage<io.opentelemetry.sdk.trace.data.SpanData>

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.trace.data.SpanData>

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.trace.data.SpanData>> iterator()

Specified by:

iterator in interface Iterable<Collection<io.opentelemetry.sdk.trace.data.SpanData>>