Package com.cockroachlabs.data.cdc.test

Class CDCEventBuilder<T>

java.lang.Object

com.cockroachlabs.data.cdc.test.CDCEventBuilder<T>

public final class CDCEventBuilder<T>
extends Object

Method Summary

Modifier and Type	Method	Description
CDCEventBuilder<T>	after(T after)
CDCEventBuilder<T>	before(T before)
CDCEvent<T>	build()
CDCEnvelope	buildAsEnvelope(tools.jackson.databind.ObjectMapper objectMapper)
String	buildAsJson()
String	buildAsJson(tools.jackson.databind.ObjectMapper objectMapper)
static <T> CDCEventBuilder<T>	create()
static <T> CDCEnvelope	deleteEnvelope(tools.jackson.databind.ObjectMapper objectMapper, Object... keyParts)
static <T> CDCEnvelope	insertEnvelope(T entity, tools.jackson.databind.ObjectMapper objectMapper, Object... keyParts)
CDCEventBuilder<T>	key(Object... keyParts)
CDCEventBuilder<T>	operation(CDCOperationType operation)
static CDCEnvelope	resolvedEnvelope(Instant timestamp)
CDCEventBuilder<T>	table(String table)
CDCEventBuilder<T>	timestamp(Instant timestamp)
static <T> CDCEnvelope	updateEnvelope(T before, T after, tools.jackson.databind.ObjectMapper objectMapper, Object... keyParts)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static <T> CDCEventBuilder<T> create()

operation

public CDCEventBuilder<T> operation(CDCOperationType operation)

after

public CDCEventBuilder<T> after(T after)

before

public CDCEventBuilder<T> before(T before)

key

public CDCEventBuilder<T> key(Object... keyParts)

table

public CDCEventBuilder<T> table(String table)

timestamp

public CDCEventBuilder<T> timestamp(Instant timestamp)

build

public CDCEvent<T> build()

buildAsEnvelope

public CDCEnvelope buildAsEnvelope(tools.jackson.databind.ObjectMapper objectMapper)

buildAsJson

public String buildAsJson(tools.jackson.databind.ObjectMapper objectMapper)

buildAsJson

public String buildAsJson()

resolvedEnvelope

public static CDCEnvelope resolvedEnvelope(Instant timestamp)

insertEnvelope

public static <T> CDCEnvelope insertEnvelope(T entity,
 tools.jackson.databind.ObjectMapper objectMapper,
 Object... keyParts)

updateEnvelope

public static <T> CDCEnvelope updateEnvelope(T before,
 T after,
 tools.jackson.databind.ObjectMapper objectMapper,
 Object... keyParts)

deleteEnvelope

public static <T> CDCEnvelope deleteEnvelope(tools.jackson.databind.ObjectMapper objectMapper,
 Object... keyParts)