Package com.inductiveautomation.historian.gateway.api.storage.strategy

Class ImmediateStorageStrategy

java.lang.Object

com.inductiveautomation.historian.gateway.api.storage.strategy.PointStorageStrategy

com.inductiveautomation.historian.gateway.api.storage.strategy.ImmediateStorageStrategy

public final class ImmediateStorageStrategy
extends PointStorageStrategy

A singleton implementation of the PointStorageStrategy interface that provides default behavior for processing and storing atomic, complex, and change points. All processing operations are executed immediately and synchronously, returning completed CompletionStage instances.

This class uses the provided storage functions directly without any intermediate processing or enhancements. It is designed to be a lightweight, no-operation implementation that delegates processing entirely to the supplied functions.

This implementation doesn't manage any internal state or resources and performs no additional logic for flushing or shutting down beyond the required no-operation behavior. It's especially useful for scenarios where simple and synchronous storage processing behavior is sufficient.

Nested Class Summary

Nested classes/interfaces inherited from class com.inductiveautomation.historian.gateway.api.storage.strategy.PointStorageStrategy

PointStorageStrategy.Listener

Field Summary

Fields inherited from class com.inductiveautomation.historian.gateway.api.storage.strategy.PointStorageStrategy

SHUTDOWN_FAILURE_CODE

Method Summary

Modifier and Type	Method	Description
static ImmediateStorageStrategy	create(String key)
CompletionStage<StorageResult<AtomicPoint<?>>>	processAtomic(List<AtomicPoint<?>> atomicPoints)	Processes a list of atomic points asynchronously.
<C extends ChangePoint<?>> CompletionStage<StorageResult<C>>	processChanges(List<C> changePoints)	Processes a list of change points asynchronously.
<C extends ComplexPoint<?>> CompletionStage<StorageResult<C>>	processComplex(List<C> complexPoints)	Processes a list of complex points asynchronously.
void	shutdown()	Shuts down the storage strategy, preventing further processing of points.

Methods inherited from class com.inductiveautomation.historian.gateway.api.storage.strategy.PointStorageStrategy

forwardPoints, onPointsReady

Methods inherited from class java.lang.Object

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

Method Details

create

public static ImmediateStorageStrategy create(String key)

processAtomic

public CompletionStage<StorageResult<AtomicPoint<?>>> processAtomic(List<AtomicPoint<?>> atomicPoints)

Description copied from class: PointStorageStrategy

Processes a list of atomic points asynchronously.

Specified by:

processAtomic in class PointStorageStrategy

Parameters:

atomicPoints - The list of atomic points to process.

Returns:

A CompletionStage representing the result of the storage operation.

processComplex

public <C extends ComplexPoint<?>>
CompletionStage<StorageResult<C>> processComplex(List<C> complexPoints)

Description copied from class: PointStorageStrategy

Processes a list of complex points asynchronously.

Specified by:

processComplex in class PointStorageStrategy

Type Parameters:

C - The type of complex points.

Parameters:

complexPoints - The list of complex points to process.

Returns:

A CompletionStage representing the result of the storage operation.

processChanges

public <C extends ChangePoint<?>>
CompletionStage<StorageResult<C>> processChanges(List<C> changePoints)

Description copied from class: PointStorageStrategy

Processes a list of change points asynchronously.

Specified by:

processChanges in class PointStorageStrategy

Type Parameters:

C - The type of change points.

Parameters:

changePoints - The list of change points to process.

Returns:

A CompletionStage representing the result of the storage operation.

shutdown

public void shutdown()

Description copied from class: PointStorageStrategy

Shuts down the storage strategy, preventing further processing of points.

Specified by:

shutdown in class PointStorageStrategy