Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.diservice | |
io.apicurio.registry.streams.utils |
Modifier and Type | Method and Description |
---|---|
AsyncBiFunctionService<Void,Void,org.apache.kafka.streams.KafkaStreams.State> |
StreamsRegistryConfiguration.stateService(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
LocalService<AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>> localStateService) |
AsyncBiFunctionService<String,Long,Str.Data> |
StreamsRegistryConfiguration.waitForDataUpdateService(StreamsProperties properties,
org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> localWaitForDataUpdateService) |
Modifier and Type | Method and Description |
---|---|
void |
StreamsRegistryConfiguration.destroyStateService(io.quarkus.runtime.ShutdownEvent event,
AsyncBiFunctionService<Void,Void,org.apache.kafka.streams.KafkaStreams.State> service) |
void |
StreamsRegistryConfiguration.destroyWaitForDataUpdateService(io.quarkus.runtime.ShutdownEvent event,
AsyncBiFunctionService<String,Long,Str.Data> service) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
StateService
Return KafkaStream state.
|
class |
WaitForDataService
This is a local implementation of our Data lookup AsyncBiFunctionService.
|
Copyright © 2020 Red Hat. All rights reserved.