A B C E G I N O P Q R V

A

Aggregator<E,A> - Interface in io.simplesource.api

An Aggregator is a function that builds up an aggregate from a stream of events (effectively a fold function).

AggregatorBuilder<E,A> - Class in io.simplesource.dsl

An builder for creating an Aggregator that can handle multiple event types by adding one or more single event aggregators.

applyEvent(A, E) - Method in interface io.simplesource.api.Aggregator

A function that takes the current aggregate value, the latest event and generates a new aggregate value.

B

build() - Method in class io.simplesource.dsl.AggregatorBuilder

build() - Method in class io.simplesource.dsl.CommandHandlerBuilder

C

CommandAPI<K,C> - Interface in io.simplesource.api

The public API for submitting commands against a given aggregate and querying where they have been successfully applied.

CommandAPI.CommandError - Enum in io.simplesource.api

CommandAPI.Request<K,C> - Class in io.simplesource.api

CommandAPISet - Interface in io.simplesource.api

CommandHandler<K,C,E,A> - Interface in io.simplesource.api

A command handler is responsible for accepting or rejecting commands and turning accepted commands into a list of events by applying the appropriate business logic and validations based on the current state.

CommandHandlerBuilder<K,C,E,A> - Class in io.simplesource.dsl

An builder for creating an CommandHandler that can handle several different commands types by adding one or more single command handlers.

E

empty(K) - Method in interface io.simplesource.api.InitialValue

G

getCommandAPI(String) - Method in interface io.simplesource.api.CommandAPISet

Provide access to the CommandAPI for any of the aggregates managed by this instance

I

ifSeq(CommandHandler<K, C, E, A>) - Static method in interface io.simplesource.api.CommandHandler

This method will wrap a CommandHandler in a check to ensure that the current aggregate sequence matches the expected aggregate sequence.

InitialValue<K,A> - Interface in io.simplesource.api

Provides the initial value of an aggregate .

interpretCommand(K, Sequence, Sequence, A, C) - Method in interface io.simplesource.api.CommandHandler

Determine if you will accept or reject the given command given the current aggregate aggregate and transform into events.

io.simplesource.api - package io.simplesource.api

io.simplesource.dsl - package io.simplesource.dsl

N

newBuilder() - Static method in class io.simplesource.dsl.AggregatorBuilder

newBuilder() - Static method in class io.simplesource.dsl.CommandHandlerBuilder

O

onCommand(Class<SC>, CommandHandler<K, SC, E, A>) - Method in class io.simplesource.dsl.CommandHandlerBuilder

onEvent(Class<SE>, Aggregator<SE, A>) - Method in class io.simplesource.dsl.AggregatorBuilder

P

publishAndQueryCommand(CommandAPI.Request<K, C>, Duration) - Method in interface io.simplesource.api.CommandAPI

Chain together publishing a command then query the result.

publishCommand(CommandAPI.Request<K, C>) - Method in interface io.simplesource.api.CommandAPI

Submit the given command ready for processing.

Q

queryCommandResult(UUID, Duration) - Method in interface io.simplesource.api.CommandAPI

Get the result of the execution of the command identified by the provided UUID.

R

Request() - Constructor for class io.simplesource.api.CommandAPI.Request

V

valueOf(String) - Static method in enum io.simplesource.api.CommandAPI.CommandError

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.simplesource.api.CommandAPI.CommandError

Returns an array containing the constants of this enum type, in the order they are declared.

A B C E G I N O P Q R V