JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2020
Red Hat
. All rights reserved.