Package | Description |
---|---|
io.simplesource.api | |
io.simplesource.kafka.api | |
io.simplesource.kafka.serialization.avro | |
io.simplesource.kafka.serialization.json | |
io.simplesource.kafka.testutils |
Modifier and Type | Method and Description |
---|---|
static CommandId |
CommandId.random() |
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,CommandId> |
CommandAPI.publishCommand(CommandAPI.Request<K,C> request)
Submit the given command ready for processing.
|
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,Sequence> |
CommandAPI.queryCommandResult(CommandId commandId,
java.time.Duration timeout)
Get the result of the execution of the command identified by the provided UUID.
|
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<CommandId> |
CommandSerdes.commandId() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<CommandId> |
AvroAggregateSerdes.commandId() |
org.apache.kafka.common.serialization.Serde<CommandId> |
AvroCommandSerdes.commandId() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.serialization.Serde<CommandId> |
JsonCommandSerdes.commandId() |
org.apache.kafka.common.serialization.Serde<CommandId> |
JsonAggregateSerdes.commandId() |
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,CommandId> |
AggregateTestDriver.publishCommand(CommandAPI.Request<K,C> request) |
Modifier and Type | Method and Description |
---|---|
FutureResult<CommandError,Sequence> |
AggregateTestDriver.queryCommandResult(CommandId commandId,
java.time.Duration timeout) |
Copyright © 2019. All rights reserved.