Packages

trait PollingMetric[-R, +E, +Out] extends AnyRef

A PollingMetric[Type, Out] is a combination of a metric and an effect that polls for updates to the metric.

Self Type
PollingMetric[R, E, Out]
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PollingMetric
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. abstract type In
  2. abstract type Type

Abstract Value Members

  1. abstract def metric: Metric[Type, In, Out]

    The metric that this PollingMetric polls to update.

  2. abstract def poll(implicit trace: Trace): ZIO[R, E, In]

    An effect that polls a value that may be fed to the metric.

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. final def blocking: Full[Type, In, R, E, Out]

    Create a new PollingMetric that will poll on the blocking thread pool.

  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def launch[R1 <: R, B](schedule: Schedule[R1, Any, B])(implicit trace: Trace): ZIO[R1 with Scope, Nothing, Fiber[E, B]]

    Returns an effect that will launch the polling metric in a background fiber, using the specified schedule.

  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def pollAndUpdate(implicit trace: Trace): ZIO[R, E, Unit]

    An effect that polls for a value and uses the value to update the metric.

  17. final def retry[R1 <: R, E1 >: E](policy: Schedule[R1, E1, Any]): Full[Type, In, R1, E1, Out]

    Returns a new polling metric whose poll function will be retried with the specified retry policy.

  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  23. final def zip[R1 <: R, E1 >: E, Out2](that: PollingMetric[R1, E1, Out2])(implicit z1: Zippable[Type, Type], z2: Zippable[Out, Out2]): Full[Out, (In, In), R1, E1, Out]

    Zips this polling metric with the specified polling metric.

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped