A B C D E F G H I J K L M N O P Q R S T U V W

A

addAggregate(Consumer<AggregateBuilder<K, C, E, A>>) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

addAggregate(AggregateSpec<K, C, E, A>) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

addCommands(Consumer<CommandApiBuilder<K, C>>) - Method in class io.simplesource.kafka.dsl.EventSourcedClient

addCommands(CommandSpec<K, C>) - Method in class io.simplesource.kafka.dsl.EventSourcedClient

addShutdownHook(Logger, KafkaStreams) - Static method in class io.simplesource.kafka.util.KafkaStreamsUtils

adminClientConfig() - Method in class io.simplesource.kafka.dsl.KafkaConfig

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

aggregateKey() - Method in interface io.simplesource.kafka.api.CommandSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

aggregateKey() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

AggregateResources - Class in io.simplesource.kafka.api

AggregateResources() - Constructor for class io.simplesource.kafka.api.AggregateResources

AggregateResources.TopicEntity - Enum in io.simplesource.kafka.api

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

Responsible for providing the mechanism for reading and writing to Kafka from the Simple Sourcing Kafka Streams application when using the given serialization class.

AggregateSetSpec - Class in io.simplesource.kafka.spec

AggregateSetSpec() - Constructor for class io.simplesource.kafka.spec.AggregateSetSpec

AggregateSpec<K,C,E,A> - Class in io.simplesource.kafka.spec

AggregateSpec() - Constructor for class io.simplesource.kafka.spec.AggregateSpec

AggregateSpec.Generation<K,C,E,A> - Class in io.simplesource.kafka.spec

AggregateSpec.Serialization<K,C,E,A> - Class in io.simplesource.kafka.spec

AggregateTestDriver<K,C,E,A> - Class in io.simplesource.kafka.testutils

AggregateTestDriver(AggregateSpec<K, C, E, A>, KafkaConfig) - Constructor for class io.simplesource.kafka.testutils.AggregateTestDriver

AggregateTestHelper<K,C,E,A> - Class in io.simplesource.kafka.testutils

AggregateTestHelper(AggregateTestDriver<K, C, E, A>) - Constructor for class io.simplesource.kafka.testutils.AggregateTestHelper

AggregateTestHelper.PublishBuilder - Class in io.simplesource.kafka.testutils

AggregateTestHelper.PublishResponse - Class in io.simplesource.kafka.testutils

aggregateUpdate() - Method in interface io.simplesource.kafka.api.AggregateSerdes

AggregateUpdate<A> - Class in io.simplesource.kafka.model

AggregateUpdate() - Constructor for class io.simplesource.kafka.model.AggregateUpdate

aggregateUpdate() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

aggregateUpdate() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

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

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

applicationId() - Method in class io.simplesource.kafka.dsl.KafkaConfig

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.

AvroAggregateSerdes<K,C,E,A> - Class in io.simplesource.kafka.serialization.avro

AvroAggregateSerdes(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, GenericMapper<E, GenericRecord>, GenericMapper<A, GenericRecord>, String, boolean, Schema) - Constructor for class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

AvroCommandSerdes<K,C> - Class in io.simplesource.kafka.serialization.avro

AvroCommandSerdes(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, String, boolean) - Constructor for class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

AvroGenericUtils - Class in io.simplesource.kafka.serialization.avro

AvroGenericUtils() - Constructor for class io.simplesource.kafka.serialization.avro.AvroGenericUtils

AvroGenericUtils.SchemaNameStrategy - Enum in io.simplesource.kafka.serialization.avro

AvroGenericUtils.ValueWithSequenceAvroHelper - Class in io.simplesource.kafka.serialization.avro

AvroSerdes - Class in io.simplesource.kafka.serialization.avro

AvroSerdes() - Constructor for class io.simplesource.kafka.serialization.avro.AvroSerdes

AvroSpecificGenericMapper<D extends org.apache.avro.generic.GenericRecord> - Class in io.simplesource.kafka.serialization.avro

B

bootstrapServers() - Method in class io.simplesource.kafka.dsl.KafkaConfig

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

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

build() - Method in class io.simplesource.kafka.dsl.AggregateBuilder

build() - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

build() - Method in class io.simplesource.kafka.dsl.EventSourcedClient

build() - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

build(boolean) - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

