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

Interface SignalStorage<T>

Type Parameters:

T - The type of signal data supported.

All Superinterfaces:

AutoCloseable, Closeable, Iterable<Collection<T>>

All Known Subinterfaces:

SignalStorage.LogRecord, SignalStorage.Metric, SignalStorage.Span

All Known Implementing Classes:

FileLogRecordStorage, FileMetricStorage, FileSpanStorage

public interface SignalStorage<T>
extends Iterable<Collection<T>>, Closeable

Allows writing and iterating over written signal items.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	SignalStorage.LogRecord	Abstraction for Logs.
static interface	SignalStorage.Metric	Abstraction for Metrics.
static interface	SignalStorage.Span	Abstraction for Spans.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<WriteResult>	clear()	Removes all the previously stored items.
CompletableFuture<WriteResult>	write(Collection<T> items)	Stores signal items.

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Details

write

CompletableFuture<WriteResult> write(Collection<T> items)

Stores signal items.

Parameters:

items - The items to be stored.

Returns:

A future with WriteResult.

clear

CompletableFuture<WriteResult> clear()

Removes all the previously stored items.

Returns:

A future with WriteResult.