taskbridge-core/io.github.nikkiw.taskbridge.transport/TaskBridgeCheckpointBinding

TaskBridgeCheckpointBinding

data class TaskBridgeCheckpointBinding<Ctx>(val store: TaskBridgeCheckpointStore, val namespace: String? = null, val keyFactory: (Ctx, taskId: String) -> String? = null)

Checkpoint storage and keying for stream resume.

Constructors

TaskBridgeCheckpointBinding

constructor(store: TaskBridgeCheckpointStore, namespace: String? = null, keyFactory: (Ctx, taskId: String) -> String? = null)

Properties

val keyFactory: (Ctx, taskId: String) -> String?

Factory for generating storage keys.

val namespace: String?

Optional namespace for keys.

val store: TaskBridgeCheckpointStore

The storage implementation.