io.simplesource.kafka.serialization.avro.mappers

Class DomainMapperRegistry

java.lang.Object

io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry

public final class DomainMapperRegistry
extends Object

Constructor Summary

Constructors

Constructor and Description
DomainMapperRegistry()

Method Summary

Modifier and Type	Method and Description
<D,A extends org.apache.avro.generic.GenericRecord> Optional<io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry.RegistryMapper<D,A>>	mapperFor(Class clazz)
<D,A extends org.apache.avro.generic.GenericRecord> DomainMapperRegistry	register(Class<?> domainClazz, Class<?> avroClazz, java.util.function.Function<D,A> fromDomain, java.util.function.Function<A,D> toDomain)

Methods inherited from class java.lang.Object

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

Constructor Detail

DomainMapperRegistry

public DomainMapperRegistry()

Method Detail

mapperFor

public <D,A extends org.apache.avro.generic.GenericRecord> Optional<io.simplesource.kafka.serialization.avro.mappers.DomainMapperRegistry.RegistryMapper<D,A>> mapperFor(Class clazz)

register

public <D,A extends org.apache.avro.generic.GenericRecord> DomainMapperRegistry register(Class<?> domainClazz,
                                                                                         Class<?> avroClazz,
                                                                                         java.util.function.Function<D,A> fromDomain,
                                                                                         java.util.function.Function<A,D> toDomain)