Interface | Description |
---|---|
AsyncBiFunctionService<K,REQ,RES> |
A
BiFunction that returns an asynchronous CompletionStage result. |
AsyncBiFunctionService.WithSerdes<K,REQ,RES> |
An extension of
AsyncBiFunctionService providing Serde implementations:
AsyncBiFunctionService.WithSerdes.keySerde() , AsyncBiFunctionService.WithSerdes.reqSerde() and AsyncBiFunctionService.WithSerdes.resSerde() . |
Class | Description |
---|---|
AsyncBiFunctionServiceGrpcClient<K,REQ,RES> | |
AsyncBiFunctionServiceGrpcLocalDispatcher | |
DefaultGrpcChannelProvider |
Default plain-text gRPC Channel provider.
|
DistributedAsyncBiFunctionService<K,REQ,RES> | |
DistributedService<K,S> |
A service base class for services that are distributed among
KafkaStreams processing
nodes comprising the distributed streams application. |
LocalService<S> |
A holder of local streams service with accompanying serviceName
|
LocalService.Registry<S> | |
StreamObserverCompletableFuture<T> |
Copyright © 2020 Red Hat. All rights reserved.