Skip to content

ExecutorPodsSnapshotsStore

ExecutorPodsSnapshotsStore is an abstraction of pod stores.

Contract

addSubscriber

addSubscriber(
  processBatchIntervalMillis: Long)(
  onNewSnapshots: Seq[ExecutorPodsSnapshot] => Unit): Unit

Used when:

  • ExecutorPodsAllocator is requested to start
  • ExecutorPodsLifecycleManager is requested to start

notifySubscribers

notifySubscribers(): Unit

Used when:

replaceSnapshot

replaceSnapshot(
  newSnapshot: Seq[Pod]): Unit

Used when:

  • PollRunnable is requested to start

stop

stop(): Unit

Used when:

  • KubernetesClusterSchedulerBackend is requested to stop

updatePod

updatePod(
  updatedPod: Pod): Unit

Used when:

Implementations


Last update: 2021-01-04