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

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

Properties

Link copied to clipboard
val keyFactory: (Ctx, taskId: String) -> String?

Factory for generating storage keys.

Link copied to clipboard

Optional namespace for keys.

Link copied to clipboard

The storage implementation.