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

Class FileLogRecordStorage

java.lang.Object

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

All Implemented Interfaces:

SignalStorage<io.opentelemetry.sdk.logs.data.LogRecordData>, SignalStorage.LogRecord, Closeable, AutoCloseable, Iterable<Collection<io.opentelemetry.sdk.logs.data.LogRecordData>>

public final class FileLogRecordStorage
extends Object
implements SignalStorage.LogRecord

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

create

public static FileLogRecordStorage create(File destinationDir,
 FileStorageConfiguration configuration)

write

public CompletableFuture<WriteResult> write(Collection<io.opentelemetry.sdk.logs.data.LogRecordData> items)

Description copied from interface: SignalStorage

Stores signal items.

Specified by:

write in interface SignalStorage<io.opentelemetry.sdk.logs.data.LogRecordData>

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.logs.data.LogRecordData>

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.logs.data.LogRecordData>> iterator()

Specified by:

iterator in interface Iterable<Collection<io.opentelemetry.sdk.logs.data.LogRecordData>>