o

com.spotify.scio.testing

CoderAssertions

object CoderAssertions

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

Type Members

  1. case class AssertionContext[T](actualValue: Option[T], coder: Coder[T], lastAssertion: Option[Assertion] = None, opts: PipelineOptions = DefaultPipelineOptions) extends AssertionContextBase with Product with Serializable
  2. trait AssertionContextBase extends AnyRef
  3. type CoderAssertion[T] = (AssertionContext[T]) => Assertion
  4. type CoderAssertionBase = (AssertionContextBase) => Assertion
  5. implicit class CoderShouldSyntax[T] extends AnyRef
  6. trait CustomOptionsSyntax[T] extends AnyRef
  7. implicit class ValueShouldSyntax[T] extends AnyRef
  8. case class WithOptions(opts: PipelineOptions) extends Product with Serializable

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. def beConsistentWithEquals(): CoderAssertionBase
  6. def beDeterministic(): CoderAssertionBase
  7. def beFullyCompliant[T <: AnyRef]()(implicit arg0: ClassTag[T]): CoderAssertion[T]

    Passes all checks on Beam coder

  8. def beFullyCompliantNonDeterministic[T <: AnyRef]()(implicit arg0: ClassTag[T]): CoderAssertion[T]
  9. def beFullyCompliantNotConsistentWithEquals[T <: AnyRef]()(implicit arg0: ClassTag[T]): CoderAssertion[T]
  10. def beNonDeterministic(): CoderAssertionBase
  11. def beNotConsistentWithEquals(): CoderAssertionBase
  12. def beOfType[ExpectedCoder](implicit arg0: ClassTag[ExpectedCoder]): CoderAssertionBase
  13. def beSerializable(): CoderAssertionBase
  14. def bytesCountTested[T <: AnyRef]()(implicit arg0: ClassTag[T]): CoderAssertion[T]
  15. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  16. def coderIsSerializable[A](implicit c: Coder[A]): Assertion
  17. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  19. def fallback[T]()(implicit arg0: ClassTag[T], arg1: Equality[T]): CoderAssertion[T]
  20. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  21. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. def haveCoderInstance(expectedCoder: Coder[_]): CoderAssertionBase
  24. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  25. def materializeTo[ExpectedBeamCoder](implicit arg0: ClassTag[ExpectedBeamCoder]): CoderAssertionBase
  26. def materializeToTransformOf[ExpectedBeamCoder](implicit arg0: ClassTag[ExpectedBeamCoder]): CoderAssertionBase
  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. def notFallback[T]()(implicit arg0: ClassTag[T], arg1: Equality[T]): CoderAssertion[T]
  29. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  30. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  31. def roundtrip[T]()(implicit arg0: Equality[T]): CoderAssertion[T]
  32. def roundtripToBytes[T](expectedBytes: Array[Byte])(implicit arg0: Equality[T]): CoderAssertion[T]
  33. def structuralValueConsistentWithEquals(): CoderAssertionBase

    Verifies that for the given coder and values, the structural values are equal if and only if the encoded bytes are equal.

    Verifies that for the given coder and values, the structural values are equal if and only if the encoded bytes are equal. Verifies for Outer and Nested contexts

  34. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  35. def toString(): String
    Definition Classes
    AnyRef → Any
  36. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  37. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  38. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped