Class Hierarchy
- java.lang.Object
- java.util.AbstractCollection<E> (implements java.util.Collection<E>)
- io.simplesource.kafka.dsl.AggregateBuilder<K,C,E,A>
- io.simplesource.kafka.api.AggregateResources
- io.simplesource.kafka.spec.AggregateSetSpec
- io.simplesource.kafka.spec.AggregateSpec<K,C,E,A>
- io.simplesource.kafka.spec.AggregateSpec.Generation<K,C,E,A>
- io.simplesource.kafka.spec.AggregateSpec.Serialization<K,C,E,A>
- io.simplesource.kafka.testutils.AggregateTestDriver<K,C,E,A>
- io.simplesource.kafka.testutils.AggregateTestHelper<K,C,E,A>
- io.simplesource.kafka.testutils.AggregateTestHelper.PublishBuilder
- io.simplesource.kafka.testutils.AggregateTestHelper.PublishResponse
- io.simplesource.kafka.model.AggregateUpdate<A>
- io.simplesource.dsl.AggregatorBuilder<E,A>
- io.simplesource.kafka.serialization.avro.AvroAggregateSerdes<K,C,E,A> (implements io.simplesource.kafka.api.AggregateSerdes<K,C,E,A>)
- io.simplesource.kafka.serialization.avro.AvroCommandSerdes<K,C> (implements io.simplesource.kafka.api.CommandSerdes<K,C>)
- io.simplesource.kafka.serialization.avro.AvroGenericUtils
- io.simplesource.kafka.serialization.avro.AvroGenericUtils.ValueWithSequenceAvroHelper
- io.simplesource.kafka.serialization.avro.AvroSerdes
- io.simplesource.kafka.serialization.avro.AvroSpecificGenericMapper<D> (implements io.simplesource.kafka.serialization.util.GenericMapper<V,S>)
- io.simplesource.api.CommandAPI.Request<K,C>
- io.simplesource.kafka.dsl.CommandApiBuilder<K,C>
- io.simplesource.api.CommandError
- io.simplesource.dsl.CommandHandlerBuilder<K,C,E,A>
- io.simplesource.api.CommandId
- io.simplesource.kafka.model.CommandRequest<K,C>
- io.simplesource.kafka.model.CommandResponse<K>
- io.simplesource.kafka.spec.CommandSetSpec
- io.simplesource.kafka.spec.CommandSpec<K,C>
- io.simplesource.data.Error.StringError<Reason> (implements io.simplesource.data.Error<Reason>)
- io.simplesource.data.Error.ThrowableError<Reason> (implements io.simplesource.data.Error<Reason>)
- io.simplesource.kafka.dsl.EventSourcedApp
- io.simplesource.kafka.dsl.EventSourcedClient
- io.simplesource.data.FutureResult<E,T>
- io.simplesource.kafka.serialization.util.GenericSerde<A,S> (implements org.apache.kafka.common.serialization.Serde<T>)
- io.simplesource.kafka.serialization.json.JsonAggregateSerdes<K,C,E,A> (implements io.simplesource.kafka.api.AggregateSerdes<K,C,E,A>)
- io.simplesource.kafka.serialization.json.JsonCommandSerdes<K,C> (implements io.simplesource.kafka.api.CommandSerdes<K,C>)
- io.simplesource.kafka.serialization.json.JsonGenericMapper<D> (implements io.simplesource.kafka.serialization.util.GenericMapper<V,S>)
- io.simplesource.kafka.serialization.json.JsonOptionalGenericMapper<D> (implements io.simplesource.kafka.serialization.util.GenericMapper<V,S>)
- io.simplesource.kafka.dsl.KafkaConfig
- io.simplesource.kafka.dsl.KafkaConfig.Builder
- io.simplesource.kafka.util.KafkaStreamsUtils
- io.simplesource.kafka.util.PrefixResourceNamingStrategy (implements io.simplesource.kafka.api.ResourceNamingStrategy)
- io.simplesource.data.Result<E,A>
- io.simplesource.data.Sequence (implements java.lang.Comparable<T>)
- io.simplesource.kafka.util.SpecUtils
- io.simplesource.kafka.spec.TopicSpec
- io.simplesource.kafka.model.ValueWithSequence<V>
- io.simplesource.kafka.spec.WindowSpec
Interface Hierarchy
- io.simplesource.api.Aggregator<E,A>
- io.simplesource.api.CommandAPI<K,C>
- io.simplesource.api.CommandAPISet
- io.simplesource.api.CommandHandler<K,C,E,A>
- io.simplesource.kafka.api.CommandSerdes<K,C>
- io.simplesource.data.Error<Reason>
- io.simplesource.kafka.serialization.util.GenericMapper<V,S>
- io.simplesource.api.InitialValue<K,A>
- io.simplesource.api.InvalidSequenceHandler<K,C,A>
- io.simplesource.kafka.api.ResourceNamingStrategy
Enum Hierarchy
Copyright © 2019. All rights reserved.