Package io.github.flink.gcp.connector.cloudtasks.sink

Class CloudTasksReplaySnapshot

java.lang.Object

io.github.flink.gcp.connector.cloudtasks.sink.CloudTasksReplaySnapshot

@Internal
public final class CloudTasksReplaySnapshot
extends Object

Immutable observation of an owned batch, containing no task payload or durable state.

Method Summary

Modifier and Type	Method	Description
long	ageMillis(long now)	Returns the oldest age in milliseconds, or -1 when no tasks are observed.
static CloudTasksReplaySnapshot	empty()	Returns an observation with no owned tasks.
CloudTasksReplaySnapshot	include(long origin, long deadline)	Includes an envelope's origin and effective authorization deadline.
long	remainingMillis(long now)	Returns the shortest remaining budget in milliseconds, or -1 for an empty observation.

Methods inherited from class java.lang.Object

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

Method Details

empty

public static CloudTasksReplaySnapshot empty()

Returns an observation with no owned tasks.

include

public CloudTasksReplaySnapshot include(long origin,
 long deadline)

Includes an envelope's origin and effective authorization deadline.

ageMillis

public long ageMillis(long now)

Returns the oldest age in milliseconds, or -1 when no tasks are observed.

remainingMillis

public long remainingMillis(long now)

Returns the shortest remaining budget in milliseconds, or -1 for an empty observation.