Package | Description |
---|---|
io.apicurio.registry.streams | |
io.apicurio.registry.streams.distore |
Modifier and Type | Method and Description |
---|---|
FilterPredicate<String,Str.Data> |
StreamsRegistryConfiguration.filterPredicate() |
Modifier and Type | Method and Description |
---|---|
ExtReadOnlyKeyValueStore<String,Str.Data> |
StreamsRegistryConfiguration.storageKeyValueStore(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo storageLocalHost,
StreamsProperties properties,
FilterPredicate<String,Str.Data> filterPredicate) |
KeyValueStoreGrpc.KeyValueStoreImplBase |
StreamsRegistryConfiguration.streamsKeyValueStoreGrpcImpl(org.apache.kafka.streams.KafkaStreams streams,
StreamsProperties props,
FilterPredicate<String,Str.Data> filterPredicate) |
Constructor and Description |
---|
DistributedReadOnlyKeyValueStore(org.apache.kafka.streams.KafkaStreams streams,
org.apache.kafka.streams.state.HostInfo localApplicationServer,
String storeName,
org.apache.kafka.common.serialization.Serde<K> keySerde,
org.apache.kafka.common.serialization.Serde<V> valSerde,
Function<? super org.apache.kafka.streams.state.HostInfo,? extends io.grpc.Channel> grpcChannelProvider,
boolean parallel,
FilterPredicate<K,V> filterPredicate) |
ExtReadOnlyKeyValueStoreImpl(org.apache.kafka.streams.state.ReadOnlyKeyValueStore<K,V> delegate,
FilterPredicate<K,V> filterPredicate) |
KeyValueStoreGrpcImplLocalDispatcher(org.apache.kafka.streams.KafkaStreams streams,
KeyValueSerde.Registry keyValueSerdeRegistry,
FilterPredicate<?,?> filterPredicate) |
Copyright © 2020 Red Hat. All rights reserved.