io.simplesource.saga.action.eventsourcing

Class EventSourcingBuilder

java.lang.Object

io.simplesource.saga.action.eventsourcing.EventSourcingBuilder

public final class EventSourcingBuilder
extends Object

A class with a single static function that returns an action processor build step for a simple sourcing event sourcing action.

An event sourcing action is an action that is processed as a simple sourcing command against an aggregate.

Simple sourcing records the version number of an aggregate, called a sequence number, and every successful command results in this sequence number being incremented. The event sourcing action processor will ensure that only the saga can write to the aggregate, and if any other writes to the aggregate occur during the saga, the saga will fail. An optimistic lock is essentially held on the aggregate for the duration of the saga.

Constructor Summary

Constructors

Constructor and Description
EventSourcingBuilder()

Method Summary

Modifier and Type	Method and Description
static <A,D,K,C> ActionProcessorBuildStep<A>	apply(EventSourcingSpec<A,D,K,C> esSpec)
static <A,D,K,C> ActionProcessorBuildStep<A>	apply(EventSourcingSpec<A,D,K,C> esSpec, TopicConfigBuilder.BuildSteps actionTopicBuilder, TopicConfigBuilder.BuildSteps commandTopicBuilder) A static function that returns an action processor build step that: 1.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventSourcingBuilder

public EventSourcingBuilder()

Method Detail

apply

public static <A,D,K,C> ActionProcessorBuildStep<A> apply(EventSourcingSpec<A,D,K,C> esSpec,
                                                          TopicConfigBuilder.BuildSteps actionTopicBuilder,
                                                          TopicConfigBuilder.BuildSteps commandTopicBuilder)

A static function that returns an action processor build step that: 1. Defines the stream topology for an EventSourcing processor 2. Computes topic configuration (names and configuration properties) for the action processor. This includes both the action request and response topics, and the command request and response topics.

Type Parameters:

A - - common representation form for all action commands (typically Json / GenericRecord for Avro)

D - - intermediate decoded input type (that can easily be converted to both K and C)

K - - aggregate key type

C - - simple sourcing command type

Parameters:

esSpec - data structure specifying how to turn the action request into a command request and interpret the result

actionTopicBuilder - the action topic builder - a mechanism for configuring the action topics

commandTopicBuilder - the command topic builder - a mechanism for configuring the simple sourcing command topics

Returns:

the action processor build step

apply

public static <A,D,K,C> ActionProcessorBuildStep<A> apply(EventSourcingSpec<A,D,K,C> esSpec)