Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.diservice | |
io.apicurio.registry.streams.utils |
Modifier and Type | Method and Description |
---|---|
LocalService<AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>> |
StreamsRegistryConfiguration.localStateService(StateService localService) |
LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> |
StreamsRegistryConfiguration.localWaitForDataService(WaitForDataService localService) |
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) |
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase |
StreamsRegistryConfiguration.storageAsyncBiFunctionServiceGrpcImpl(LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> localWaitForDataService,
LocalService<AsyncBiFunctionService.WithSerdes<Void,Void,org.apache.kafka.streams.KafkaStreams.State>> localStateService) |
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase |
StreamsRegistryConfiguration.storageAsyncBiFunctionServiceGrpcImpl(LocalService<AsyncBiFunctionService.WithSerdes<String,Long,Str.Data>> localWaitForDataService,
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) |
Constructor and Description |
---|
AsyncBiFunctionServiceGrpcLocalDispatcher(Collection<LocalService<? extends AsyncBiFunctionService.WithSerdes<?,?,?>>> localAsyncBiFunctionServices) |
DistributedAsyncBiFunctionService(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo localApplicationServer,
String storeName,
LocalService<? extends AsyncBiFunctionService.WithSerdes<K,REQ,RES>> localService,
Function<? super org.apache.kafka.streams.state.HostInfo,? extends io.grpc.Channel> grpcChannelProvider) |
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.