Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-core-load/io.airbyte.cdk.load.state/ReservationManager

ReservationManager

class ReservationManager(val totalCapacityBytes: Long)

Manages memory usage for the destination.

TODO: Better initialization of available runtime memory?

TODO: Some degree of logging/monitoring around how accurate we're actually being?

Constructors

ReservationManager

constructor(totalCapacityBytes: Long)

Properties

remainingCapacityBytes

val remainingCapacityBytes: Long

totalBytesReserved

val totalBytesReserved: Long

totalCapacityBytes

val totalCapacityBytes: Long

Functions

suspend fun release(bytes: Long)

suspend fun reserve(bytes: Long)

suspend fun <T> reserve(bytes: Long, reservedFor: T): Reserved<T>

suspend fun <T> reserveOrThrow(bytes: Long, reservedFor: T): Reserved<T>