Builder() - Constructor for class io.simplesource.kafka.dsl.KafkaConfig.Builder

C

close() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

close() - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

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.Request<K,C> - Class in io.simplesource.api

CommandApiBuilder<K,C> - Class in io.simplesource.kafka.dsl

CommandAPISet - Interface in io.simplesource.api

CommandError - Class in io.simplesource.api

A CommandError explains failures.

CommandError.Reason - Enum 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.

CommandId - Class in io.simplesource.api

CommandId() - Constructor for class io.simplesource.api.CommandId

commandId() - Method in interface io.simplesource.kafka.api.CommandSerdes

commandId() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandId() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandId() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandId() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

commandRequest() - Method in interface io.simplesource.kafka.api.CommandSerdes

CommandRequest<K,C> - Class in io.simplesource.kafka.model

CommandRequest() - Constructor for class io.simplesource.kafka.model.CommandRequest

commandRequest() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandRequest() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

commandResponse() - Method in interface io.simplesource.kafka.api.CommandSerdes

CommandResponse<K> - Class in io.simplesource.kafka.model

CommandResponse() - Constructor for class io.simplesource.kafka.model.CommandResponse

commandResponse() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

commandResponse() - Method in class io.simplesource.kafka.serialization.json.JsonCommandSerdes

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

Responsible for providing the mechanism for reading and writing to Kafka from the Simple Sourcing Kafka Streams application when using the given serialization class.

CommandSetSpec - Class in io.simplesource.kafka.spec

CommandSetSpec() - Constructor for class io.simplesource.kafka.spec.CommandSetSpec

CommandSpec<K,C> - Class in io.simplesource.kafka.spec

CommandSpec() - Constructor for class io.simplesource.kafka.spec.CommandSpec

compareTo(Sequence) - Method in class io.simplesource.data.Sequence

configure(Map<String, ?>, boolean) - Method in class io.simplesource.kafka.serialization.util.GenericSerde

consumerConfig() - Method in class io.simplesource.kafka.dsl.KafkaConfig

D

deserializer() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

E

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

equals(Object) - Method in class io.simplesource.data.Error.StringError

equals(Object) - Method in class io.simplesource.data.Error.ThrowableError

equals(Object) - Method in class io.simplesource.data.Result

equals(Object) - Method in class io.simplesource.data.Sequence

Error<Reason> - Interface in io.simplesource.data

A CommandError explains failures.

Error.StringError<Reason> - Class in io.simplesource.data

Error.ThrowableError<Reason> - Class in io.simplesource.data

errorMap(Function<E, F>) - Method in class io.simplesource.data.FutureResult

errorMap(Function<E, F>) - Method in class io.simplesource.data.Result

Modifies the error type of the result, returning a new Result

EventSourcedApp - Class in io.simplesource.kafka.dsl

EventSourcedApp() - Constructor for class io.simplesource.kafka.dsl.EventSourcedApp

EventSourcedClient - Class in io.simplesource.kafka.dsl

EventSourcedClient() - Constructor for class io.simplesource.kafka.dsl.EventSourcedClient

expecting(NonEmptyList<E>, A) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the publishCommand was success generating the given events and aggregate_update update.

