Uses of Class
io.simplesource.kafka.dsl.AggregateBuilder

Packages that use AggregateBuilder

Package	Description
io.simplesource.kafka.dsl

Uses of AggregateBuilder in io.simplesource.kafka.dsl

Methods in io.simplesource.kafka.dsl that return AggregateBuilder

Modifier and Type	Method and Description
static <K,C,E,A> AggregateBuilder<K,C,E,A>	AggregateBuilder.newBuilder()
AggregateBuilder<K,C,E,A>	AggregateBuilder.withAggregator(Aggregator<E,A> aggregator)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withCommandHandler(CommandHandler<K,C,E,A> commandHandler)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withCommandResponseRetention(long retentionInSeconds)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withDefaultTopicSpec(int partitions, int replication, int retentionDays)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withInitialValue(InitialValue<K,A> initialValue)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withInvalidSequenceStrategy(InvalidSequenceStrategy invalidSequenceStrategy)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withName(String name)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withResourceNamingStrategy(ResourceNamingStrategy resourceNamingStrategy)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withSerdes(AggregateSerdes<K,C,E,A> aggregateSerdes)
AggregateBuilder<K,C,E,A>	AggregateBuilder.withTopicSpec(AggregateResources.TopicEntity topicEntity, TopicSpec topicSpec)

Method parameters in io.simplesource.kafka.dsl with type arguments of type AggregateBuilder

Modifier and Type	Method and Description
<K,C,E,A> EventSourcedApp	EventSourcedApp.addAggregate(java.util.function.Consumer<AggregateBuilder<K,C,E,A>> buildSteps)