Packages

o

nelson.monitoring

DeploymentMonitor

object DeploymentMonitor

Source
DeploymentMonitor.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeploymentMonitor
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. sealed abstract class MonitorActionItem extends AnyRef
  2. final case class PromoteToReady(dc: Datacenter, deployment: Deployment) extends MonitorActionItem with Product with Serializable
  3. final case class RetainAsWarming(dc: Datacenter, deployment: Deployment, reason: String) extends MonitorActionItem with Product with Serializable

Value Members

  1. def count(item: MonitorActionItem): IO[Unit]
  2. val counterSink: Sink[IO, MonitorActionItem]
  3. def drain[A](cfg: NelsonConfig)(h: Stream[IO, Duration], w: NelsonFK[Stream, Seq[A]], s: Sink[IO, A], k: NelsonFK[Sink, A]): Stream[IO, Unit]
  4. def getHealth(dc: Datacenter, ns: NamespaceName, sn: StackName): HealthCheckF[List[HealthStatus]]
  5. def heartbeat(cfg: NelsonConfig): Stream[IO, Duration]
  6. def loop(cfg: NelsonConfig): Stream[IO, Unit]
  7. def majorityPassing(statuses: List[HealthStatus]): Boolean
  8. def monitorActionItem(dc: Datacenter, d: Deployment): IO[MonitorActionItem]
  9. def monitorActionItems(cfg: NelsonConfig): IO[List[MonitorActionItem]]
  10. def monitorActionItemsByDatacenter(dc: Datacenter): IO[List[MonitorActionItem]]
  11. def monitorActionItemsByNamespace(dc: Datacenter, ns: Namespace): IO[List[MonitorActionItem]]
  12. def next(d: Deployment): StoreOpF[Option[Deployment]]
  13. def promote(item: MonitorActionItem)(auditor: Auditor): IO[Unit]
  14. def promoteToReady(d: Deployment): StoreOpF[Unit]
  15. def promotionSink(cfg: NelsonConfig): Sink[IO, MonitorActionItem]
  16. def trafficShift(d: Deployment): StoreOpF[Option[TrafficShift]]