Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.distore |
Modifier and Type | Method and Description |
---|---|
KeyValueStoreGrpc.KeyValueStoreImplBase |
StreamsRegistryConfiguration.streamsKeyValueStoreGrpcImpl(org.apache.kafka.streams.KafkaStreams streams,
StreamsProperties props,
FilterPredicate<String,Str.Data> filterPredicate) |
Modifier and Type | Method and Description |
---|---|
Lifecycle |
StreamsRegistryConfiguration.storageGrpcServer(org.apache.kafka.streams.state.HostInfo storageLocalHost,
KeyValueStoreGrpc.KeyValueStoreImplBase storageStoreGrpcImpl,
AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase storageAsyncBiFunctionServiceGrpcImpl) |
Modifier and Type | Class and Description |
---|---|
class |
KeyValueStoreGrpcImplLocalDispatcher
Concrete implementation of
KeyValueStoreGrpc.KeyValueStoreImplBase that dispatches the
gRPC requests to the appropriately named local ReadOnlyKeyValueStore
obtained from given KafkaStreams instance. |
Copyright © 2020 Red Hat. All rights reserved.