Package com.cockroachlabs.data.cdc.test

Class CDCTestHarness

java.lang.Object

com.cockroachlabs.data.cdc.test.CDCTestHarness

public class CDCTestHarness
extends Object

Constructor Summary

Constructors

Constructor	Description
CDCTestHarness(CDCHandlerRegistry registry, CDCMethodInvoker invoker)

Method Summary

Modifier and Type	Method	Description
CDCEnvelope	buildRawEnvelope(CDCOperationType operation, Object entity, Object entityBefore, Object... keyParts)
Map<String,CDCHandlerRegistry.HandlerDescriptor>	getRegisteredHandlers()
<T> void	send(String endpoint, CDCEvent<T> event)
<T> void	sendBatch(String endpoint, List<CDCEvent<T>> events)
void	simulateDelete(String endpoint, Object... keyParts)
<T> void	simulateInsert(String endpoint, T entity, Object... keyParts)
void	simulateResolved(String endpoint, Instant timestamp)
<T> void	simulateUpdate(String endpoint, T before, T after, Object... keyParts)

Methods inherited from class java.lang.Object

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

Constructor Details

CDCTestHarness

public CDCTestHarness(CDCHandlerRegistry registry,
 CDCMethodInvoker invoker)

Method Details

simulateInsert

public <T> void simulateInsert(String endpoint,
 T entity,
 Object... keyParts)

simulateUpdate

public <T> void simulateUpdate(String endpoint,
 T before,
 T after,
 Object... keyParts)

simulateDelete

public void simulateDelete(String endpoint,
 Object... keyParts)

simulateResolved

public void simulateResolved(String endpoint,
 Instant timestamp)

send

public <T> void send(String endpoint,
 CDCEvent<T> event)

sendBatch

public <T> void sendBatch(String endpoint,
 List<CDCEvent<T>> events)

buildRawEnvelope

public CDCEnvelope buildRawEnvelope(CDCOperationType operation,
 Object entity,
 Object entityBefore,
 Object... keyParts)

getRegisteredHandlers

public Map<String,CDCHandlerRegistry.HandlerDescriptor> getRegisteredHandlers()