org.apache.ignite.internal.processors.cache.persistence.pagemem

Interface PagesWriteThrottlePolicy

All Known Implementing Classes:

PagesWriteSpeedBasedThrottle, PagesWriteThrottle

public interface PagesWriteThrottlePolicy

Throttling policy, encapsulates logic of delaying write operations.

Field Summary

Fields

Modifier and Type	Field and Description
static long	LOGGING_THRESHOLD Max park time.

Method Summary

Modifier and Type	Method and Description
void	onBeginCheckpoint() Callback to notify throttling policy checkpoint was started.
void	onFinishCheckpoint() Callback to notify throttling policy checkpoint was finished.
void	onMarkDirty(boolean isPageInCheckpoint) Callback to apply throttling delay.
default boolean	shouldThrottle()
default void	tryWakeupThrottledThreads() Callback to try wakeup throttled threads.

Field Detail

LOGGING_THRESHOLD

static final long LOGGING_THRESHOLD

Max park time.

Method Detail

onMarkDirty

void onMarkDirty(boolean isPageInCheckpoint)

Callback to apply throttling delay.

Parameters:

isPageInCheckpoint - flag indicating if current page is in scope of current checkpoint.

tryWakeupThrottledThreads

default void tryWakeupThrottledThreads()

Callback to try wakeup throttled threads.

onBeginCheckpoint

void onBeginCheckpoint()

Callback to notify throttling policy checkpoint was started.

onFinishCheckpoint

void onFinishCheckpoint()

Callback to notify throttling policy checkpoint was finished.

shouldThrottle

default boolean shouldThrottle()

Returns:

True if throttling should be enabled, and False otherwise.