Package | Description |
---|---|
io.apicurio.registry.utils.streams.diservice |
Modifier and Type | Interface and Description |
---|---|
static interface |
AsyncBiFunctionService.WithSerdes<K,REQ,RES>
An extension of
AsyncBiFunctionService providing Serde implementations:
AsyncBiFunctionService.WithSerdes.keySerde() , AsyncBiFunctionService.WithSerdes.reqSerde() and AsyncBiFunctionService.WithSerdes.resSerde() . |
Modifier and Type | Class and Description |
---|---|
class |
AsyncBiFunctionServiceGrpcClient<K,REQ,RES> |
class |
DistributedAsyncBiFunctionService<K,REQ,RES> |
Modifier and Type | Method and Description |
---|---|
protected AsyncBiFunctionService<K,REQ,RES> |
DistributedAsyncBiFunctionService.localService(String storeName,
org.apache.kafka.streams.KafkaStreams streams) |
protected AsyncBiFunctionService<K,REQ,RES> |
DistributedAsyncBiFunctionService.remoteServiceGrpcClient(String storeName,
io.grpc.Channel channel,
org.apache.kafka.common.serialization.Serde<K> keySerde) |
Copyright © 2020 Red Hat. All rights reserved.