Skip navigation links
A C D F G I K L N R S T U W 

A

apply() - Method in class io.apicurio.registry.streams.utils.StateService
 
apply(Void, Void) - Method in class io.apicurio.registry.streams.utils.StateService
 
apply(String, Long) - Method in class io.apicurio.registry.streams.utils.WaitForDataService
 

C

close() - Method in class io.apicurio.registry.streams.utils.StateService
 
close() - Method in class io.apicurio.registry.streams.utils.WaitForDataService
 
createArtifact(String, ArtifactType, ContentHandle) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
createArtifactRuleAsync(String, RuleType, RuleConfigurationDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
createArtifactWithMetadata(String, ArtifactType, ContentHandle, EditableArtifactMetaDataDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
createGlobalRule(RuleType, RuleConfigurationDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 

D

dataDispatcher() - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
deleteArtifact(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteArtifactRule(String, RuleType) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteArtifactRules(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteArtifactRulesInternal(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteArtifactVersion(String, long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteArtifactVersionMetaData(String, long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteGlobalRule(RuleType) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deleteGlobalRules() - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
deserialize(String, byte[]) - Method in class io.apicurio.registry.streams.utils.StateSerde
 
destroy(ShutdownEvent, KafkaStreams) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
destroy(ShutdownEvent, Lifecycle) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
destroyGlobaIdStore(ShutdownEvent, ReadOnlyKeyValueStore<Long, Str.TupleValue>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
destroyStateService(ShutdownEvent, AsyncBiFunctionService<Void, Void, KafkaStreams.State>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
destroyStorageStore(ShutdownEvent, ExtReadOnlyKeyValueStore<String, Str.Data>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
destroyWaitForDataUpdateService(ShutdownEvent, AsyncBiFunctionService<String, Long, Str.Data>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 

F

filterPredicate() - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 

G

get() - Method in class io.apicurio.registry.streams.StreamsTopologyProvider
 
getApplicationServer() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getApplicationServer() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getArtifact(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactIds(Integer) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactMetaData(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactMetaData(String, ContentHandle) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactMetaData(long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactRule(String, RuleType) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactRules(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactVersion(long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactVersion(String, long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactVersionMetaData(String, long) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getArtifactVersions(String) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getBaseOffset() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getBaseOffset() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getGlobalIdStoreName() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getGlobalIdStoreName() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getGlobalIdTopic() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getGlobalIdTopic() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getGlobalRule(RuleType) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getGlobalRules() - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
getProperties() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getProperties() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getStorageStoreName() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getStorageStoreName() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
getStorageTopic() - Method in interface io.apicurio.registry.streams.StreamsProperties
 
getStorageTopic() - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 
GLOBAL_RULES_ID - Static variable in class io.apicurio.registry.streams.StreamsRegistryStorage
 
globalIdKeyValueStore(KafkaStreams, HostInfo, StreamsProperties) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 

I

init(StartupEvent, KafkaStreams) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
init(StartupEvent, Lifecycle) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
io.apicurio.registry.streams - package io.apicurio.registry.streams
 
io.apicurio.registry.streams.utils - package io.apicurio.registry.streams.utils
 
isAlive() - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
isReady() - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 

K

keySerde() - Method in class io.apicurio.registry.streams.utils.StateService
 
keySerde() - Method in class io.apicurio.registry.streams.utils.WaitForDataService
 

L

localStateService(StateService) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
localWaitForDataService(WaitForDataService) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 

N

NAME - Static variable in class io.apicurio.registry.streams.utils.StateService
 
NAME - Static variable in class io.apicurio.registry.streams.utils.WaitForDataService
 

R

reqSerde() - Method in class io.apicurio.registry.streams.utils.StateService
 
reqSerde() - Method in class io.apicurio.registry.streams.utils.WaitForDataService
 
resSerde() - Method in class io.apicurio.registry.streams.utils.StateService
 
resSerde() - Method in class io.apicurio.registry.streams.utils.WaitForDataService
 

S

searchArtifacts(String, int, int, SearchOver, SortOrder) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
searchVersions(String, int, int) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
serialize(String, KafkaStreams.State) - Method in class io.apicurio.registry.streams.utils.StateSerde
 
StateSerde - Class in io.apicurio.registry.streams.utils
KafkaStream state serde.
StateSerde() - Constructor for class io.apicurio.registry.streams.utils.StateSerde
 
stateService(KafkaStreams, HostInfo, LocalService<AsyncBiFunctionService.WithSerdes<Void, Void, KafkaStreams.State>>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
StateService - Class in io.apicurio.registry.streams.utils
Return KafkaStream state.
StateService(KafkaStreams) - Constructor for class io.apicurio.registry.streams.utils.StateService
 
stateServiceImpl(KafkaStreams) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
stopStorageProducer(ProducerActions<String, Str.StorageValue>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageAsyncBiFunctionServiceGrpcImpl(LocalService<AsyncBiFunctionService.WithSerdes<String, Long, Str.Data>>, LocalService<AsyncBiFunctionService.WithSerdes<Void, Void, KafkaStreams.State>>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageGrpcServer(HostInfo, KeyValueStoreGrpc.KeyValueStoreImplBase, AsyncBiFunctionServiceGrpc.AsyncBiFunctionServiceImplBase) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageKeyValueStore(KafkaStreams, HostInfo, StreamsProperties, FilterPredicate<String, Str.Data>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageLocalHost(StreamsProperties) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageProducer(Properties) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
storageStreams(StreamsProperties, ForeachAction<? super String, ? super Str.Data>, ArtifactTypeUtilProviderFactory) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
streamsKeyValueStoreGrpcImpl(KafkaStreams, StreamsProperties, FilterPredicate<String, Str.Data>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
StreamsProperties - Interface in io.apicurio.registry.streams
 
streamsProperties(Properties) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
StreamsPropertiesImpl - Class in io.apicurio.registry.streams
 
StreamsPropertiesImpl(Properties) - Constructor for class io.apicurio.registry.streams.StreamsPropertiesImpl
 
StreamsRegistryConfiguration - Class in io.apicurio.registry.streams
 
StreamsRegistryConfiguration() - Constructor for class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
StreamsRegistryStorage - Class in io.apicurio.registry.streams
 
StreamsRegistryStorage() - Constructor for class io.apicurio.registry.streams.StreamsRegistryStorage
 
StreamsTopologyProvider - Class in io.apicurio.registry.streams
Request --> Storage (topic / store) --> GlobalId (topic / store)
StreamsTopologyProvider(StreamsProperties, ForeachAction<? super String, ? super Str.Data>, ArtifactTypeUtilProviderFactory) - Constructor for class io.apicurio.registry.streams.StreamsTopologyProvider
 

T

toGlobalId(long, int) - Method in interface io.apicurio.registry.streams.StreamsProperties
 
toGlobalId(long, int) - Method in class io.apicurio.registry.streams.StreamsPropertiesImpl
 

U

updateArtifact(String, ArtifactType, ContentHandle) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactMetaData(String, EditableArtifactMetaDataDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactRule(String, RuleType, RuleConfigurationDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactState(String, ArtifactState) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactState(String, ArtifactState, Integer) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactVersionMetaData(String, long, EditableArtifactMetaDataDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateArtifactWithMetadata(String, ArtifactType, ContentHandle, EditableArtifactMetaDataDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 
updateGlobalRule(RuleType, RuleConfigurationDto) - Method in class io.apicurio.registry.streams.StreamsRegistryStorage
 

W

WaitForDataService - Class in io.apicurio.registry.streams.utils
This is a local implementation of our Data lookup AsyncBiFunctionService.
WaitForDataService(ReadOnlyKeyValueStore<String, Str.Data>, ForeachActionDispatcher<String, Str.Data>) - Constructor for class io.apicurio.registry.streams.utils.WaitForDataService
 
waitForDataServiceImpl(ReadOnlyKeyValueStore<String, Str.Data>, ForeachActionDispatcher<String, Str.Data>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
waitForDataUpdateService(StreamsProperties, KafkaStreams, HostInfo, LocalService<AsyncBiFunctionService.WithSerdes<String, Long, Str.Data>>) - Method in class io.apicurio.registry.streams.StreamsRegistryConfiguration
 
A C D F G I K L N R S T U W 
Skip navigation links

Copyright © 2020 Red Hat. All rights reserved.