cobalt
API
Generated with
cobalt/com.worxbend.cobalt/PendingWrite

PendingWrite

com.worxbend.cobalt.PendingWrite
final case class PendingWrite(record: ConsumerRecord[String, Array[Byte]], envelope: Envelope, event: NewEvent)

A record that decoded, together with everything the write path needs.

The original ConsumerRecord is kept even though the Envelope is fully decoded, because a record that the database later rejects still has to become a DeadLetter, and a dead letter is only replayable if it carries the original bytes and headers.

Attributes

Graph
Supertypes
trait Serializable
trait Product
trait Equals
class Object
trait Matchable
class Any
Show all

Members list

Value members

Inherited methods

def productElementNames: Iterator[String]

An iterator over the names of all the elements of this product.

An iterator over the names of all the elements of this product.

Attributes

Inherited from:
Product
def productIterator: Iterator[Any]

An iterator over all the elements of this product.

An iterator over all the elements of this product.

Attributes

Returns

in the default implementation, an Iterator[Any]

Inherited from:
Product
Generated with