expectingFailure(Consumer<NonEmptyList<CommandError>>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the call failed.

expectingFailure(NonEmptyList<CommandError.Reason>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder

Publish the command and assert that the call failed.

F

fail(E, E...) - Static method in class io.simplesource.data.FutureResult

fail(NonEmptyList<E>) - Static method in class io.simplesource.data.FutureResult

failure(E, E...) - Static method in class io.simplesource.data.Result

Factory method to creates a Failed Result from a array value of error

failure(NonEmptyList<E>) - Static method in class io.simplesource.data.Result

Factory method to creates a Failed Result from a {@link NonEmptyList< E >}}

failureReasons() - Method in class io.simplesource.data.Result

If this is a failure, return the error reasons for that failure, if not return nothing.

first() - Static method in class io.simplesource.data.Sequence

flatMap(Function<T, FutureResult<E, R>>) - Method in class io.simplesource.data.FutureResult

flatMap(Function<A, Result<E, T>>) - Method in class io.simplesource.data.Result

Runs the given function on the contents value this Result, returning a new Result with the extracted reason extracted from the functions returned Result<E, T>

fold(Function<NonEmptyList<E>, R>, Function<T, R>) - Method in class io.simplesource.data.FutureResult

fold(Function<A, B>, BiFunction<B, A, B>) - Method in class io.simplesource.data.NonEmptyList

fold(Function<NonEmptyList<E>, T>, Function<A, T>) - Method in class io.simplesource.data.Result

Turn this Result into a destination type by supplying functions from the list of failure errors, or a function from the contained value.

foldLeft(B, BiFunction<B, A, B>) - Method in class io.simplesource.data.NonEmptyList

fromGeneric(GenericRecord) - Method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

fromGeneric(JsonElement) - Method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

fromGeneric(JsonElement) - Method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

fromGeneric(S) - Method in interface io.simplesource.kafka.serialization.util.GenericMapper

fromGenericRecord(GenericRecord) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

fromList(List<A>) - Static method in class io.simplesource.data.NonEmptyList

future() - Method in class io.simplesource.data.FutureResult

FutureResult<E,T> - Class in io.simplesource.data

Represents an operation that calculates an Result asynchronously.

G

Generation() - Constructor for class io.simplesource.kafka.spec.AggregateSpec.Generation

genericAvroSerde(String, boolean, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils

genericAvroSerde(String, boolean, boolean, AvroGenericUtils.SchemaNameStrategy) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils

GenericMapper<V,S> - Interface in io.simplesource.kafka.serialization.util

Provides a mapping from your domain classes for aggregates, events, commands and keys to a generic serialization class used to read and write from Kafka.

GenericSerde<A,S> - Class in io.simplesource.kafka.serialization.util

get(int) - Method in class io.simplesource.data.NonEmptyList

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

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

getCommandAPISet(String) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

Creates a CommandAPISet instance Used for directly exposing a CommandAPISet from within a Simple Sourcing application If creating a CommandAPISet from an external application, rather use the CommandAPISetBuilder DSL

getCommandSpec(AggregateSpec<K, C, ?, ?>, String) - Static method in class io.simplesource.kafka.util.SpecUtils

getMessage() - Method in class io.simplesource.api.CommandError

The error message accessor

getMessage() - Method in interface io.simplesource.data.Error

The reason message accessor

getMessage() - Method in class io.simplesource.data.Error.StringError

getMessage() - Method in class io.simplesource.data.Error.ThrowableError

getOrElse(Supplier<Result<E, T>>, Function<Exception, E>) - Method in class io.simplesource.data.FutureResult

getOrElse(A) - Method in class io.simplesource.data.Result

Return the value contained within this Result if the Result.isSuccess() is true else return the default value provided.

getReason() - Method in class io.simplesource.api.CommandError

The reason value accessor.

getReason() - Method in interface io.simplesource.data.Error

The reason value accessor.

getReason() - Method in class io.simplesource.data.Error.StringError

getReason() - Method in class io.simplesource.data.Error.ThrowableError

getSeq() - Method in class io.simplesource.data.Sequence

H

hashCode() - Method in class io.simplesource.data.Error.StringError

hashCode() - Method in class io.simplesource.data.Error.ThrowableError

hashCode() - Method in class io.simplesource.data.Sequence

head() - Method in class io.simplesource.data.NonEmptyList

I

id - Variable in class io.simplesource.api.CommandId

ifSuccessful(Consumer<A>) - Method in class io.simplesource.data.Result

If a value is present, invoke the specified consumer with the value, otherwise do nothing.

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

Provides the initial value of an aggregate.

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

Determine whether you will accept the given command given the current aggregate and, if so, transform it into events.

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

This functional for accepting or rejecting commands executed against an out of date view.

InvalidSequenceStrategy - Enum in io.simplesource.kafka.dsl

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

io.simplesource.data - package io.simplesource.data

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

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

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

io.simplesource.kafka.model - package io.simplesource.kafka.model

io.simplesource.kafka.serialization.avro - package io.simplesource.kafka.serialization.avro

io.simplesource.kafka.serialization.json - package io.simplesource.kafka.serialization.json

io.simplesource.kafka.serialization.util - package io.simplesource.kafka.serialization.util

io.simplesource.kafka.spec - package io.simplesource.kafka.spec

io.simplesource.kafka.testutils - package io.simplesource.kafka.testutils

io.simplesource.kafka.util - package io.simplesource.kafka.util

isEqualTo(Sequence) - Method in class io.simplesource.data.Sequence

isExactlyOnce() - Method in class io.simplesource.kafka.dsl.KafkaConfig

isFailure() - Method in class io.simplesource.data.Result

Return true if this Result is a failure.

isGreaterThan(Sequence) - Method in class io.simplesource.data.Sequence

isGreaterThanOrEqual(Sequence) - Method in class io.simplesource.data.Sequence

isLessThan(Sequence) - Method in class io.simplesource.data.Sequence

isLessThanOrEqual(Sequence) - Method in class io.simplesource.data.Sequence

isSuccess() - Method in class io.simplesource.data.Result

Return true if this Result is a success.

J

JsonAggregateSerdes<K,C,E,A> - Class in io.simplesource.kafka.serialization.json

JsonAggregateSerdes() - Constructor for class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

JsonAggregateSerdes(GenericMapper<K, JsonElement>, GenericMapper<C, JsonElement>, GenericMapper<E, JsonElement>, GenericMapper<A, JsonElement>) - Constructor for class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

JsonCommandSerdes<K,C> - Class in io.simplesource.kafka.serialization.json

JsonCommandSerdes() - Constructor for class io.simplesource.kafka.serialization.json.JsonCommandSerdes

JsonCommandSerdes(GenericMapper<K, JsonElement>, GenericMapper<C, JsonElement>) - Constructor for class io.simplesource.kafka.serialization.json.JsonCommandSerdes

jsonDomainMapper() - Static method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

JsonGenericMapper<D> - Class in io.simplesource.kafka.serialization.json

jsonOptionalDomainMapper() - Static method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

JsonOptionalGenericMapper<D> - Class in io.simplesource.kafka.serialization.json

K

KafkaConfig - Class in io.simplesource.kafka.dsl

KafkaConfig() - Constructor for class io.simplesource.kafka.dsl.KafkaConfig

KafkaConfig.Builder - Class in io.simplesource.kafka.dsl

KafkaStreamsUtils - Class in io.simplesource.kafka.util

KafkaStreamsUtils() - Constructor for class io.simplesource.kafka.util.KafkaStreamsUtils

L

last() - Method in class io.simplesource.data.NonEmptyList

M

map(Function<T, R>) - Method in class io.simplesource.data.FutureResult

map(Function<A, B>) - Method in class io.simplesource.data.NonEmptyList

map(Function<A, T>) - Method in class io.simplesource.data.Result

Runs the given function on the contents value this Result, returning a new Result with the output value the result of that function.

map(Function<A, S>) - Method in class io.simplesource.kafka.model.AggregateUpdate

map(Function<K, KR>) - Method in class io.simplesource.kafka.model.CommandResponse

map(Function<V, S>) - Method in class io.simplesource.kafka.model.ValueWithSequence

map2(Function<K, KR>, Function<C, CR>) - Method in class io.simplesource.kafka.model.CommandRequest

N

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

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

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

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

next() - Method in class io.simplesource.data.Sequence

NonEmptyList<A> - Class in io.simplesource.data

A random access List implementation that is guaranteed to contain at least one item.

NonEmptyList(A, List<A>) - Constructor for class io.simplesource.data.NonEmptyList

O

of(CommandError.Reason, Throwable) - Static method in class io.simplesource.api.CommandError

Construct a CommandError from a Throwable.

of(CommandError.Reason, String) - Static method in class io.simplesource.api.CommandError

Construct a CommandError from a Throwable.

of(Reason, Throwable) - Static method in interface io.simplesource.data.Error

Construct a Error from a Throwable.

of(Reason, String) - Static method in interface io.simplesource.data.Error

Construct a Error from a Throwable.

of(T) - Static method in class io.simplesource.data.FutureResult

of(A, A...) - Static method in class io.simplesource.data.NonEmptyList

of(A) - Static method in class io.simplesource.kafka.model.AggregateUpdate

of(V) - Static method in class io.simplesource.kafka.model.ValueWithSequence

of(String, Schema) - Static method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

of(String, boolean, Schema) - Static method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

of(String) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(String, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(GenericMapper<K, GenericRecord>, GenericMapper<C, GenericRecord>, String, boolean) - Static method in class io.simplesource.kafka.serialization.avro.AvroCommandSerdes

of(Serde<S>, GenericMapper<A, S>) - Static method in class io.simplesource.kafka.serialization.util.GenericSerde

of(Serde<S>, Function<A, S>, Function<S, A>) - Static method in class io.simplesource.kafka.serialization.util.GenericSerde

of(int, int) - Static method in class io.simplesource.kafka.spec.TopicSpec

of(int, int, Map<String, String>) - Static method in class io.simplesource.kafka.spec.TopicSpec

ofCompletableFuture(CompletableFuture<Result<E, T>>) - Static method in class io.simplesource.data.FutureResult

ofFuture(Future<T>, Function<Exception, E>) - Static method in class io.simplesource.data.FutureResult

ofFutureResult(Future<Result<E, T>>, Function<Exception, E>) - Static method in class io.simplesource.data.FutureResult

ofResult(Result<E, T>) - Static method in class io.simplesource.data.FutureResult

ofSupplier(Supplier<Result<E, T>>) - Static method in class io.simplesource.data.FutureResult

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

pollForApiResponse() - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

position(long) - Static method in class io.simplesource.data.Sequence

PrefixResourceNamingStrategy - Class in io.simplesource.kafka.util

PrefixResourceNamingStrategy() - Constructor for class io.simplesource.kafka.util.PrefixResourceNamingStrategy

PrefixResourceNamingStrategy(String) - Constructor for class io.simplesource.kafka.util.PrefixResourceNamingStrategy

PrefixResourceNamingStrategy(String, String) - Constructor for class io.simplesource.kafka.util.PrefixResourceNamingStrategy

producerConfig() - Method in class io.simplesource.kafka.dsl.KafkaConfig

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.

publishCommand(CommandAPI.Request<K, C>) - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

publishCommand(K, Sequence, C) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper

Q

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

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

queryCommandResult(CommandId, Duration) - Method in class io.simplesource.kafka.testutils.AggregateTestDriver

R

random() - Static method in class io.simplesource.api.CommandId

registerExceptionHandler(Logger, KafkaStreams) - Static method in class io.simplesource.kafka.util.KafkaStreamsUtils

removeIf(Predicate<? super A>) - Method in class io.simplesource.data.NonEmptyList

replaceAll(UnaryOperator<A>) - Method in class io.simplesource.data.NonEmptyList

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

ResourceNamingStrategy - Interface in io.simplesource.kafka.api

Result<E,A> - Class in io.simplesource.data

A Result is either a success containing a value of the specified type, or a failure with a list value errors.

S

Sequence - Class in io.simplesource.data

A monotonically increasing identifier.

Serialization() - Constructor for class io.simplesource.kafka.spec.AggregateSpec.Serialization

serializer() - Method in class io.simplesource.kafka.serialization.util.GenericSerde

shouldReject(K, Sequence, Sequence, A, C) - Method in interface io.simplesource.api.InvalidSequenceHandler

The sequence handler is responsible for accepting or rejecting commands executed against an out of date view If expectedSeq == currentSeq this handler will not be invoked If this handler is invoked, it means the is executing a command against an old version of the aggregate

size() - Method in class io.simplesource.data.NonEmptyList

sort(Comparator<? super A>) - Method in class io.simplesource.data.NonEmptyList

specificDomainMapper() - Static method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

SpecUtils - Class in io.simplesource.kafka.util

SpecUtils() - Constructor for class io.simplesource.kafka.util.SpecUtils

start() - Method in class io.simplesource.kafka.dsl.EventSourcedApp

stateDir() - Method in class io.simplesource.kafka.dsl.KafkaConfig

streamsConfig() - Method in class io.simplesource.kafka.dsl.KafkaConfig

success(S) - Static method in class io.simplesource.data.Result

Factory method to creates a succesful Result from a value.

T

tail() - Method in class io.simplesource.data.NonEmptyList

thenPublish(C) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse

Combinator to chain together multiple publishCommand commands.

thenPublish(Function<AggregateUpdate<A>, ValueWithSequence<C>>) - Method in class io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse

Combinator to chain together multiple publishCommand commands.

toGeneric(D) - Method in class io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper

toGeneric(D) - Method in class io.simplesource.kafka.serialization.json.JsonGenericMapper

toGeneric(Optional<D>) - Method in class io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper

toGeneric(V) - Method in interface io.simplesource.kafka.serialization.util.GenericMapper

toGenericRecord(ValueWithSequence<GenericRecord>) - Static method in class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

toList() - Method in class io.simplesource.data.NonEmptyList

topicName(String, String) - Method in interface io.simplesource.kafka.api.ResourceNamingStrategy

Generate the Kafka topic name to use for a given aggregate domain.

topicName(String, String) - Method in class io.simplesource.kafka.util.PrefixResourceNamingStrategy

TopicSpec - Class in io.simplesource.kafka.spec

TopicSpec() - Constructor for class io.simplesource.kafka.spec.TopicSpec

toString() - Method in class io.simplesource.data.Error.StringError

toString() - Method in class io.simplesource.data.Error.ThrowableError

toString() - Method in class io.simplesource.data.Sequence

U

unsafePerform(Function<Exception, E>) - Method in class io.simplesource.data.FutureResult

V

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

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

valueOf(String) - Static method in enum io.simplesource.kafka.api.AggregateResources.TopicEntity

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

valueOf(String) - Static method in enum io.simplesource.kafka.dsl.InvalidSequenceStrategy

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

valueOf(String) - Static method in enum io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

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

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

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

values() - Static method in enum io.simplesource.kafka.api.AggregateResources.TopicEntity

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

values() - Static method in enum io.simplesource.kafka.dsl.InvalidSequenceStrategy

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

values() - Static method in enum io.simplesource.kafka.serialization.avro.AvroGenericUtils.SchemaNameStrategy

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

valueWithSequence() - Method in interface io.simplesource.kafka.api.AggregateSerdes

ValueWithSequence<V> - Class in io.simplesource.kafka.model

ValueWithSequence() - Constructor for class io.simplesource.kafka.model.ValueWithSequence

valueWithSequence() - Method in class io.simplesource.kafka.serialization.avro.AvroAggregateSerdes

valueWithSequence() - Method in class io.simplesource.kafka.serialization.json.JsonAggregateSerdes

ValueWithSequenceAvroHelper() - Constructor for class io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper

W

waitForShutdown(Logger, KafkaStreams) - Static method in class io.simplesource.kafka.util.KafkaStreamsUtils

waitUntilStable(Logger, KafkaStreams) - Static method in class io.simplesource.kafka.util.KafkaStreamsUtils

WindowSpec - Class in io.simplesource.kafka.spec

WindowSpec() - Constructor for class io.simplesource.kafka.spec.WindowSpec

withAggregator(Aggregator<E, A>) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withAtLeastOnce() - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withClientId(String) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withCommandHandler(CommandHandler<K, C, E, A>) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withCommandResponseRetention(long) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withCommandResponseRetention(long) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withDefaultTopicSpec(int, int, int) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withExactlyOnce() - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withInitialValue(InitialValue<K, A>) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withInvalidSequenceStrategy(InvalidSequenceStrategy) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withKafkaApplicationId(String) - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withKafkaBootstrap(String) - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withKafkaConfig(Function<KafkaConfig.Builder, KafkaConfig>) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

withKafkaConfig(KafkaConfig) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

withKafkaConfig(Function<? super KafkaConfig.Builder, KafkaConfig>) - Method in class io.simplesource.kafka.dsl.EventSourcedClient

withName(String) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withName(String) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withResourceNamingStrategy(ResourceNamingStrategy) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withResourceNamingStrategy(ResourceNamingStrategy) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withScheduler(ScheduledExecutorService) - Method in class io.simplesource.kafka.dsl.EventSourcedApp

withScheduler(ScheduledExecutorService) - Method in class io.simplesource.kafka.dsl.EventSourcedClient

withSerdes(AggregateSerdes<K, C, E, A>) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withSerdes(CommandSerdes<K, C>) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withSetting(String, Object) - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withSettings(Map<String, Object>) - Method in class io.simplesource.kafka.dsl.KafkaConfig.Builder

withTopicSpec(AggregateResources.TopicEntity, TopicSpec) - Method in class io.simplesource.kafka.dsl.AggregateBuilder

withTopicSpec(int, int) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

withTopicSpec(TopicSpec) - Method in class io.simplesource.kafka.dsl.CommandApiBuilder

A B C D E F G H I J K L M N O P Q R S T U V W