Index (Azkarra Framework 0.9.0 API)

A B C D E F G H I J K L M N O P Q R S T U V W X
All Classes All Packages

A

abort() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
AbstractAuthentication<T extends Credentials> - Class in io.streamthoughts.azkarra.http.security.auth
AbstractAuthentication(Principal, T) - Constructor for class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication: Creates a new AbstractAuthentication instance.
AbstractAzkarraStreamsService - Class in io.streamthoughts.azkarra.runtime.service
AbstractAzkarraStreamsService() - Constructor for class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Creates a new AbstractAzkarraStreamsService instance.
AbstractConf - Class in io.streamthoughts.azkarra.api.config
AbstractConf() - Constructor for class io.streamthoughts.azkarra.api.config.AbstractConf
AbstractConfigEntryLoader - Class in io.streamthoughts.azkarra.streams
AbstractConfigEntryLoader(String) - Constructor for class io.streamthoughts.azkarra.streams.AbstractConfigEntryLoader: Creates a new AbstractConfigEntryLoader instance.
AbstractResultSet - Class in io.streamthoughts.azkarra.api.query.result
AbstractStreamHttpHandler - Class in io.streamthoughts.azkarra.http.handler
AbstractStreamHttpHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.AbstractStreamHttpHandler: Creates a new AbstractStreamHttpHandler instance.
AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>> - Class in io.streamthoughts.azkarra.runtime
AbstractTopologyStreamsExecution(E, StreamsTopologyMeta, Executed) - Constructor for class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution: Creates a new AbstractTopologyStreamsExecution instance.
accept(State) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.StateChangeWatcher: Should this watcher be called for the given State.
accept(Class<?>) - Method in interface io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.ClassAliasExtractor
accept(Class<?>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.DropClassNameSuffixExtractor
accept(String) - Method in class io.streamthoughts.azkarra.streams.AbstractConfigEntryLoader: Checks whether this loader supported the specified root config key.
accept(String) - Method in interface io.streamthoughts.azkarra.streams.ApplicationConfigEntryLoader: Checks whether this loader supported the specified root config key.
accept(String) - Method in class io.streamthoughts.azkarra.streams.NoopConfigEntryLoader
activeTasks(List<V1TaskMetadata>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
Adapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum.Adapter
Adapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum.Adapter
add(String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
add(String, Object, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
addActiveTasksItem(V1TaskMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
addAliases(Set<String>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Adds new aliases to reference the described component.
addAliases(Set<String>) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Adds new aliases to reference the described component.
addAliases(Set<String>) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Adds new aliases to reference the described component.
addAssignmentsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
addAttribute(ComponentAttribute) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata: Adds the specified attribute.
addClassAliasExtractor(ClassComponentAliasesGenerator.ClassAliasExtractor) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator
addConfigEntryLoader(ApplicationConfigEntryLoader) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Adds a new ApplicationConfigEntryLoader to be used for reading the application configuration.
addConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds the specified Conf to the configuration of this AzkarraContext.
addConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds a new configuration to this environment.
addConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds the specified Conf to the configuration of this AzkarraContext.
addConfiguration(Conf) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Adds the specified Conf to the configuration of this AzkarraApplication.
addConfiguration(Supplier<Conf>) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds a new configuration to this environment.
addConfiguration(Supplier<Conf>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a new configuration to this environment.
addConsumersItem(V1StreamsConsumerClientOffsets) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
addDefaultCookie(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Add a default cookie.
addDefaultHeader(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Add a default header.
addErrorsItem(V1Error) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
addEventStream(EventStream<K, V>) - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport
addEventStreamsWithDefaults(String...) - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport
addExecutionEnvironment(StreamsExecutionEnvironment<?>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds the StreamsExecutionEnvironment to this context.
addExecutionEnvironment(StreamsExecutionEnvironment<?>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds the StreamsExecutionEnvironment to this context.
addFactory(StreamsExecutionEnvironmentFactory<?>) - Method in class io.streamthoughts.azkarra.runtime.StreamsExecutionEnvironmentAbstractFactory: Adds a new StreamsExecutionEnvironmentFactory to this one.
addFailureItem(V1QueryErrorResultSet) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
addFallbackConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.
addFallbackConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.
addGlobalStateListener(StateRestoreListener) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addGlobalStoresItem(V1StreamsGlobalStore) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
addHandler(Thread.UncaughtExceptionHandler) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler
addInterceptors(Collection<StreamsLifecycleInterceptor>) - Method in class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor
addListener(AzkarraContextListener) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Registers a new listener instance to this context.
addListener(AzkarraContextListener) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Registers a new listener instance to this context.
addListener(KafkaStreams.StateListener) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener
addListener(StateRestoreListener) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
addMetricsItem(V1Metric) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
addNewEnvironment(String, String, Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Adds a new environment to this application.
addNewEnvironment(String, String, Conf) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Adds a new environment to this application.
addNodesItem(V1StreamsTopologyNode) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
addPartitionLagInfosItem(V1StatePartitionLagInfo) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
addPartitionRestoreInfosItem(V1StatePartitionRestoreInfo) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
addPositionsItem(V1StreamsConsumerLogOffsets) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
addProducerClientIdsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
addRecordsItem(V1Record) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
address() - Method in class io.streamthoughts.azkarra.api.util.Endpoint
addSource(Class<?>) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Adds a class source which must be used for initializing this AzkarraApplication.
addSources(Class<?>...) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Adds a class sources which must be used for initializing this AzkarraApplication.
addStandbyAssignmentsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
addStandbyStateStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
addStandbyTasksItem(V1TaskMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Register a watcher to be notified of KafkaStreams.State change event.
addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Register a watcher to be notified of KafkaStreams.State change event.
addStateListener(KafkaStreams.StateListener) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addStateStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
addStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
addStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
addStreamsConfiguration(Supplier<Conf>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Helper method to add a configuration prefixed with 'streams.'.
addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a streams interceptor that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addSubTopologiesItem(V1StreamsSubTopology) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
addSuccessItem(V1QuerySuccessResultSet) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
addThreadsItem(V1ThreadMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
addTopicPartitionsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
addTopicsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
addTopicsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
addTopology(Class<? extends TopologyProvider>, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds a topology to the default environment of this context.
addTopology(Class<? extends TopologyProvider>, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds a topology to the default environment of this context.
addTopology(Class<? extends TopologyProvider>, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds a topology to a specified environment.
addTopology(Class<? extends TopologyProvider>, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds a topology to a specified environment.
addTopology(String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds a topology to the default environment of this context.
addTopology(String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds a topology to the default environment of this context.
addTopology(String, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds a topology to a specified environment.
addTopology(String, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds a topology to a specified environment.
addTopology(String, String, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds a topology to a specified environment.
addTopology(String, String, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Adds a topology to a specified environment.
addTopology(Supplier<TopologyProvider>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a new TopologyProvider instance to this StreamsExecutionEnvironment.
addTopology(Supplier<TopologyProvider>, Executed) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Adds a new TopologyProvider instance to this StreamsExecutionEnvironment.
addUsers(UserDetails) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
adminClientId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
AdminClientUtils - Class in io.streamthoughts.azkarra.api.streams.admin
AdminClientUtils() - Constructor for class io.streamthoughts.azkarra.api.streams.admin.AdminClientUtils
aggregate(List<Health>) - Method in class io.streamthoughts.azkarra.http.health.HealthAggregator: Aggregates the specified Health instances to a single one.
aggregateStatus(List<Status>) - Method in class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator: Aggregates the the specified list of status.
aggregateStatus(List<Status>) - Method in interface io.streamthoughts.azkarra.http.health.StatusAggregator: Aggregates the the specified list of status.
aliases() - Method in annotation type io.streamthoughts.azkarra.api.annotations.TopologyInfo: Gets the aliases used to register this the Topology.
aliases() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the set of aliases for this component.
aliases() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Gets the set of aliases for this component.
aliases() - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
aliases() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Gets the set of aliases for this component.
all() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
all() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueQueryBuilder
all() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
all() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
all() - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
all(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
all(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
ALL - io.streamthoughts.azkarra.api.query.StoreOperation
allGrantedAuthorities() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
allInstances() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
allLocalStorePartitionInfos() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the partition restoration and lag for all local state store.
allLocalStorePartitionInfos() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets the partition restoration and lag for all local state store.
allOf() - Static method in class io.streamthoughts.azkarra.api.util.FutureCollectors
allOf(List<Error>) - Static method in class io.streamthoughts.azkarra.api.query.result.QueryError
AllowAllHostNameVerifier - Class in io.streamthoughts.azkarra.http.security: A HostnameVerifier that accept all certificates.
AllowAllHostNameVerifier() - Constructor for class io.streamthoughts.azkarra.client.HttpClientBuilder.AllowAllHostNameVerifier
AllowAllHostNameVerifier() - Constructor for class io.streamthoughts.azkarra.http.security.AllowAllHostNameVerifier
ALLOWED - io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult
AlreadyExistsException - Exception in io.streamthoughts.azkarra.api.errors: Thrown if an application or an environment already exists.
AlreadyExistsException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AlreadyExistsException: Creates a new AlreadyExistsException instance.
AnnotationResolver - Class in io.streamthoughts.azkarra.api.util
AnnotationResolver() - Constructor for class io.streamthoughts.azkarra.api.util.AnnotationResolver
AnnotationResolver.AnnotationFilter - Interface in io.streamthoughts.azkarra.api.util
AnnotationResolver.PackageAnnotationFilter - Class in io.streamthoughts.azkarra.api.util
AnnotationResolver.TypeAnnotationFilter - Class in io.streamthoughts.azkarra.api.util
any(Condition...) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions: Specify that ANY of the given condition should be true for a component to be eligible for use.
any(List<? extends Condition>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions: Specify that ANY of the given condition should be true for a component to be eligible for use.
AnyQualifier<T> - Class in io.streamthoughts.azkarra.api.components.qualifier
AnyQualifier(List<Qualifier<T>>) - Constructor for class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier: Creates a new AnyQualifier instance.
ApiApplicationsRoutes - Class in io.streamthoughts.azkarra.http.routes: This class defines all routes for API '/applications'.
ApiApplicationsRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiApplicationsRoutes: Creates a new ApiApplicationsRoutes instance.
ApiCallback<T> - Interface in io.streamthoughts.azkarra.client.openapi: Callback for asynchronous API call.
ApiClient - Class in io.streamthoughts.azkarra.client.openapi
ApiClient() - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiClient
ApiClient(OkHttpClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiClient
ApiContextRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiContextRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiContextRoutes
ApiDefaultRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiDefaultRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes
ApiDocHttpRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiDocHttpRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiDocHttpRoutes
ApiEnvironmentRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiEnvironmentRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
ApiException - Exception in io.streamthoughts.azkarra.client.openapi
ApiException() - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(int, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(int, String, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(String, int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(String, Throwable, int, Map<String, List<String>>) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(String, Throwable, int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiException(Throwable) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
ApiHealthRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiHealthRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
ApiInfoRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiInfoRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
ApiKeyAuth - Class in io.streamthoughts.azkarra.client.openapi.auth
ApiKeyAuth(String, String) - Constructor for class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
ApiOnFailureCallback - Interface in io.streamthoughts.azkarra.http.query
ApiResponse<T> - Class in io.streamthoughts.azkarra.client.openapi: API response returned by API call.
ApiResponse(int, Map<String, List<String>>) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiResponse
ApiResponse(int, Map<String, List<String>>, T) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiResponse
ApiStreamsRoutes - Class in io.streamthoughts.azkarra.http.routes: This class defines all routes for API '/streams'.
ApiStreamsRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiStreamsRoutes
ApiTopologyRoutes - Class in io.streamthoughts.azkarra.http.routes: This class defines all routes for API '/topologies'.
ApiTopologyRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiTopologyRoutes: Creates a new ApiTopologyRoutes instance.
ApiVersionRoutes - Class in io.streamthoughts.azkarra.http.routes: This class defines all routes for API '/version'.
ApiVersionRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
APIVersions - Class in io.streamthoughts.azkarra.http
APIVersions() - Constructor for class io.streamthoughts.azkarra.http.APIVersions
application() - Static method in class io.streamthoughts.azkarra.api.components.Restriction
ApplicationConfigEntryLoader - Interface in io.streamthoughts.azkarra.streams
ApplicationConfigLoader - Class in io.streamthoughts.azkarra.streams
ApplicationConfigLoader(List<ApplicationConfigEntryLoader>) - Constructor for class io.streamthoughts.azkarra.streams.ApplicationConfigLoader
applicationId() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets configured StreamsConfig.APPLICATION_ID_CONFIG for this KafkaStreams instance.
applicationId() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleContext
applicationId() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
applicationId() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets configured StreamsConfig.APPLICATION_ID_CONFIG for this KafkaStreams instance.
ApplicationId - Class in io.streamthoughts.azkarra.api: An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.
ApplicationId(String) - Constructor for class io.streamthoughts.azkarra.api.ApplicationId: Creates a new ApplicationId for specified id.
ApplicationIdBuilder - Interface in io.streamthoughts.azkarra.api.streams: Class for building StreamsConfig.APPLICATION_ID_CONFIG.
ApplicationQueryStoreHandler - Class in io.streamthoughts.azkarra.http.handler
ApplicationQueryStoreHandler(InteractiveQueryService, boolean) - Constructor for class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler: Creates a new ApplicationQueryStoreHandler instance.
applications() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
applicationServer() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
apply() - Method in interface io.streamthoughts.azkarra.commons.rocksdb.internal.ResourceInitializer: Creates a new resource.
apply() - Method in interface io.streamthoughts.azkarra.runtime.util.ShutdownHook.Hook
apply(A) - Method in class io.streamthoughts.azkarra.api.monad.Reader
apply(MeterRegistry) - Method in class io.streamthoughts.azkarra.metrics.micrometer.MicrometerMeterRegistryConfigurer: Applies this configurer to the given meter registry.
apply(ComponentDescriptor<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorModifier: Modifies the given ComponentDescriptor.
apply(String) - Method in interface io.streamthoughts.examples.azkarra.conditional.ConditionalStreamsApplication.Normalize
apply(T) - Method in interface io.streamthoughts.azkarra.api.monad.CheckedFunction
apply(T) - Method in interface io.streamthoughts.azkarra.metrics.micrometer.MeterRegistryConfigurer: Applies this configurer to the given meter registry.
applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in interface io.streamthoughts.azkarra.client.openapi.auth.Authentication: Apply authentication settings to header and query params.
applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBearerAuth
ArgsConf - Class in io.streamthoughts.azkarra.api.config: A Conf which is build from a list of arguments.
ArgsConf(String[]) - Constructor for class io.streamthoughts.azkarra.api.config.ArgsConf: Creates a new ArgsConf instance.
arrayValue(String, String) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata: Gets the array value for the specified attribute name and member.
as(String) - Static method in class io.streamthoughts.azkarra.api.Executed: Static helper that can be used to creates a new Executed instance with the specified streams name.
as(String, String) - Static method in class io.streamthoughts.azkarra.api.Executed: Static helper that can be used to creates a new Executed instance with the specified streams name and description.
asBoolean() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as an boolean.
asDouble() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a double.
asEager() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers: Gets a modifier implementation that will set a component as eager.
asInt() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as an integer.
asLong() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets valuer as a long.
asPrimary() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers: Gets a modifier implementation that will set a component as primary.
asProperty() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Get the ConfEntry as Property.
asSecondary() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers: Gets a modifier implementation that will set a component as secondary.
assignments() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsMetadata: Gets the set of topic-partitions assigned to this instance.
assignments(Set<V1TopicPartition>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
asString() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a string.
asStringList() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a list.
asSubConf() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a Conf.
asSubConfList() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a list of Conf.
AsyncMulticastEventStreamPublisher<K,V> - Class in io.streamthoughts.azkarra.api.events.reactive: The AsyncMulticastEventStreamPublisher is an implementation of Reactive Streams Flow.Publisher which executes asynchronously, using an internal single-thread Executor.
AsyncMulticastEventStreamPublisher(EventStream<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.reactive.AsyncMulticastEventStreamPublisher: Creates a new AsyncMulticastEventStreamPublisher instance.
AsyncQueryApiCallback<K,V> - Class in io.streamthoughts.azkarra.http.query
AsyncQueryApiCallback(CompletableFuture<QueryResult<K, V>>, ApiOnFailureCallback) - Constructor for class io.streamthoughts.azkarra.http.query.AsyncQueryApiCallback: Creates a new AsyncQueryApiCallback instance.
AtLeastOnce - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to automatically set the streams property processing.guarantee to at_least_once.
attributes() - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata: Gets all attributes.
attributes() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
attributesForName(String) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata: Gets all attributes for the given name.
authenticate(Authentication) - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationManager: Performs the authentication.
authenticate(AuthorizationContext) - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationManager
authenticate(AuthorizationContext) - Method in class io.streamthoughts.azkarra.http.security.authorizer.SimpleAuthorizationManager
authenticate(Principal, Credentials) - Method in interface io.streamthoughts.azkarra.http.security.auth.Authenticator: Authenticates the current user for the specified principal and credentials.
authenticate(Principal, Credentials) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicAuthenticator: Authenticates the current user for the specified principal and credentials.
authenticate(Principal, Credentials) - Method in class io.streamthoughts.azkarra.http.security.auth.CertClientAuthenticator: Authenticates the current user for the specified principal and credentials.
authenticate(Route, Response) - Method in class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator
Authentication - Interface in io.streamthoughts.azkarra.client.openapi.auth
Authentication - Interface in io.streamthoughts.azkarra.http.security.auth
AuthenticationCallback<T extends Authentication> - Class in io.streamthoughts.azkarra.http.security.jaas.spi
AuthenticationCallback() - Constructor for class io.streamthoughts.azkarra.http.security.jaas.spi.AuthenticationCallback
AuthenticationContext - Interface in io.streamthoughts.azkarra.http.security.auth
AuthenticationContextHandler - Class in io.streamthoughts.azkarra.http.security.handler
AuthenticationContextHandler(SecurityMechanism, HttpHandler) - Constructor for class io.streamthoughts.azkarra.http.security.handler.AuthenticationContextHandler: Creates a new AuthenticationContextHandler instance.
AuthenticationContextHolder - Class in io.streamthoughts.azkarra.http.security.auth: Class used to hold information about current authenticated principal.
AuthenticationContextHolder() - Constructor for class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder
AuthenticationManager - Interface in io.streamthoughts.azkarra.http.security.auth
authenticator(Authenticator) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder
Authenticator - Interface in io.streamthoughts.azkarra.http.security.auth: Interface to authenticate users.
authorities() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext: Gets the list of authorities granted to the authenticated used.
AuthorizationContext - Interface in io.streamthoughts.azkarra.http.security.authorizer
AuthorizationHandler - Class in io.streamthoughts.azkarra.http.security.authorizer
AuthorizationHandler(HttpHandler, AuthorizationManager, AzkarraPrincipalBuilder) - Constructor for class io.streamthoughts.azkarra.http.security.authorizer.AuthorizationHandler: Creates a new AuthorizationHandler instance.
AuthorizationManager - Interface in io.streamthoughts.azkarra.http.security.authorizer: Pluggable interface which is used to authenticate users.
AuthorizationResult - Enum in io.streamthoughts.azkarra.http.security.authorizer
AUTO_CREATE_TOPICS_CONFIGS_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: auto.create.topics.configs
AUTO_CREATE_TOPICS_ENABLE_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: auto.create.topics.enable
AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: auto.create.topics.num.partitions
AUTO_CREATE_TOPICS_NUM_PARTITIONS_DEFAULT - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: auto.create.topics.replication.factor
AUTO_CREATE_TOPICS_REPLICATION_FACTOR_DEFAULT - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
AUTO_DELETE_TOPICS_ENABLE_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: auto.delete.topics.enable
AutoConfigure - Class in io.streamthoughts.azkarra.streams.autoconfigure: This class is used for auto-configuring the AzkarraApplication instance.
AutoConfigure() - Constructor for class io.streamthoughts.azkarra.streams.autoconfigure.AutoConfigure: Creates a new AutoConfigure instance.
AutoCreateTopicsInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors: This StreamsLifecycleInterceptor create both topics source and sink before starting the streams instance.
AutoCreateTopicsInterceptor() - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor: Creates a new AutoCreateTopicsInterceptor instance.
AutoCreateTopicsInterceptor(AdminClient) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor: Creates a new AutoCreateTopicsInterceptor instance.
AutoCreateTopicsInterceptorConfig - Class in io.streamthoughts.azkarra.runtime.interceptors: The configuration class for AutoCreateTopicsInterceptor.
AutoCreateTopicsInterceptorConfig(Conf) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: Creates a new AutoCreateTopicsInterceptorConfig instance.
AutoStartConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
AutoStartConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.AutoStartConfigEntryLoader
AZKARRA_ROOT_CONFIG_KEY - Static variable in class io.streamthoughts.azkarra.streams.AzkarraApplication
AzkarraAccount - Class in io.streamthoughts.azkarra.http.security: AzkarraAccount.
AzkarraAccount(Principal, Credentials, UserDetails) - Constructor for class io.streamthoughts.azkarra.http.security.AzkarraAccount: Creates a new AzkarraAccount instance.
AzkarraApplication - Class in io.streamthoughts.azkarra.streams: AzkarraApplication is the high-level class which can be used to deploy a simple server for managing multiple KafkaStreams instances.
AzkarraApplication(Class<?>...) - Constructor for class io.streamthoughts.azkarra.streams.AzkarraApplication: Creates a new AzkarraApplication instance.
AzkarraBanner - Class in io.streamthoughts.azkarra.streams.banner: The default Banner implementation which writes "Kafka Streams".
AzkarraBanner() - Constructor for class io.streamthoughts.azkarra.streams.banner.AzkarraBanner
AzkarraConf - Class in io.streamthoughts.azkarra.streams.config: The AzkarraConf is Conf implementation backed by the Typesafe Config.
AzkarraConf(Config) - Constructor for class io.streamthoughts.azkarra.streams.config.AzkarraConf: Creates a new AzkarraConf instance.
AzkarraContext - Interface in io.streamthoughts.azkarra.api: The AzkarraContext.
AzkarraContextAware - Interface in io.streamthoughts.azkarra.api: Interface to be implemented by any object that wishes to be notified of the AzkarraContext that it runs in.
AzkarraContextException - Exception in io.streamthoughts.azkarra.api.errors
AzkarraContextException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraContextException: Creates a new AzkarraContextException instance.
AzkarraContextException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraContextException: Creates a new AzkarraContextException instance.
AzkarraContextListener - Interface in io.streamthoughts.azkarra.api
AzkarraException - Exception in io.streamthoughts.azkarra.api.errors: AzkarraException is the top-level error type generated by the core-api.
AzkarraException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException: Creates a new AzkarraException instance.
AzkarraException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException: Creates a new AzkarraException instance.
AzkarraException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException: Creates a new AzkarraException instance.
AzkarraExceptionMapper - Class in io.streamthoughts.azkarra.http.error: The default JAX-RS ExceptionMapper implementation.
AzkarraExceptionMapper() - Constructor for class io.streamthoughts.azkarra.http.error.AzkarraExceptionMapper
AzkarraIdentityManager - Class in io.streamthoughts.azkarra.http.security: BasicMapIdentityManager.
AzkarraIdentityManager(Authenticator) - Constructor for class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager: Creates a new AzkarraIdentityManager instance.
AzkarraMetricsConfig - Class in io.streamthoughts.azkarra.metrics: Properties to configure metrics.
AzkarraMetricsConfig(Conf) - Constructor for class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfig: Creates a new AzkarraMetricsConfig instance.
AzkarraMetricsConfigEntryLoader - Class in io.streamthoughts.azkarra.metrics
AzkarraMetricsConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfigEntryLoader: Creates a new AzkarraMetricsConfigEntryLoader instance.
AzkarraPrincipalBuilder - Interface in io.streamthoughts.azkarra.http.security.auth: Pluggable builder interface which is used to build Principal object used during authorization.
AzkarraRestExtension - Interface in io.streamthoughts.azkarra.api.server: A pluggable interface to allow registration of new JAX-RS resources like REST endpoints.
AzkarraRestExtensionContext - Interface in io.streamthoughts.azkarra.api.server: This interfaces provides the capability for AzkarraRestExtension implementations to register JAX-RS resources using the provided Configurable and to get access to the AzkarraContext instance.
AzkarraRetriableException - Exception in io.streamthoughts.azkarra.api.errors
AzkarraRetriableException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraRetriableException: Creates a new AzkarraRetriableException instance.
AzkarraRetriableException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraRetriableException: Creates a new AzkarraRetriableException instance.
AzkarraRocksDBConfigSetter - Class in io.streamthoughts.azkarra.commons.rocksdb: This RocksDBConfigSetter implementation allows fine-tuning of RocksDB instances.
AzkarraRocksDBConfigSetter() - Constructor for class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
AzkarraRocksDBConfigSetterConfig - Class in io.streamthoughts.azkarra.commons.rocksdb: The AzkarraRocksDBConfigSetterConfig is used to configure the AzkarraRocksDBConfigSetter.
AzkarraSimpleModule - Class in io.streamthoughts.azkarra.serialization.json: A simple module with all registered serializers.
AzkarraSimpleModule() - Constructor for class io.streamthoughts.azkarra.serialization.json.AzkarraSimpleModule: Creates a new AzkarraSimpleModule instance.
AzkarraStreamsApplication - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
AzkarraStreamsService - Interface in io.streamthoughts.azkarra.api: The AzkarraStreamsService serves as the main front-facing interface for manipulating streams applications.
AzkarraV1Api - Class in io.streamthoughts.azkarra.client.openapi.apis
AzkarraV1Api() - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
AzkarraV1Api(ApiClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
azkarraVersion(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
AzkarraVersion - Class in io.streamthoughts.azkarra.api: A AzkarraVersion is used to get version information about the running azkarra library.
AzkarraVersion() - Constructor for class io.streamthoughts.azkarra.api.AzkarraVersion
AzkarraVersionApi - Class in io.streamthoughts.azkarra.client.openapi.apis
AzkarraVersionApi() - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
AzkarraVersionApi(ApiClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
AzkarraWorker - Class in io.streamthoughts.azkarra: The default main class for starting an Azkarra worker.
AzkarraWorker() - Constructor for class io.streamthoughts.azkarra.AzkarraWorker

B

BadRequestException - Exception in io.streamthoughts.azkarra.http.error
BadRequestException(String) - Constructor for exception io.streamthoughts.azkarra.http.error.BadRequestException: Creates a new BadRequestException instance.
Banner - Interface in io.streamthoughts.azkarra.api.banner
Banner.Mode - Enum in io.streamthoughts.azkarra.api.banner
BannerPrinter - Interface in io.streamthoughts.azkarra.api.banner
BannerPrinterBuilder - Class in io.streamthoughts.azkarra.streams.banner: Default class for building BannerPrinter instance.
BaseAsyncQueryCall<K,V,Q extends Query> - Class in io.streamthoughts.azkarra.runtime.query
BaseAsyncQueryCall(Q) - Constructor for class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall: Creates a new BaseAsyncQueryCall instance.
BaseComponentModule - Class in io.streamthoughts.azkarra.api.components: An abstract base class that can be extended to supply configurable components.
BaseComponentModule() - Constructor for class io.streamthoughts.azkarra.api.components.BaseComponentModule
BaseKeyedLocalStoreQuery<K1,K2,V> - Class in io.streamthoughts.azkarra.api.query.internal
BASIC_AUTH - io.streamthoughts.azkarra.http.security.SecurityMechanism
BasicAuthAuthenticator - Class in io.streamthoughts.azkarra.client.authentication: BasicAuthAuthenticator.
BasicAuthAuthenticator(Supplier<BasicAuthAuthenticator.Credential>) - Constructor for class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator
BasicAuthAuthenticator.Credential - Class in io.streamthoughts.azkarra.client.authentication
BasicAuthenticationExample - Class in io.streamthoughts.examples.azkarra.security: Example to configure an azkarra application with Basic authentication.
BasicAuthenticationExample() - Constructor for class io.streamthoughts.examples.azkarra.security.BasicAuthenticationExample
BasicAuthenticator - Class in io.streamthoughts.azkarra.http.security.auth: BasicAuthenticator.
BasicAuthenticator(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicAuthenticator: Creates a new BasicAuthenticator instance.
BasicBlockingRecordQueue<K,V> - Class in io.streamthoughts.azkarra.api.events: A simple BlockingRecordQueue backed by a BlockingQueue.
BasicBlockingRecordQueue() - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue: Creates a new BasicBlockingRecordQueue instance.
BasicBlockingRecordQueue(int) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue: Creates a new BasicBlockingRecordQueue instance.
BasicBlockingRecordQueue(int, Duration) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue: Creates a new BasicBlockingRecordQueue instance.
BasicBlockingRecordQueue(int, Duration, LimitHandler) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue: Creates a new BasicBlockingRecordQueue instance.
BasicComponentFactory<T> - Class in io.streamthoughts.azkarra.runtime.components
BasicComponentFactory(Class<T>) - Constructor for class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Creates a new BasicComponentFactory instance.
BasicComponentFactory(Class<T>, ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Creates a new BasicComponentFactory instance.
BasicContainerId - Class in io.streamthoughts.azkarra.runtime.env.internal
BasicContainerId(String) - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId: Creates a new BasicContainerId instance.
BasicRolePrincipal - Class in io.streamthoughts.azkarra.http.security.auth
BasicRolePrincipal(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal: Creates a new BasicRolePrincipal instance.
BasicUserPrincipal - Class in io.streamthoughts.azkarra.http.security.auth: BasicUserPrincipal.
BasicUserPrincipal(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal: Creates a new BasicUserPrincipal instance.
BasicWordCountTopology - Class in io.streamthoughts.examples.azkarra.topology: A basic WordCount topology.
BasicWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.topology.BasicWordCountTopology
BlockingRecordQueue<K,V> - Interface in io.streamthoughts.azkarra.api.events: A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.
branch(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
build() - Method in class io.streamthoughts.azkarra.api.events.EventStream.Builder
build() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
build() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
build() - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder: Builds the http client.
build() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.Builder
build() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Builds a new Health instance.
build() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
build() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
build() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsBuilder: Builds a new cloud event entity
build() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.StreamsExtensionBuilder
build() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainerBuilder: Builds a KafkaStreams instance.
build() - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
build(TopologyDescription) - Static method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
build(TopologyDescription.Processor) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNodeBuilder
build(TopologyDescription.Sink) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNodeBuilder
build(TopologyDescription.Source) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNodeBuilder
buildApplicationId(TopologyMetadata, Conf) - Method in interface io.streamthoughts.azkarra.api.streams.ApplicationIdBuilder: Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
buildApplicationId(TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder: Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
buildApplicationId(TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder: Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
buildCall(String, String, List<Pair>, List<Pair>, Object, Map<String, String>, Map<String, String>, Map<String, Object>, String[], ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Build HTTP call with the given options.
buildConditionsForAnnotations(List<ConditionalOn>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions: Static helper to build a list of Conditions based on the given annotation.
buildContainerId(ApplicationId, TopologyMetadata, Conf) - Method in interface io.streamthoughts.azkarra.runtime.env.ContainerIdBuilder: Builds the identifier that will be used for identifying the KafkaStreamsContainer running the topology.
buildContainerId(ApplicationId, TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder: Builds the identifier that will be used for identifying the KafkaStreamsContainer running the topology.
Builder() - Constructor for class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
Builder() - Constructor for class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.Builder
Builder() - Constructor for class io.streamthoughts.azkarra.http.health.Health.Builder: Creates a new Health.Builder instance.
Builder(String) - Constructor for class io.streamthoughts.azkarra.api.events.EventStream.Builder: Creates a new EventStream.Builder instance.
buildInternalErrorResult(String, String, Throwable) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
buildNotAvailableResult(String) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
buildPrincipal(AuthenticationContext) - Method in interface io.streamthoughts.azkarra.http.security.auth.AzkarraPrincipalBuilder: Builds the Principal.
buildQueryResult(List<Either<SuccessResultSet<K, V>, ErrorResultSet>>) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
buildRequest(String, String, List<Pair>, List<Pair>, Object, Map<String, String>, Map<String, String>, Map<String, Object>, String[], ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Build an HTTP request with the given options.
buildRequestBodyFormEncoding(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Build a form-encoding request body with the given form parameters.
buildRequestBodyMultipart(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Build a multipart (file uploading) request body with the given form parameters, which could contain text fields and file fields.
buildUrl(String, List<Pair>, List<Pair>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Build full URL by concatenating base path, the given sub path and query parameters.
byAnyRestrictions(Restriction...) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byLatestVersion() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byName(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byPrimary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byQualifiers(Qualifier<T>...) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byRestriction(Restriction) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byRestriction(String, String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
bySecondary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
ByteArrayAdapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.ByteArrayAdapter
byVersion(Version) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
byVersion(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers

C

calculateRemainingFormatted(TopicPartition, long) - Method in class io.streamthoughts.azkarra.commons.streams.LoggingStateRestoreListener
call() - Method in interface io.streamthoughts.azkarra.api.StreamsTopologyExecution
canBeInstantiated(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
cancel() - Method in interface io.streamthoughts.azkarra.api.query.QueryCall: Cancels the QueryCall, if possible.
cancel() - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall: Cancels the QueryCall, if possible.
cancel() - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall: Cancels the QueryCall, if possible.
capped(Instant) - Static method in class io.streamthoughts.azkarra.api.util.Utils: Instant.toEpochMilli() could result in an arithmetic overflow/underflow (e.g.
CertClientAuthenticator - Class in io.streamthoughts.azkarra.http.security.auth
CertClientAuthenticator() - Constructor for class io.streamthoughts.azkarra.http.security.auth.CertClientAuthenticator
CheckedFunction<T,R,E extends Exception> - Interface in io.streamthoughts.azkarra.api.monad
CheckedSupplier<R,E extends Throwable> - Interface in io.streamthoughts.azkarra.api.monad
checkEndpoint(Endpoint) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Checks whether the given Endpoint is the same as this container.
checkEndpoint(Endpoint) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Checks whether the given Endpoint is the same as this container.
ClassComponentAliasesGenerator - Class in io.streamthoughts.azkarra.runtime.components: ClassComponentAliasesGenerator can be used to generate aliases from component class.
ClassComponentAliasesGenerator() - Constructor for class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator: Creates a new ClassComponentAliasesGenerator instance.
ClassComponentAliasesGenerator.ClassAliasExtractor - Interface in io.streamthoughts.azkarra.runtime.components
ClassComponentAliasesGenerator.DropClassNameSuffixExtractor - Class in io.streamthoughts.azkarra.runtime.components
classLoader() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the classloader used to load the component.
classLoader() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Gets the classloader used to load the component.
classLoader() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
classLoader() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Gets the classloader used to load the component.
classLoader(ClassLoader) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Sets the classLoader of the component.
ClassLoaderAwareKafkaStreamsFactory - Class in io.streamthoughts.azkarra.runtime.context.internal
ClassLoaderAwareKafkaStreamsFactory(KafkaStreamsFactory, ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ClassLoaderAwareKafkaStreamsFactory: Creates a new ClassLoaderAwareKafkaStreamsFactory instance.
classLoaderMetrics() - Method in class io.streamthoughts.azkarra.metrics.binders.JvmMeterRegistryBinderFactory: Return the JVM Class loader metrics component.
ClassloadingIsolationInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors
ClassloadingIsolationInterceptor(ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.ClassloadingIsolationInterceptor: Creates a new ClassloadingIsolationInterceptor instance.
className() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the name of the describe component.
className() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Gets the name of the describe component.
ClassUtils - Class in io.streamthoughts.azkarra.api.util
ClassUtils() - Constructor for class io.streamthoughts.azkarra.api.util.ClassUtils
cleanup(Boolean) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
clear() - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
clear() - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue
clear() - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
clearContext() - Static method in class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder: Clears the context value from the current thread.
CLIENT_CERT_AUTH - io.streamthoughts.azkarra.http.security.SecurityMechanism
clientAddress() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext: Gets the client address.
clientId() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
clientId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
close() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
close() - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
close() - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent: Closes the created component.
close() - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue: Close the queue.
close() - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue: Close the queue.
close() - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue: Close the queue.
close() - Method in class io.streamthoughts.azkarra.api.events.EventStream
close() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtension
close() - Method in class io.streamthoughts.azkarra.api.streams.consumer.MonitorOffsetsConsumerInterceptor
close() - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer: {@inheritDoc
close() - Method in class io.streamthoughts.azkarra.commons.rocksdb.internal.OpaqueMemoryResource: Releases this resource.
close() - Method in class io.streamthoughts.azkarra.metrics.endpoints.PrometheusEndpoint.PrometheusEndpointExtension
close() - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
close() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaMonitoringReporter: Closes this MonitoringReporter.
close() - Method in interface io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringReporter: Closes this MonitoringReporter.
close() - Method in interface io.streamthoughts.azkarra.serialization.Serdes: Close this Serdes.
close(boolean, Duration) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Closes this KafkaStreams instance and wait up to the timeout for the streams to be closed.
close(boolean, Duration) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Closes this KafkaStreams instance and wait up to the timeout for the streams to be closed.
close(String, Options) - Method in class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
close(Duration) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Closes this KafkaStreams instance.
close(Duration) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Closes this KafkaStreams instance.
CloseKafkaStreamsOnThreadException - Class in io.streamthoughts.azkarra.runtime.streams.errors: Closes immediately the KafkaStreams instance when a StreamThread abruptly terminates due to an uncaught exception.
CloseKafkaStreamsOnThreadException() - Constructor for class io.streamthoughts.azkarra.runtime.streams.errors.CloseKafkaStreamsOnThreadException
closeQuietly(AutoCloseable) - Static method in class io.streamthoughts.azkarra.api.util.Utils
cloudEventId(ZonedDateTime) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
CloudEventsAttributes - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce: This class describes the required attributes for streams events, following CloudEvents Specification.
CloudEventsBuilder<T> - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
CloudEventsContext - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce: This class is used to wrap information about a Cloud Events in the context of Kafka Streams.
CloudEventsContext(String, String, String) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext: Creates a new CloudEventsContext instance.
CloudEventsEntity<T> - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
CloudEventsExtension - Interface in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce: Represents a list of Cloud Events Extension.
cloudEventSource() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
cloudEventSubject() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
collect() - Method in class io.streamthoughts.azkarra.http.prometheus.KafkaStreamsMetricsCollector
collectionPathParameterToString(String, Collection) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Formats the specified collection path parameter to a string value.
commit() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
commitId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
committedOffset() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
committedOffset(OffsetAndTimestamp) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
committedOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
committedTimestamp(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
compareAndSwapLoaders(ClassLoader) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
compareTo(Ordered) - Method in interface io.streamthoughts.azkarra.api.components.Ordered
compareTo(KV<K, V>) - Method in class io.streamthoughts.azkarra.api.model.KV
compareTo(MetricGroup) - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
compareTo(StreamsTopologyGraph.Node) - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
compareTo(StreamsTopologyGraph.SubTopologyGraph) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
compareTo(TimestampedValue) - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
compareTo(ConsumerLogOffsets) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
compareTo(TopicPartitions) - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
compareTo(Version) - Method in class io.streamthoughts.azkarra.api.util.Version
compile() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
compile(QueryParams) - Method in interface io.streamthoughts.azkarra.api.query.LocalPreparedQuery: Builds a new LocalExecutableQuery based on the given Query.
ComplexWordCountTopology - Class in io.streamthoughts.examples.azkarra.dependency
ComplexWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
ComplexWordCountTopologyModule - Class in io.streamthoughts.examples.azkarra.dependency: A ComponentModule for providing a new @{link ComplexWordCountTopology} instance.
ComplexWordCountTopologyModule() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopologyModule
Component - Annotation Type in io.streamthoughts.azkarra.api.annotations: Marker interface that any class having a no-arg constructor can used to indicate it can be registered.
ComponentAliasesGenerator - Interface in io.streamthoughts.azkarra.api.components
ComponentAttribute - Class in io.streamthoughts.azkarra.api.components
ComponentAttribute(String) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentAttribute: Creates a new ComponentAttribute instance.
ComponentAttribute(String, Map<String, Object>, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentAttribute: Creates a new ComponentAttribute instance.
ComponentClassLoader - Class in io.streamthoughts.azkarra.streams.components.isolation: Default ClassLoader for loading components using a 'child-first strategy'.
ComponentConditionalContext<T extends ComponentDescriptor<?>> - Interface in io.streamthoughts.azkarra.api.components.condition: Interface to verify if a conditional component is enabled for a given context.
ComponentConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
ComponentConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.ComponentConfigEntryLoader: Creates a new ComponentConfigEntryLoader instance.
ComponentDescriptor<T> - Interface in io.streamthoughts.azkarra.api.components: Describes a single component managed by a ComponentFactory.
ComponentDescriptorBuilder<T> - Class in io.streamthoughts.azkarra.runtime.components
ComponentDescriptorBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
ComponentDescriptorFactory - Interface in io.streamthoughts.azkarra.api.components: Factory to create new SimpleComponentDescriptor instance.
ComponentDescriptorModifier - Interface in io.streamthoughts.azkarra.api.components: Callback for modifying a given component descriptor.
ComponentDescriptorModifierResolver - Interface in io.streamthoughts.azkarra.streams.components.annotation: This interface can be used to resolve a ComponentDescriptorModifier to be used for registering a component.
ComponentDescriptorModifierResolver.ApplyModifierOnAnnotationExist - Class in io.streamthoughts.azkarra.streams.components.annotation
ComponentDescriptorModifierResolver.ApplyModifierOnAnnotations<T extends Annotation> - Class in io.streamthoughts.azkarra.streams.components.annotation
ComponentDescriptorModifiers - Class in io.streamthoughts.azkarra.runtime.components
ComponentDescriptorModifiers() - Constructor for class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers
ComponentDescriptorRegistry - Interface in io.streamthoughts.azkarra.api.components
ComponentFactory - Interface in io.streamthoughts.azkarra.api.components
ComponentFactoryAware - Interface in io.streamthoughts.azkarra.api.components
componentLocation() - Method in interface io.streamthoughts.azkarra.api.components.ExternalComponentClassLoader
componentLocation() - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
ComponentMetadata - Class in io.streamthoughts.azkarra.api.components
ComponentMetadata() - Constructor for class io.streamthoughts.azkarra.api.components.ComponentMetadata: Creates a new ComponentMetadata instance.
ComponentModule<T> - Class in io.streamthoughts.azkarra.api.components: A configurable component supplier which has access to the ComponentFactory.
ComponentModule() - Constructor for class io.streamthoughts.azkarra.api.components.ComponentModule
ComponentNameGenerator - Interface in io.streamthoughts.azkarra.api.components: Interface which is used for generating component name.
ComponentRegistrationException - Exception in io.streamthoughts.azkarra.api.components
ComponentRegistrationException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.ComponentRegistrationException: Creates a new ComponentRegistrationException instance.
ComponentRegistrationException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.components.ComponentRegistrationException: Creates a new ComponentRegistrationException instance.
ComponentRegistry - Interface in io.streamthoughts.azkarra.api.components: The ComponentRegistry is the main interface for managing components used in an Azkarra application.
ComponentResolver - Class in io.streamthoughts.azkarra.streams.components.isolation
ComponentResolver(Path) - Constructor for class io.streamthoughts.azkarra.streams.components.isolation.ComponentResolver: Creates a new ComponentResolver instance.
components() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn: Specify that components of the given types must be registered for the component to be enabled.
ComponentScan - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
ComponentScanner - Interface in io.streamthoughts.azkarra.api.components
compose(Condition...) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions: Specify that ALL of the given condition should be true for a component to be eligible for use.
compose(List<? extends Condition>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions: Specify that ALL of the given condition should be true for a component to be eligible for use.
compositeMeterRegistry() - Method in class io.streamthoughts.azkarra.metrics.micrometer.MeterRegistryFactory
CompositeQualifier<T> - Class in io.streamthoughts.azkarra.api.components.qualifier
CompositeQualifier(List<Qualifier<T>>) - Constructor for class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier: Creates a new CompositeQualifier instance.
CompositeStateListener - Class in io.streamthoughts.azkarra.api.streams.listener: A KafkaStreams.StateListener that delegates to one or more KafkaStreams.StateListener in order.
CompositeStateListener() - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener: Creates a new CompositeStateListener instance.
CompositeStateListener(Collection<KafkaStreams.StateListener>) - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener: Creates a new CompositeStateListener instance.
CompositeStateRestoreListener - Class in io.streamthoughts.azkarra.api.streams.listener: A StateRestoreListener that delegates to one or more StateRestoreListener in order.
CompositeStateRestoreListener(Collection<StateRestoreListener>) - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener: Creates a new CompositeStateRestoreListener instance.
CompositeStreamsInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors
CompositeStreamsInterceptor() - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor: Creates a new CompositeStreamsInterceptor instance.
CompositeStreamsInterceptor(Collection<StreamsLifecycleInterceptor>) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor: Creates a new CompositeStreamsInterceptor instance.
CompositeUncaughtExceptionHandler - Class in io.streamthoughts.azkarra.api.streams.listener
CompositeUncaughtExceptionHandler() - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler: Creates a new CompositeUncaughtExceptionHandler instance.
condition() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the Condition that need to be fulfilled for this component to be eligible for use in the application.
condition() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Gets the Condition that need to be fulfilled for this component to be eligible for use in the application.
condition() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Gets the Condition that need to be fulfilled for this component to be eligible for use in the application.
condition(Condition) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
Condition - Interface in io.streamthoughts.azkarra.api.components.condition: Define a single condition that need to be fulfilled for a component to be eligible for use in the application.
ConditionalDescriptorRegistry - Interface in io.streamthoughts.azkarra.api.components: The main interface that defines methods to find registered ComponentDescriptor for enable components.
ConditionalOn - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to indicate the condition(s) that need to be fulfilled for a component to be eligible for use in the application.
ConditionalOnMetricsEnable - Annotation Type in io.streamthoughts.azkarra.metrics.annotations
Conditionals - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to indicate all the conditions that need to be fulfilled for a component to be eligible for use in the application.
ConditionalStreamsApplication - Class in io.streamthoughts.examples.azkarra.conditional: This example demonstrates how conditional components can be used to dynamically change the behavior of a stream topology based on its configuration.
ConditionalStreamsApplication() - Constructor for class io.streamthoughts.examples.azkarra.conditional.ConditionalStreamsApplication
ConditionalStreamsApplication.Normalize - Interface in io.streamthoughts.examples.azkarra.conditional
ConditionalStreamsApplication.Normalizes - Class in io.streamthoughts.examples.azkarra.conditional
ConditionalStreamsApplication.NormalizeStreamsTopology - Class in io.streamthoughts.examples.azkarra.conditional
ConditionContext<T extends ComponentDescriptor> - Interface in io.streamthoughts.azkarra.api.components.condition: The context information for use by a Condition matching a ComponentDescriptor.
conditions() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn: Specify one or more conditions that the component must match.
Conditions - Class in io.streamthoughts.azkarra.api.components.condition
Conditions() - Constructor for class io.streamthoughts.azkarra.api.components.condition.Conditions
Conf - Interface in io.streamthoughts.azkarra.api.config: A Conf represents an immutable object which can be used for configuring components.
ConfEntry - Class in io.streamthoughts.azkarra.api.config
ConfException - Exception in io.streamthoughts.azkarra.api.errors: ConfException is the top-level error type generated by the Conf api.
ConfException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
ConfException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
ConfException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
config - Variable in class io.streamthoughts.azkarra.api.Executed
config - Variable in class io.streamthoughts.azkarra.http.data.EnvironmentRequestBody
config() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
config() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
config() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig: Gets the configuration for this environment.
config() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.TopologyConfig: Gets the Conf to be used for configuring the TopologyProvider and KafkaStreams instance.
CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfigEntryLoader
CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.streams.config.loader.AutoStartConfigEntryLoader
CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.streams.config.loader.StreamsConfigEntryLoader
ConfigConditionalContext<T> - Class in io.streamthoughts.azkarra.runtime.components.condition: Default ComponentConditionalContext implementation..
ConfigConditionalContext(Conf) - Constructor for class io.streamthoughts.azkarra.runtime.components.condition.ConfigConditionalContext: Creates a new ConfigConditionalContext instance.
configDef() - Static method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
configDef(ConfigDef.Type) - Static method in class io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig
configurable() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtensionContext: Provides an implementation of Configurable that must be used to register JAX-RS resources.
configurable() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer.InternalRestExtensionContext
Configurable - Interface in io.streamthoughts.azkarra.api.config
ConfigurableComponentFactory - Interface in io.streamthoughts.azkarra.api.components
ConfigurableStopWordsService - Class in io.streamthoughts.examples.azkarra.dependency
ConfigurableStopWordsService() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
ConfigurableSupplier<T> - Class in io.streamthoughts.azkarra.api.config: A configurable supplier.
ConfigurableSupplier() - Constructor for class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
ConfigurableWordCountTopology - Class in io.streamthoughts.examples.azkarra.topology: A basic WordCount topology.
ConfigurableWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
configuration() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the default configuration that will pass to the describe component if it implements the Configurable interface.
configuration() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor: Gets the default configuration that will pass to the describe component if it implements the Configurable interface.
configuration() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Returns Conf defined for this TopologyProvider.
configuration() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
configuration() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Gets the default configuration that will pass to the describe component if it implements the Configurable interface.
configuration(Conf) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
configuration(Conf) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
Configuration - Class in io.streamthoughts.azkarra.client.openapi
Configuration() - Constructor for class io.streamthoughts.azkarra.client.openapi.Configuration
configure(Conf) - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule: Configures this instance with the specified Conf.
configure(Conf) - Method in interface io.streamthoughts.azkarra.api.config.Configurable: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier: Configures this instance with the specified Conf.
configure(Conf) - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtension: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.http.security.authorizer.SimpleAuthorizationManager: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.metrics.interceptor.MeterKafkaStreamsInterceptor: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptor: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaMonitoringReporter: Configure this StreamsMetadataReporter.
configure(Conf) - Method in interface io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringReporter: Configure this StreamsMetadataReporter.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptor: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptor: Configures this instance with the specified Conf.
configure(Conf) - Method in interface io.streamthoughts.azkarra.serialization.Serdes: Configure this Serdes.
configure(Conf) - Method in class io.streamthoughts.azkarra.streams.components.ReflectMethodComponentSupplier: Configures this instance with the specified Conf.
configure(Conf) - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
configure(Conf) - Method in class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
configure(Conf) - Method in class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
configure(Consumer<ObjectMapper>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.api.streams.consumer.MonitorOffsetsConsumerInterceptor
configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
configure(Map<String, ?>, boolean) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer: {@inheritDoc
ConflictingComponentDefinitionException - Exception in io.streamthoughts.azkarra.api.components
ConflictingComponentDefinitionException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.ConflictingComponentDefinitionException: Creates a new ConflictingComponentDefinitionException instance.
ConfSerializer - Class in io.streamthoughts.azkarra.serialization.json: Json serializer for Conf.
ConfSerializer() - Constructor for class io.streamthoughts.azkarra.serialization.json.ConfSerializer
ConfValue - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to provide default config values to a configurable component.
ConfValues - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to provide default config values to a configurable component.
connected(ServerSentEventConnection, String) - Method in class io.streamthoughts.azkarra.http.sse.EventStreamConnectionCallback
connectTimeout(int) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder: Sets the connect timeout (in milliseconds).
CONSOLE - io.streamthoughts.azkarra.api.banner.Banner.Mode
Constants - Class in io.streamthoughts.azkarra.http.utils: Helpers class for HTTP query params.
Constants() - Constructor for class io.streamthoughts.azkarra.http.utils.Constants
consumedOffset() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
consumedOffset(OffsetAndTimestamp) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
consumedOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
consumedTimestamp(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
ConsumerClientOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
ConsumerClientOffsets(String, String, Set<ConsumerLogOffsets>) - Constructor for class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets: Creates a new ConsumerClientOffsets instance.
ConsumerGroupOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
ConsumerGroupOffsets(String, Set<ConsumerClientOffsets>) - Constructor for class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets: Creates a new ConsumerGroupOffsets instance.
ConsumerGroupOffsetsRegistry - Interface in io.streamthoughts.azkarra.api.streams.consumer
ConsumerGroupOffsetsState - Class in io.streamthoughts.azkarra.api.streams.consumer
ConsumerLogOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
consumers() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
consumers(List<V1StreamsConsumerClientOffsets>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
ConsumerThreadKey - Class in io.streamthoughts.azkarra.api.streams.consumer
container() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleContext
CONTAINER_ID_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
containerId() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the id for this container.
containerId() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets the id for this container.
ContainerId - Interface in io.streamthoughts.azkarra.api: An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.
ContainerIdBuilder - Interface in io.streamthoughts.azkarra.runtime.env: A ContainerIdBuilder is used to build ContainerId.
contains(char[], char) - Static method in class io.streamthoughts.azkarra.api.util.Utils
contains(Qualifier) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
contains(String) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
contains(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams: Checks whether this QueryParams contains the given key param.
contains(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams: Checks whether this QueryParams contains the given key param.
contains(String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
contains(String, String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata: Checks whether the metadata contains the given value for the given attribute name and member.
containsComponent(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Checks if at least one component is registered for the given type.
containsComponent(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
containsComponent(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Checks if at least one component is registered for the given type.
containsComponent(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Checks if at least one component is registered for the given type and qualifier.
containsComponent(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
containsComponent(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Checks if at least one component is registered for the given type and qualifier.
containsComponent(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Checks if at least one component is registered for the given type.
containsComponent(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
containsComponent(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Checks if at least one component is registered for the given type.
containsComponent(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Checks if at least one component is registered for the given type and qualifier.
containsComponent(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
containsComponent(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Checks if at least one component is registered for the given type and qualifier.
containsIgnoreCase(String[], String) - Static method in class io.streamthoughts.azkarra.client.openapi.StringUtil: Check if the given array contains the given value (with case-insensitive comparison).
contentLength() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressRequestBody
contentLength() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressResponseBody
contentType() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressRequestBody
contentType() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressResponseBody
contentType() - Method in class io.streamthoughts.azkarra.http.serialization.json.SpecificJsonSerdes: Get the content-type attached to this Serdes.
contentType() - Method in interface io.streamthoughts.azkarra.serialization.Serdes: Get the content-type attached to this Serdes.
context - Variable in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareComponentSupplier
context - Variable in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
context() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtensionContext: Provides the AzkarraContext instance that can be used to retrieve registered components.
context() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer.InternalRestExtensionContext
ContextAwareApplicationIdBuilderSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareApplicationIdBuilderSupplier(AzkarraContext, GettableComponent<ApplicationIdBuilder>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier
ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder - Class in io.streamthoughts.azkarra.runtime.context.internal: A delegating KafkaStreamsFactory which is not Configurable.
ContextAwareComponentFactory - Class in io.streamthoughts.azkarra.api.components
ContextAwareComponentFactory(AzkarraContext, ComponentFactory) - Constructor for class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Creates a new ContextAwareComponentFactory instance.
ContextAwareComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareGettableComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.context.internal: Supplier class which is used to get a specific component from AzkarraContext.
ContextAwareKafkaStreamsFactorySupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareKafkaStreamsFactorySupplier(AzkarraContext, GettableComponent<KafkaStreamsFactory>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareKafkaStreamsFactorySupplier
ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory - Class in io.streamthoughts.azkarra.runtime.context.internal: A delegating KafkaStreamsFactory which is not Configurable.
ContextAwareLifecycleInterceptorSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareLifecycleInterceptorSupplier(AzkarraContext, GettableComponent<StreamsLifecycleInterceptor>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareLifecycleInterceptorSupplier
ContextAwareThreadExceptionHandlerSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareThreadExceptionHandlerSupplier(AzkarraContext, GettableComponent<StreamThreadExceptionHandler>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier
ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler - Class in io.streamthoughts.azkarra.runtime.context.internal: A delegating StreamThreadExceptionHandler which is not Configurable.
ContextAwareTopologySupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
ContextAwareTopologySupplier(AzkarraContext, StreamsTopologyMeta) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier: Creates a new ContextAwareTopologySupplier instance.
ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider - Class in io.streamthoughts.azkarra.runtime.context.internal: A delegating TopologyProvider which is not Configurable.
count() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
count(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
count(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
COUNT - io.streamthoughts.azkarra.api.query.StoreOperation
create() - Static method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta: Helper method to create a new StreamsTopologyMeta.Builder instance.
create() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Static helper method for creating a new ComponentDescriptorBuilder instance.
create() - Static method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and a empty configuration.
create() - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance using the empty configuration and a generated unique name.
create() - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Static helper that can be used to creates a new AzkarraConf instance that loads a default configuration.
create(ComponentDescriptor<T>) - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder: Static helper method for creating a new ComponentDescriptorBuilder instance.
create(ComponentFactory) - Static method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Static helper that can be used to creates a new AzkarraContext instance using the specified ComponentRegistry and a empty configuration.
create(Conf) - Static method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Static helper that can be used to creates a new AzkarraContext instance using a default ComponentRegistry and the specified configuration.
create(Conf) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and using a generated env name.
create(HasId) - Static method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId: An helper method to create a new BasicContainerId based on a given HasId.
create(QueryRequest, QueryOptions) - Static method in class io.streamthoughts.azkarra.http.query.V1QueryBuilder: Helper method to create a new V1Query object based on the given QueryRequest and QueryOptions.
create(String) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentFactory: Creates a new StreamsExecutionEnvironment from the specified name and an empty configuration.
create(String) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified env name and using the configuration.
create(String) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Static helper that can be used to creates a new AzkarraConf instance using the specified resource base name.
create(String, Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentFactory: Creates a new StreamsExecutionEnvironment from the specified name and configuration.
create(String, Conf) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and env name.
create(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory: Creates a new StreamsExecutionEnvironment from the specified name and configuration.
create(String, Endpoint, Endpoint, QueryRequest) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCallFactory
create(String, Endpoint, Endpoint, QueryRequest) - Method in interface io.streamthoughts.azkarra.runtime.query.RemoteQueryCallFactory
create(String, String, Conf) - Method in class io.streamthoughts.azkarra.runtime.StreamsExecutionEnvironmentAbstractFactory: Creates a new StreamsExecutionEnvironment for the specified type using the given name and configuration.
create(Map<String, ? extends Object>) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Static helper that can be used to creates a new AzkarraConf instance from the specified map.
create(Properties) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Static helper that can be used to creates a new AzkarraConf instance from the specified properties.
CREATED - io.streamthoughts.azkarra.api.State
CREATED - io.streamthoughts.azkarra.api.streams.State.Standards: The KafkaStreams instance has been created successfully.
createGson() - Static method in class io.streamthoughts.azkarra.client.openapi.JSON
createKeyManagers(String, char[], String, String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
createKeyStore(String, char[], String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils: Helper method to create a new KeyStore.
createNewProducer(Map<String, Object>) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Creates a new Producer instance using the same configs that the Kafka Streams instance.
createNewProducer(Map<String, Object>) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Creates a new Producer instance using the same configs that the Kafka Streams instance.
createTrustManagers(String, char[], String, String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
Credential(String, String) - Constructor for class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator.Credential
credentials() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
Credentials - Interface in io.streamthoughts.azkarra.http.security.auth: Interface to hold a user credentials.
Credentials.UnsupportedCredentialException - Exception in io.streamthoughts.azkarra.http.security.auth
currentOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
customHeaders() - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
CustomHealthCheckExample - Class in io.streamthoughts.examples.azkarra.healthcheck: Example for registering custom health-check.
CustomHealthCheckExample() - Constructor for class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample
CustomHealthCheckExample.MyCustomerHealthCheck - Class in io.streamthoughts.examples.azkarra.healthcheck

D

data() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
dataContentType - Variable in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes: Content type of data value.
dataContentType() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
DateTypeAdapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.DateTypeAdapter
DateTypeAdapter(DateFormat) - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.DateTypeAdapter
DEAD_LETTER_HEADERS_PREFIX - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DEAD_LETTER_PRODUCER_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DEAD_LETTER_TOPIC_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DEAD_LETTER_TOPIC_DOC - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DeadLetterTopicExceptionHandler - Class in io.streamthoughts.azkarra.commons.error: A DeserializationExceptionHandler implementation that write rejected records to an dead-letter-topic.
DeadLetterTopicExceptionHandler() - Constructor for class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
DeadLetterTopicExceptionHandlerConfig - Class in io.streamthoughts.azkarra.commons.error: Config class for DeadLetterTopicExceptionHandler.
DeadLetterTopicExceptionHandlerConfig(Map<String, ?>) - Constructor for class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig: Creates a new DeadLetterTopicExceptionHandlerConfig instance.
debugging(boolean) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder: Enable/disable debugging for this API client.
DecorateQuery<T extends Query> - Class in io.streamthoughts.azkarra.api.query
DecorateQuery(T) - Constructor for class io.streamthoughts.azkarra.api.query.DecorateQuery: Creates a new DecorateQuery instance.
DEFAULT - Static variable in interface io.streamthoughts.azkarra.api.components.ComponentNameGenerator: The default ComponentNameGenerator implementation.
DEFAULT - Static variable in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory
DEFAULT_ENV_NAME - Static variable in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER - Static variable in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
DefaultApplicationIdBuilder - Class in io.streamthoughts.azkarra.runtime.streams: The default ApplicationIdBuilder implementation.
DefaultApplicationIdBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder
DefaultAuthenticationCallbackHandler - Class in io.streamthoughts.azkarra.http.security.jaas.spi
DefaultAuthenticationCallbackHandler() - Constructor for class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler: Creates a new DefaultAuthenticationCallbackHandler instance.
DefaultAzkarraContext - Class in io.streamthoughts.azkarra.runtime.context: The AzkarraContext.
DefaultBannerPrinter - Class in io.streamthoughts.azkarra.streams.banner
DefaultComponentDescriptorFactory - Class in io.streamthoughts.azkarra.runtime.components
DefaultComponentDescriptorFactory() - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultComponentDescriptorFactory: Creates a new DefaultComponentDescriptorFactory instance.
DefaultComponentFactory - Class in io.streamthoughts.azkarra.runtime.components: The default ComponentRegistry implementation.
DefaultComponentFactory(ComponentDescriptorFactory) - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Creates a new DefaultComponentFactory instance.
DefaultContainerIdBuilder - Class in io.streamthoughts.azkarra.runtime.env.internal
DefaultContainerIdBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
DefaultInteractiveQueryService - Class in io.streamthoughts.azkarra.runtime.query: A DefaultInteractiveQueryService is used to execute a query request.
DefaultInteractiveQueryService(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService: Creates a new DefaultInteractiveQueryService instance.
DefaultInteractiveQueryService(AzkarraStreamsService, List<QueryExecutionDelegatee>) - Constructor for class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService: Creates a new DefaultInteractiveQueryService instance.
defaultKeySerde() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the default Serde configured for key.
defaultKeySerde() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets the default Serde configured for key.
defaultObject() - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig
DefaultStatusAggregator - Class in io.streamthoughts.azkarra.http.health.internal
DefaultStatusAggregator() - Constructor for class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator: Creates a new DefaultStatusAggregator instance.
DefaultStatusAggregator(List<Status>) - Constructor for class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator: Creates a new DefaultStatusAggregator instance using the specified status order.
DefaultStreamThreadExceptionHandlerFactory - Class in io.streamthoughts.azkarra.runtime.context
DefaultStreamThreadExceptionHandlerFactory() - Constructor for class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
defaultValue - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
DelegateBlockingRecordQueue<K,V> - Class in io.streamthoughts.azkarra.api.events: A delegating BlockingRecordQueue that can be used to easily override some methods.
DelegateBlockingRecordQueue(BlockingRecordQueue<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
DelegatingComponentFactory - Class in io.streamthoughts.azkarra.api.components: A delegating ComponentFactory implementation.
DelegatingComponentFactory(ComponentFactory) - Constructor for class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
DelegatingConf - Class in io.streamthoughts.azkarra.api.config: Delegates to a Conf.
DelegatingConf(Conf) - Constructor for class io.streamthoughts.azkarra.api.config.DelegatingConf: Creates a new DelegatingConf instance.
DelegatingExecutionEnvironmentAware<T> - Class in io.streamthoughts.azkarra.runtime.context.internal: A delegating StreamsExecutionEnvironmentAware implementation.
DelegatingUncaughtExceptionHandler - Class in io.streamthoughts.azkarra.api.streams.errors: This class can be used to delegate Thread.UncaughtExceptionHandler exception handling to an a given StreamThreadExceptionHandler implementation.
DelegatingUncaughtExceptionHandler(KafkaStreamsContainer, StreamThreadExceptionHandler) - Constructor for class io.streamthoughts.azkarra.api.streams.errors.DelegatingUncaughtExceptionHandler
deleteUsersByName(String) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
DENIED - io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult
describe() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Describes the local KafkaStreams instance.
describe() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets a serializable view of this StreamsExecutionEnvironment instance.
describe() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Describes the local KafkaStreams instance.
describeAllEnvironments() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all existing streams environments.
describeAllEnvironments() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets all existing streams environments.
describeEnvironmentByName(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets the StreamsExecutionEnvironment for the specified name.
describeEnvironmentByName(String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets the StreamsExecutionEnvironment for the specified name.
description - Variable in class io.streamthoughts.azkarra.api.Executed
description - Variable in class io.streamthoughts.azkarra.client.openapi.ServerConfiguration
description - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
description() - Method in annotation type io.streamthoughts.azkarra.api.annotations.TopologyInfo: Gets the Topology description.
description() - Method in class io.streamthoughts.azkarra.api.model.Metric
description() - Method in class io.streamthoughts.azkarra.api.providers.TopologyDescriptor
description() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
description() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
description() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
description() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.TopologyConfig: Gets the user-defined topology description.
description(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
description(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
descriptionOrElseGet(String) - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
descriptor() - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent: Gets the descriptor for the component.
deserialize(byte[]) - Method in class io.streamthoughts.azkarra.http.serialization.json.SpecificJsonSerdes: Deserialize data from a byte array into a value or object.
deserialize(byte[]) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given bytes array.
deserialize(byte[]) - Method in interface io.streamthoughts.azkarra.serialization.Serdes: Deserialize data from a byte array into a value or object.
deserialize(byte[], Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given bytes array.
deserialize(JsonNode, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given bytes array.
deserialize(InputStream) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given InputStream.
deserialize(InputStream, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given InputStream.
deserialize(String, byte[]) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer: {@inheritDoc
deserialize(String, byte[]) - Static method in class io.streamthoughts.azkarra.http.serialization.json.JsonQuerySerde
deserialize(String, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json: An helper method that can be used to deserialize a given InputStream.
deserialize(String, Type) - Method in class io.streamthoughts.azkarra.client.openapi.JSON: Deserialize the given JSON string to Java object.
deserialize(String, Headers, byte[]) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer: {@inheritDoc
deserialize(Response, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Deserialize response body to Java object, according to the return type and the Content-Type response header.
DigestPasswordCredentials - Class in io.streamthoughts.azkarra.http.security.auth
DigestPasswordCredentials(String, String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials: Creates a new PasswordCredentials instance.
disableHeadlessMode() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Disables the headless mode.
disableRestExtensions() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Disables support for rest extensions.
disableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Disables SSL.
dispose() - Method in interface io.streamthoughts.azkarra.commons.rocksdb.internal.ResourceDisposer: Release the memory shared resource.
DistributedQueryCall<K,V> - Class in io.streamthoughts.azkarra.runtime.query
DistributedQueryCall(LocalExecutableQuery<K, V>, LocalKafkaStreamsContainer, RemoteQueryCallFactory) - Constructor for class io.streamthoughts.azkarra.runtime.query.DistributedQueryCall: Creates a new DecorateQuery instance.
DistributedQueryExecutionDelegatee - Class in io.streamthoughts.azkarra.runtime.query
DistributedQueryExecutionDelegatee(RemoteQueryCallFactory) - Constructor for class io.streamthoughts.azkarra.runtime.query.DistributedQueryExecutionDelegatee: Creates a new DistributedQueryExecutionDelegatee instance.
Double() - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
Double(Double) - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
down() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the status for the Health indicator to be built to Status.DOWN.
DOWN - Static variable in class io.streamthoughts.azkarra.http.health.Status
downloadFileFromResponse(Response) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Download file from the given response.
drainTo(Collection<? super KV<K, V>>) - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
drainTo(Collection<? super KV<K, V>>) - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue
drainTo(Collection<? super KV<K, V>>) - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
dropHeadOnLimitReached() - Static method in class io.streamthoughts.azkarra.api.events.LimitHandlers
DTF - Static variable in interface io.streamthoughts.azkarra.api.time.Time
duration(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo

E

Eager - Annotation Type in io.streamthoughts.azkarra.api.annotations: Annotation that can be used on any class or method directly or indirectly annotated with Component.
Either<L,R> - Class in io.streamthoughts.azkarra.api.monad: Simple Either monad type.
Either.Left<L,R> - Class in io.streamthoughts.azkarra.api.monad
Either.LeftProjection<L,R> - Class in io.streamthoughts.azkarra.api.monad
Either.Right<L,R> - Class in io.streamthoughts.azkarra.api.monad
Either.RightProjection<L,R> - Class in io.streamthoughts.azkarra.api.monad
EmbeddedHttpServer - Interface in io.streamthoughts.azkarra.api.server: Default interface to provide an embedded http-server.
EmbeddedHttpServerProvider - Interface in io.streamthoughts.azkarra.api.spi: Default Service Provider interface to provides an EmbeddedHttpServer implementation.
empty() - Static method in interface io.streamthoughts.azkarra.api.config.Conf: Static helper that can be used to creates a new empty Conf instance.
empty() - Static method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
empty() - Static method in class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator.Credential
empty() - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Static helper that can be used to creates a new empty AzkarraConf instance.
EMPTY - Static variable in interface io.streamthoughts.azkarra.api.config.Conf
EMPTY - Static variable in class io.streamthoughts.azkarra.api.streams.KafkaStreamsMetadata
EmptyConf - Class in io.streamthoughts.azkarra.api.config
EmptyConf() - Constructor for class io.streamthoughts.azkarra.api.config.EmptyConf
EmptyQueryCall<K,V> - Class in io.streamthoughts.azkarra.runtime.query
EmptyQueryCall(Query) - Constructor for class io.streamthoughts.azkarra.runtime.query.EmptyQueryCall: Creates a new DecorateQuery instance.
ENABLE_WAIT_FOR_TOPICS__CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig: wait.for.topics.enable
EnableAutoConfig - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
EnableAutoStart - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
EnableEmbeddedHttpServer - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
enableHeadlessMode() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Enables the headless mode.
enableRestExtensions() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Enables support for rest extensions.
enableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Enables the SSL.
enableUI(boolean) - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder: Sets if the Web UI must be enable.
endingOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
endpoint() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the endpoint configured for this KafkaStreams instance.
endpoint() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsInstance
endpoint() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets the endpoint configured for this KafkaStreams instance.
Endpoint - Class in io.streamthoughts.azkarra.api.util
Endpoint(String, int) - Constructor for class io.streamthoughts.azkarra.api.util.Endpoint: Creates a new Endpoint instance.
enumValues - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
env(String) - Static method in class io.streamthoughts.azkarra.api.components.Restriction
environment - Variable in class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
environment() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsApplication
environment() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.EnableAutoStart
ENVIRONMENT_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
ENVIRONMENT_DEFAULT_NAME - Static variable in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
ENVIRONMENT_NAME_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
ENVIRONMENT_STREAMS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
ENVIRONMENT_TYPE_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
EnvironmentAwareComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.env.internal
EnvironmentAwareComponentSupplier(Supplier<T>) - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.EnvironmentAwareComponentSupplier: Creates a new EnvironmentAwareComponentSupplier instance.
EnvironmentConfig - Class in io.streamthoughts.azkarra.streams.config.loader.internal: Class which is used to configure a StreamsExecutionEnvironment instance.
EnvironmentConfig.Reader - Class in io.streamthoughts.azkarra.streams.config.loader.internal
EnvironmentRequestBody - Class in io.streamthoughts.azkarra.http.data
EnvironmentRequestBody(String, String, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.http.data.EnvironmentRequestBody
EnvironmentsConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
EnvironmentsConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.EnvironmentsConfigEntryLoader: Creates a new EnvironmentsConfigEntryLoader instance.
equals(Object) - Method in class io.streamthoughts.azkarra.api.ApplicationId
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.Restriction
equals(Object) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
equals(Object) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
equals(Object) - Method in class io.streamthoughts.azkarra.api.errors.Error
equals(Object) - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.KV
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.Metric
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
equals(Object) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.QueryOptions
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsetsState
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerThreadKey
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.OffsetAndTimestamp
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.StateChangeEvent
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
equals(Object) - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
equals(Object) - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
equals(Object) - Method in class io.streamthoughts.azkarra.api.util.Endpoint
equals(Object) - Method in class io.streamthoughts.azkarra.api.util.Version
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
equals(Object) - Method in class io.streamthoughts.azkarra.http.health.Health
equals(Object) - Method in class io.streamthoughts.azkarra.http.health.Status
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
equals(Object) - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
equals(Object) - Method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata
equals(Object) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ExternalComponent
error(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
Error - Class in io.streamthoughts.azkarra.api.errors
Error(String) - Constructor for class io.streamthoughts.azkarra.api.errors.Error
Error(Throwable) - Constructor for class io.streamthoughts.azkarra.api.errors.Error
ERROR - io.streamthoughts.azkarra.api.query.result.QueryStatus: Unexpected error happens while querying store.
ERROR - io.streamthoughts.azkarra.api.streams.State.Standards
ERROR - io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
ERROR_APPLICATION_ID - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_EXCEPTION_CLASS_NAME - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_EXCEPTION_MESSAGE - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_EXCEPTION_STACKTRACE - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_RECORD_OFFSET - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_RECORD_PARTITION - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_RECORD_TOPIC - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ERROR_TIMESTAMP - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
ErrorMessage - Class in io.streamthoughts.azkarra.http.data: The error message response object.
ErrorMessage(int, String, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage: Creates a new ErrorMessage instance.
ErrorMessage(int, String, String, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage: Creates a new ErrorMessage instance.
ErrorMessage(int, String, Throwable, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage: Creates a new ErrorMessage instance.
ErrorMessage(int, Throwable, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage: Creates a new ErrorMessage instance.
ErrorResultSet - Class in io.streamthoughts.azkarra.api.query.result
ErrorResultSet(String, boolean, QueryError) - Constructor for class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
ErrorResultSet(String, boolean, List<QueryError>) - Constructor for class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
errors(List<V1Error>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
escapeString(String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Escape the given string to be used as URL query value.
EventStream<K,V> - Class in io.streamthoughts.azkarra.api.events: A typed stream of events backed by a BlockingRecordQueue.
EventStream(String, BlockingRecordQueue<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.EventStream: Creates a new EventStream instance.
EventStream.Builder - Class in io.streamthoughts.azkarra.api.events
EventStreamConnectionCallback - Class in io.streamthoughts.azkarra.http.sse
EventStreamConnectionCallback(AzkarraStreamsService, Json) - Constructor for class io.streamthoughts.azkarra.http.sse.EventStreamConnectionCallback: Creates a new EventStreamConnectionCallback instance.
EventStreamPipe<K,V> - Interface in io.streamthoughts.azkarra.api.events: The EventStreamPipe is used to attached or detach an object that will be responsible to consume records send to an EventStream.
EventStreamProvider - Interface in io.streamthoughts.azkarra.api.events: EventStreamsProvider.
EventStreamPublisher<K,V> - Interface in io.streamthoughts.azkarra.api.events.reactive: The main publisher interface to subscribe to a specific streams of key-value records.
eventStreams() - Method in interface io.streamthoughts.azkarra.api.events.EventStreamProvider: Returns the list of EventStream
eventStreams() - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport: Returns the list of EventStream
eventStreams() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider: Returns the list of EventStream
EventStreamSupport - Class in io.streamthoughts.azkarra.api.events: Base class for EventStreamProvider.
EventStreamSupport() - Constructor for class io.streamthoughts.azkarra.api.events.EventStreamSupport
ExactlyOnce - Annotation Type in io.streamthoughts.azkarra.api.annotations: This annotation can be used to automatically set the streams property processing.guarantee to exactly_once.
exception() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the last observed exception thrown the KafkaStreams instance.
exception() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets the last observed exception thrown the KafkaStreams instance.
exception(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
ExceptionDefaultHandler - Class in io.streamthoughts.azkarra.http.error: An HttpHandler which used for catching any exception thrown during request execution.
ExceptionDefaultHandler() - Constructor for class io.streamthoughts.azkarra.http.error.ExceptionDefaultHandler
ExceptionDefaultResponseListener - Class in io.streamthoughts.azkarra.http.error
ExceptionDefaultResponseListener() - Constructor for class io.streamthoughts.azkarra.http.error.ExceptionDefaultResponseListener
ExceptionHeader - Class in io.streamthoughts.azkarra.commons.error: The default record-headers added to record write to the dead-letter-topic.
ExceptionHeader() - Constructor for class io.streamthoughts.azkarra.commons.error.ExceptionHeader
exceptionType() - Method in class io.streamthoughts.azkarra.api.monad.Retry
ExchangeHelper - Class in io.streamthoughts.azkarra.http: Simple class to wrap HttpServerExchange instance.
ExchangeHelper() - Constructor for class io.streamthoughts.azkarra.http.ExchangeHelper
excludeByName(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
excludeSecondary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
execute() - Method in class io.streamthoughts.azkarra.api.streams.internal.InternalStreamsLifeCycleChain: Executes the operation on the current KafkaStreams instance.
execute() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleChain: Executes the operation on the current KafkaStreams instance.
execute(LocalStoreAccessProvider) - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueCountQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchKeyRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchKeyRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchTimeRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchKeyRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchTimeRangeQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery: Executes this query to the specified KafkaStreams application.
execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.LoggingFailureLocalExecutableQuery: Executes this query to the specified KafkaStreams application.
execute(QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall: Executes this QueryCall.
execute(QueryOptions) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall: Executes this QueryCall.
execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DistributedQueryCall: Executes this QueryCall.
execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.EmptyQueryCall: Executes this QueryCall.
execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.LocalQueryCall: Executes this QueryCall.
execute(KafkaStreamsContainer, QueryRequest, QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DistributedQueryExecutionDelegatee: Executed the provided QueryRequest with the specified QueryOptions and the KafkaStreamsContainer.
execute(KafkaStreamsContainer, QueryRequest, QueryOptions) - Method in interface io.streamthoughts.azkarra.runtime.query.QueryExecutionDelegatee: Executed the provided QueryRequest with the specified QueryOptions and the KafkaStreamsContainer.
execute(StreamsLifecycleInterceptor, StreamsLifecycleChain) - Method in interface io.streamthoughts.azkarra.api.streams.internal.InternalStreamsLifeCycleChain.Callback
execute(String, QueryRequest, QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.InteractiveQueryService: Executes an interactive query for the specified streams application.
execute(String, QueryRequest, QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService: Executes an interactive query for the specified streams application.
execute(Call) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: ApiClient.execute(Call, Type)
execute(Call, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Execute HTTP call and deserialize the HTTP response body into the given return type.
executeAsync(QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall: Executes this QueryCall asynchronously.
executeAsync(QueryOptions) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall: Executes this QueryCall asynchronously.
executeAsync(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall: Executes this QueryCall asynchronously.
executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall: Executes this QueryCall asynchronously.
executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall: Executes this QueryCall asynchronously.
executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall: Executes this QueryCall asynchronously.
executeAsync(Call, ApiCallback<T>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: ApiClient.executeAsync(Call, Type, ApiCallback)
executeAsync(Call, Type, ApiCallback<T>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Execute HTTP call asynchronously.
executed - Variable in class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
Executed - Class in io.streamthoughts.azkarra.api: Executed class is used to describe a Topology instance to be executed.
Executed() - Constructor for class io.streamthoughts.azkarra.api.Executed: Creates a new Executed instance.
Executed(Executed) - Constructor for class io.streamthoughts.azkarra.api.Executed
ExecutionException - Exception in io.streamthoughts.azkarra.api.errors
ExecutionException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ExecutionException
exists() - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
exists() - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
extensions() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
ExternalComponent - Class in io.streamthoughts.azkarra.streams.components.isolation
ExternalComponentClassLoader - Interface in io.streamthoughts.azkarra.api.components
extractAlias(Class<?>) - Method in interface io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.ClassAliasExtractor
extractAlias(Class<?>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.DropClassNameSuffixExtractor

F

factory - Variable in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
factory - Variable in class io.streamthoughts.azkarra.api.Executed
factory() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
Factory - Annotation Type in io.streamthoughts.azkarra.api.annotations: An annotation that can be used by any class having a no-arg constructor to provide one or many other component implementation.
failable(CheckedSupplier<V, E>) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
failure(Throwable) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
failure(List<V1QueryErrorResultSet>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
FATAL_ERRORS_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
FATAL_ERRORS_DOC - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
fetch(V1QueryFetchParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
fetch(V1QueryFetchParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
FETCH - io.streamthoughts.azkarra.api.query.StoreOperation
FETCH_ALL - io.streamthoughts.azkarra.api.query.StoreOperation
FETCH_KEY_RANGE - io.streamthoughts.azkarra.api.query.StoreOperation
FETCH_TIME_RANGE - io.streamthoughts.azkarra.api.query.StoreOperation
fetchAll() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
fetchAll() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
fetchAll(V1QueryFetchAllParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
fetchAll(V1QueryFetchAllParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
fetchKeyRange(V1QueryFetchKeyRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
fetchKeyRange(V1QueryFetchKeyRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
fetchLogEndOffsetsFor(Consumer<K, V>, Collection<TopicPartition>) - Static method in class io.streamthoughts.azkarra.api.streams.consumer.LogOffsetsFetcher
fetchLogStartOffsetsFor(Consumer<K, V>, Collection<TopicPartition>) - Static method in class io.streamthoughts.azkarra.api.streams.consumer.LogOffsetsFetcher
fetchTimeRange() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
fetchTimeRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
fetchTimeRange(V1QueryFetchTimeRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
fetchTimeRange(V1QueryFetchTimeRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.LatestVersionQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.PrimaryQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.SecondaryQualifier
filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
filterByGroup(String) - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
filterByGroupAndMetricName(String, String) - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
filterByName(Collection<T>, String) - Static method in interface io.streamthoughts.azkarra.api.model.HasName: An helper method to filter a Collection of HasName object based on its name.
findAllAnnotations(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
findAllAnnotationsByType(Class<?>, Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
findAllAnnotationsByType(Method, Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
findAllDescriptorsByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified alias.
findAllDescriptorsByClass(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByClass(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds all ComponentDescriptor registered for the specified type.
findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds all ComponentDescriptor registered for the specified type.
findAllEndpointsForStore(String) - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessProvider
findAllEndpointsForStore(String) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
findApplicationIdBuilder(Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory
findComponentByRestriction(Class<T>, Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.components.RestrictedComponentFactory: Finds a component for the given type that is available for the given config and restriction.
findDescriptorByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds a ComponentDescriptor for the specified type.
findDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type.
findDescriptorByAlias(String, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds a ComponentDescriptor for the specified type.
findDescriptorByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type.
findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByAlias(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByClass(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds a ComponentDescriptor for the specified type.
findDescriptorByClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByClass(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type.
findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds a ComponentDescriptor for the specified type.
findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type.
findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByClass(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry: Finds a ComponentDescriptor for the specified type and options.
findDescriptorByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
findDescriptorByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Finds a ComponentDescriptor for the specified type and options.
findFirst(Class<T>, Stream<ComponentDescriptor<T>>) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
findMetadataForStoreAndKey(String, K, Serializer<K>) - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessProvider
findMetadataForStoreAndKey(String, K, Serializer<K>) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
findStreamThreadExceptionHandler(Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory
findUserByName(String) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
findUserByName(String) - Method in interface io.streamthoughts.azkarra.http.security.auth.UsersIdentityManager
flatMap(Function<? super B, Reader<A, ? extends BB>>) - Method in class io.streamthoughts.azkarra.api.monad.Reader
flatMap(Function<? super L, Either<LL, R>>) - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
flatMap(Function<? super R, Either<L, RR>>) - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
flatMap(Function<? super V, Try<B>>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
flatMap(Function<Tuple<L, R>, Tuple<LL, RR>>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
Float() - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
Float(Float) - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
fold(Function<L, LL>, Function<R, RR>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
fold(Function<L, T>, Function<R, T>) - Method in class io.streamthoughts.azkarra.api.monad.Either
forAlias(String) - Static method in exception io.streamthoughts.azkarra.api.errors.NoSuchComponentException
forAliasAndQualifier(String, Qualifier) - Static method in exception io.streamthoughts.azkarra.api.errors.NoSuchComponentException
formatStackTrace(Throwable) - Static method in class io.streamthoughts.azkarra.api.util.Utils
from(TopologyDescriptor<TopologyProvider>) - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
fromValue(String) - Static method in enum io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum
fromValue(String) - Static method in enum io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
FutureCollectors - Class in io.streamthoughts.azkarra.api.util

G

generate(ComponentDescriptor<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentNameGenerator: Generates a component name for the specified component descriptor.
generateNext() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.SequentialSubscriptionIdGenerator: Generates the next SubscriptionId
generateNext() - Method in interface io.streamthoughts.azkarra.api.events.reactive.internal.SubscriptionIdGenerator: Generates the next SubscriptionId
GenericQueryParams - Class in io.streamthoughts.azkarra.api.query
GenericQueryParams() - Constructor for class io.streamthoughts.azkarra.api.query.GenericQueryParams: Creates a new GenericQueryParams instance.
GenericQueryParams(Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.api.query.GenericQueryParams: Creates a new GenericQueryParams instance.
GenericRecordSerializer - Class in io.streamthoughts.azkarra.http.serialization.json
GenericRecordSerializer() - Constructor for class io.streamthoughts.azkarra.http.serialization.json.GenericRecordSerializer
get() - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
get() - Method in class io.streamthoughts.azkarra.api.config.Property
get() - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
get() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
get() - Method in interface io.streamthoughts.azkarra.api.events.reactive.internal.SubscriptionId
get() - Method in interface io.streamthoughts.azkarra.api.monad.CheckedSupplier
get() - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
get() - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
get() - Method in interface io.streamthoughts.azkarra.api.monad.Try
get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
get() - Method in class io.streamthoughts.azkarra.api.monad.Validator
get() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
get() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueQueryBuilder
get() - Method in class io.streamthoughts.azkarra.api.query.LocalStoreAccessor
get() - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessor.StoreSupplier
get() - Method in interface io.streamthoughts.azkarra.http.security.auth.GrantedAuthority: Gets the string representation of this GrantedAuthority.
get() - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority: Gets the string representation of this GrantedAuthority.
get() - Method in class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory
get() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier
get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareKafkaStreamsFactorySupplier
get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareLifecycleInterceptorSupplier
get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier
get() - Method in class io.streamthoughts.azkarra.runtime.modules.InteractiveQueryServiceModule
get() - Method in class io.streamthoughts.azkarra.streams.components.ReflectMethodComponentSupplier
get() - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopologyModule
get(AzkarraContext) - Method in interface io.streamthoughts.azkarra.api.spi.EmbeddedHttpServerProvider: Creates an returns the embedded HTTP server.
get(AzkarraContext) - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServerProvider: Creates an returns the embedded HTTP server.
get(Conf) - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent: Gets the instance of type GettableComponent, which may be shared or independent.
get(Conf) - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
get(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareGettableComponentSupplier
get(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier
get(StreamsExecutionEnvironment<?>, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.internal.EnvironmentAwareComponentSupplier
get(V1QueryGetParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
get(V1QueryGetParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
get(String) - Static method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
GET - io.streamthoughts.azkarra.api.query.StoreOperation
getActiveTasks() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get activeTasks
getAdminClient() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets a shared AdminClient instance for this KafkaStreams instance.
getAdminClient() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets a shared AdminClient instance for this KafkaStreams instance.
getAdminClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get adminClientId
getAdvertisedServer() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig: Get the server name that will be included in monitoring events.
getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentAliasesGenerator: Gets unique aliases for the specified SimpleComponentDescriptor descriptor.
getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator: Gets unique aliases for the specified SimpleComponentDescriptor descriptor.
getAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll: Get all
getAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get all
getAllClassLoaders() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
getAllClassLoaders() - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllClassLoaders() - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
getAllComponentProviders(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponentProviders(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllComponentProviders(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets all instances, which may be shared or independent, for the specified type.
getAllEnvironments() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all StreamsExecutionEnvironment registered to this context.
getAllEnvironments() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all StreamsExecutionEnvironment registered to this context.
getAllPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.commons.streams.StateRestoreInfo: Gets the state of the TopicPartition being restored.
getAllStatus(Collection<Health>) - Static method in interface io.streamthoughts.azkarra.http.health.StatusAggregator: Static helper that can be used for retrieving only status from a list of Health instances.
getAllStreamsContainersById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns all the KafkaStreamsContainer for the specified application.id.
getAllStreamsContainersById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns all the KafkaStreamsContainer for the specified application.id.
getAllSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
getAllTopologies() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets the list of all topologies.
getAllTopologies() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
getApiClient() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
getApiClient() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
getApiKey() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
getApiKeyPrefix() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
getApplicationById(ApplicationId) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets the KafkaStreamsApplication for the specified application.id
getApplicationById(ApplicationId) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Gets the KafkaStreamsApplication for the specified application.id
getApplicationIdBuilder() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets the ApplicationIdBuilder.
getApplicationIdBuilder() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Gets the ApplicationIdBuilder.
getApplicationIds() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Returns all {ApplicationId for active Kafka Streams applications.
getApplicationIds() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Returns all {ApplicationId for active Kafka Streams applications.
getAsMap() - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams: Gets all query params as Map.
getAsMap() - Method in interface io.streamthoughts.azkarra.api.query.QueryParams: Gets all query params as Map.
getAssignments() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata: Get assignments
getAuthentication() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext: Gets the currently authenticated principal.
getAuthentication() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext: Gets the currently authenticated principal.
getAuthentication() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.AuthenticationCallback
getAuthentication(String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get authentication for the given name.
getAuthenticationContext() - Static method in class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder: Gets the AuthenticationContext attached to the current thread of execution.
getAuthenticationMechanism() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthenticationPrincipalBuilder() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthenticationRealm() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthenticationRestricted() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthenticationRoles() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthentications() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get authentications (key: authentication name, value: authentication).
getAuthenticationUsers() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthorizationManager() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAutoCreateTopicsConfigs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: Get additional properties that should be should be set for creating topics.
getAutoCreateTopicsNumPartition() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: Get the default number of partitions that should be set for creating topics.
getAutoCreateTopicsReplicationFactor() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig: Get the default replication factor that should be should be set for creating topics.
getAzkarraVersion() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version: Version of Azkarra Framework
getBasePath() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get base path
getBearerToken() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBearerAuth: Gets the token, which together with the scheme, will be sent as the value of the Authorization header.
getBool(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getBoolean(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as an boolean.
getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as an boolean.
getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as an boolean.
getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as an boolean.
getBoolean(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as an boolean.
getBranch() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version: Branch of Azkarra Framework
getBytes(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getCertificate() - Method in class io.streamthoughts.azkarra.http.security.auth.SSLClientAuthentication
getClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as an instances of type ConfEntry.
getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.AbstractConf: Gets a required parameter as an instances of type Conf.
getClass(String, Class<T>) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as an instances of type Conf.
getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as an instances of type Conf.
getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as an instances of type Conf.
getClasses(Class<T>) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry: Gets value as a list of instances of type ConfEntry.
getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.AbstractConf: Gets a required parameter as a list of instances of type Conf.
getClasses(String, Class<T>) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a list of instances of type Conf.
getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a list of instances of type Conf.
getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a list of instances of type Conf.
getClassLoader() - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
getCleanup() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options: Get cleanup
getClientAddress() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext: Gets the client address.
getClientAddress() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext: Gets the client address.
getClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets: Get clientId
getCode() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException: Get the HTTP status code.
getCode() - Method in class io.streamthoughts.azkarra.http.health.Status
getCommitId() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version: Commit id of Azkarra Framework
getCommittedOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get committedOffset
getCommittedTimestamp() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get committedTimestamp
getComponent() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext
getComponent(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the internal ComponentFactory.
getComponentFactory() - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule: Gets the internal ComponentFactory.
getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext: Get the ComponentFactory that holds the component descriptor should the condition match.
getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets the internal ComponentFactory.
getComponentFactory() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the internal ComponentFactory.
getComponentProvider(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getComponentProvider(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
getComponentProvider(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory: Gets an instance, which may be shared or independent, for the specified type.
getConfAsMap() - Method in interface io.streamthoughts.azkarra.api.config.Conf: Converts this Conf into a path-value map.
getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Converts this Conf into a path-value map.
getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Converts this Conf into a path-value map.
getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.MapConf: Converts this Conf into a path-value map.
getConfAsMap() - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Converts this Conf into a path-value map.
getConfAsProperties() - Method in interface io.streamthoughts.azkarra.api.config.Conf: Converts this Conf into a properties.
getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Converts this Conf into a properties.
getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Converts this Conf into a properties.
getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.MapConf: Converts this Conf into a properties.
getConfAsProperties() - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Converts this Conf into a properties.
getConfig() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext: Get the configuration that was passed to get the component instance.
getConfig() - Method in class io.streamthoughts.azkarra.http.data.GetContextResponse
getConfig() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getConfiguration() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Returns the global context streamsConfig of this AzkarraContext instance.
getConfiguration() - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule: Gets the configuration used by this component factory.
getConfiguration() - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory: Gets the configuration used by this component factory.
getConfiguration() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets this environment configuration.
getConfiguration() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Returns the global context streamsConfig of this AzkarraContext instance.
getConfiguration() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Gets this environment configuration.
getConfiguration() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Gets the configuration for this AzkarraApplication.
getConnectTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get connection timeout (in milliseconds).
getConsumedOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get consumedOffset
getConsumedTimestamp() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get consumedTimestamp
getConsumers() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets: Get consumers
getContainerById(ContainerId) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets a KafkaStreamsContainer for the specified id.
getContainerIds() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Returns all ContainerId for active Kafka Streams applications.
getContainerIds() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Returns all ContainerId for active Kafka Streams applications.
getContainers() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Returns all containers for active Kafka Streams applications.
getContainers() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Returns all containers for active Kafka Streams applications.
getContext() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Gets the AzkarraContext.
getContextConfig() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets the configuration of AzkarraContext.
getContextConfig() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets the configuration of AzkarraContext.
GetContextResponse - Class in io.streamthoughts.azkarra.http.data
GetContextResponse(Conf) - Constructor for class io.streamthoughts.azkarra.http.data.GetContextResponse: Creates a new GetContextResponse instance.
getCount() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount: Get count
getCount() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get count
getCredentials() - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication: The Credentials of the user to authenticate.
getCredentials() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication: The Credentials of the user to authenticate.
getCredentials() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
getCurrentOffset() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
getCurrentOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo: Get currentOffset
getCurrentVersion() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi: get the API current version
getCurrentVersionAsync(ApiCallback<Version>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi: (asynchronously) get the API current version
getCurrentVersionCall(ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi: Build call for getCurrentVersion
getCurrentVersionWithHttpInfo() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi: get the API current version
getData() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
getDate(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getDateFormat() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
getDefault() - Static method in class io.streamthoughts.azkarra.serialization.json.Json
getDefaultApiClient() - Static method in class io.streamthoughts.azkarra.client.openapi.Configuration: Get the default API client, which would be used when creating API instances without providing an API client.
getDefaultEnvironment() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the default StreamsExecutionEnvironment.
getDefaultEnvironment() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the default StreamsExecutionEnvironment.
getDescription() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
getDescription() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric: Get description
getDescription() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get description
getDescription() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getDescription() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getDetails() - Method in class io.streamthoughts.azkarra.http.health.Health: Gets the health indicator details.
getDouble(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getDouble(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a double.
getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a double.
getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a double.
getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a double.
getDouble(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a double.
getDuration() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get duration
getDuration() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the duration of the restoration process.
getEndingOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get endingOffset
getEndingOffset() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the exclusive ending offset of the entire restoration process for this TopicPartition
getEndpoint() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getEnv() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getEnvironmentForName(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the StreamsExecutionEnvironment for the specified name.
getEnvironmentForName(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the StreamsExecutionEnvironment for the specified name.
getError() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getError() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get error
getErrorCode() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getErrors() - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
getErrors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet: Get errors
getEventStreamPublisherForType(String) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets a new EventStreamPublisher for the given event-tye.
getEventStreamPublisherForType(String) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Gets a new EventStreamPublisher for the given event-tye.
getEventStreams() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
getException() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get exception
getException() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getException() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getExcludePatterns() - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig
getExtensions() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig: Get the list of extension attributes that should be included in monitoring events.
getFailure() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getFailure() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get failure
getFatalExceptions() - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
getFetch() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch: Get fetch
getFetch() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get fetch
getFetchAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll: Get fetchAll
getFetchAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get fetchAll
getFetchKeyRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange: Get fetchKeyRange
getFetchKeyRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get fetchKeyRange
getFetchTimeRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange: Get fetchTimeRange
getFetchTimeRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get fetchTimeRange
getFloat(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getGet() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet: Get get
getGet() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get get
getGitBranch() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
getGitCommitId() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
getGlobalStores() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
getGlobalStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology: Get globalStores
getGroup() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets: Get group
getGson() - Method in class io.streamthoughts.azkarra.client.openapi.JSON: Get Gson.
getHeaders() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
getHealth() - Method in interface io.streamthoughts.azkarra.http.health.HealthIndicator: Gets the health for a service or sub-system.
getHealth() - Method in class io.streamthoughts.azkarra.http.health.internal.StreamsHealthIndicator: Gets the health for a service or sub-system.
getHealth() - Method in class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample.MyCustomerHealthCheck
getHost() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
getHttpClient() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get HTTP client
getId() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
getId() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get id
getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore: Get id
getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus: Get id
getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology: Get id
getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsApplicationResponse
getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
getIds(Collection<? extends HasId>) - Static method in interface io.streamthoughts.azkarra.api.model.HasId: Helper method to get string ids from a collection of HasId objects.
getIds(Collection<? extends HasName>) - Static method in interface io.streamthoughts.azkarra.api.model.HasName: An helper method to get string names from a collection of HasName objects.
getInstance() - Static method in class io.streamthoughts.azkarra.api.streams.consumer.GlobalConsumerOffsetsRegistry
getInt(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getInt(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as an integer.
getInt(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as an integer.
getInt(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as an integer.
getInt(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as an integer.
getInt(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as an integer.
getIntervalMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig: Get the period the interceptor should use to send a streams state event (Default is 10 seconds).
getJSON() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get JSON
getKafkaStreams() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Returns the wrapped KafkaStreams instance.
getKafkaStreams() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Returns the wrapped KafkaStreams instance.
getKey() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
getKey() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams: Get key
getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams: Get key
getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams: Get key
getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record: Get key
getKeyFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams: Get keyFrom
getKeyFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams: Get keyFrom
getKeyManagers() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
getKeyPassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getKeySerializer() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
getKeySerializer() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
getKeystoreLocation() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getKeystorePassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getKeystoreType() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getKeyTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams: Get keyTo
getKeyTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams: Get keyTo
getLag() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get lag
getLatest(Version...) - Static method in class io.streamthoughts.azkarra.api.util.Version: Static helper for returning the latest version from a list of Version.
getLimit() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions: Only return the first n records
getList(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getListener() - Method in class io.streamthoughts.azkarra.http.ServerConfig
getLocalEndpoint() - Method in class io.streamthoughts.azkarra.runtime.query.LocalQueryCall
getLocalInstance(KafkaStreamsMetadata) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
getLocation() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
getLogEndOffset() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
getLogEndOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo: Get logEndOffset
getLoginContext() - Method in class io.streamthoughts.azkarra.http.security.auth.JAASAuthentication: Gets the LoginModule used to authenticate the user.
getLong(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getLong(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a long.
getLong(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a long.
getLong(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a long.
getLong(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a long.
getLong(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams: Gets the parameter as long for the given key.
getLong(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams: Gets the parameter as long for the given key.
getLong(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a long.
getLongEndOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get longEndOffset
getLongStartColonOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get longStartColonOffset
getMainApplicationClass() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Gets the Class containing the main method.
getMainConsumerClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get mainConsumerClientId
getMessage() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error: Get message
getMessage() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getMetrics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup: Get metrics
getMinAvailableBrokers() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
getName() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getName() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
getName() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo: Get name
getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric: Get name
getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup: Get name
getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get name
getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode: Get name
getName() - Method in class io.streamthoughts.azkarra.client.openapi.Pair
getName() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getName() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getName() - Method in class io.streamthoughts.azkarra.http.health.Health: Gets the health indicator name.
getName() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
getName() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
getNodes() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
getNodes() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology: Get nodes
getOffsetLag() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
getOffsetLag() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo: Get offsetLag
getOptionalBoolean(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets an optional parameter as an boolean.
getOptionalDouble(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets an optional parameter as an double.
getOptionalInt(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets an optional parameter as an integer.
getOptionalLong(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets an optional parameter as a long.
getOptionalQueryParam(HttpServerExchange, String) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to get an optional param from query for the specified name.
getOptionalString(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets an optional parameter as a string.
getOrThrow(Function<List<Error>, Throwable>) - Method in class io.streamthoughts.azkarra.api.monad.Validator
getParamName() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
getParams() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
getParams() - Method in interface io.streamthoughts.azkarra.api.query.Query
getParams() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
getPartition() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo: Get partition
getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get partition
getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition: The partition of the topic
getPartition() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the Partition being restored.
getPartitionLagInfos() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
getPartitionLagInfos() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo: Get partitionLagInfos
getPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
getPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo: Get partitionRestoreInfos
getPassword() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
getPath() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getPort() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
getPort() - Method in class io.streamthoughts.azkarra.http.ServerConfig
getPositions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets: Get positions
getPredecessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getPredecessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode: Get predecessors
getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf: Get predecessors
getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode: Get predecessors
getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf: Get predecessors
getPrincipal() - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication: The Principal of the user to authenticate.
getPrincipal() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication: The Principal of the user to authenticate.
getPrincipal() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
getProcessor() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
getProcessor() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore: Get processor
getProducerClientIds() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get producerClientIds
getProducerConfigs(String) - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig: Get the configs for the producer.
getQuery() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query: Get query
getQueryBuilder(String) - Method in enum io.streamthoughts.azkarra.api.query.StoreType
getQueryParam(HttpServerExchange, String) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to get an mandatory param from query for the specified name.
getQueryTimeout() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
getQueryTimeoutMs() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions: This limit the total time of state store execute.
getRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation: Get range
getRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange: Get range
getReadTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get read timeout (in milliseconds).
getRecord() - Method in class io.streamthoughts.azkarra.http.sse.ServerSentEventSubscriber.StreamedEvent
getRecords() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
getRecords() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet: Get records
getRemote() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet: Get remote
getRemote() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet: Get remote
getRemoteAccessAllowed() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions: Is remote access is allowed for this execute
getReporters() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
getResource() - Method in class io.streamthoughts.azkarra.commons.rocksdb.internal.OpaqueMemoryResource: Gets the handle resource.
getResource(String) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
getResources(String) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
getResponseBody() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException: Get the HTTP response body.
getResponseHeaders() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException: Get the HTTP response headers.
getRestoreConsumerClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get restoreConsumerClientId
getResult() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getResult() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult: Get result
getRetries() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions: The maximum number of attempts to run after failed access to a given local state store
getRetries() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
getRetryBackoff() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
getRetryBackoffMs() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions: The time to wait before attempting to retry a failed access to a given local state store
getRetryBackoffMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
getRoles() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
getSecurityMechanism() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext: Gets the security mechanism used to authenticate the current user.
getSecurityMechanism() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext: Gets the security mechanism used to authenticate the current user.
getSecurityMechanism() - Method in class io.streamthoughts.azkarra.http.security.handler.SecurityHandler
getServer() - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
getServer() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet: Get server
getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult: Get server
getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet: Get server
getServers() - Method in class io.streamthoughts.azkarra.http.data.StreamsApplicationResponse
getSetOptions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query: Get setOptions
getShort(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getSince() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get since
getSince() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState: Get since
getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.State
getSinkTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
getSource() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
getSource() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore: Get source
getSourceTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
getSslCaCert() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get SSL CA cert.
getSSLContext(KeyManager[], TrustManager[]) - Method in class io.streamthoughts.azkarra.client.security.SSLContextFactory: Gets the SSLContext instance using the specified configuration.
getSSLSession() - Method in class io.streamthoughts.azkarra.http.security.auth.SSLAuthenticationContext: Gets the current ssl session information.
getStandbyAssignments() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata: Get standbyAssignments
getStandbyStateStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata: Get standbyStateStores
getStandbyTasks() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get standbyTasks
getStartingOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get startingOffset
getStartingOffset() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the starting offset of the entire restoration process for this TopicPartition.
getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get state
getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState: Get state
getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus: Get state
getState() - Method in class io.streamthoughts.azkarra.commons.streams.StateRestoreInfo: Gets the name of the state being restored.
getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.State
getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
getStateRestoreInfo(String) - Method in class io.streamthoughts.azkarra.commons.streams.LoggingStateRestoreListener: Gets the state state of a the restoration process for given state store.
getStateRestoreInfo(String) - Method in interface io.streamthoughts.azkarra.commons.streams.StateRestoreService: Gets the state state of a the restoration process for given state store.
getStateStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata: Get stateStores
getStatus() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getStatus() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult: Get status
getStatus() - Method in class io.streamthoughts.azkarra.http.health.Health: Gets the health indicator status.
getStatusCode() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
getStore() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getStore() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get store
getStoreName() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
getStoreName() - Method in interface io.streamthoughts.azkarra.api.query.Query
getStoreName() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
getStoreOperation() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
getStoreOperation() - Method in interface io.streamthoughts.azkarra.api.query.Query
getStoreOperation() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
getStores() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNode
getStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode: Get stores
getStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf: Get stores
getStoreType() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
getStoreType() - Method in interface io.streamthoughts.azkarra.api.query.Query
getStoreType() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
getStreamBuilder() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Returns the StreamsBuilder which is used to build the Topology instance.
getStreamsApplicationById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all local and remote streams instances for the specified streams application.
getStreamsApplicationById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets all local and remote streams instances for the specified streams application.
getStreamsContainerById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the KafkaStreamsContainer for the specified id.
getStreamsContainerById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the KafkaStreamsContainer for the specified id.
getStreamsInstanceConfig(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the configuration of the KafkaStreams instance
getStreamsInstanceConfigAsync(String, ApiCallback<Map<String, Object>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the configuration of the KafkaStreams instance
getStreamsInstanceConfigCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceConfig
getStreamsInstanceConfigWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the configuration of the KafkaStreams instance
getStreamsInstanceConsumerOffsets(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the offset posititions for the consumers of the Kafka Streams instance
getStreamsInstanceConsumerOffsetsAsync(String, ApiCallback<V1StreamsConsumerGroupOffsets>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the offset posititions for the consumers of the Kafka Streams instance
getStreamsInstanceConsumerOffsetsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceConsumerOffsets
getStreamsInstanceConsumerOffsetsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the offset posititions for the consumers of the Kafka Streams instance
getStreamsInstanceDetails(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get details about a Kafka Streams instance
getStreamsInstanceDetailsAsync(String, ApiCallback<V1StreamsDetails>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get details about a Kafka Streams instance
getStreamsInstanceDetailsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceDetails
getStreamsInstanceDetailsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get details about a Kafka Streams instance
getStreamsInstanceMetadata(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: list the KafkaStreams instances currently active on the local Azkarra application
getStreamsInstanceMetadataAsync(String, ApiCallback<V1StreamsMetadata>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
getStreamsInstanceMetadataCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceMetadata
getStreamsInstanceMetadataWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: list the KafkaStreams instances currently active on the local Azkarra application
getStreamsInstanceMetricByGroupAndName(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the current metric for the streams instance, metric group and name
getStreamsInstanceMetricByGroupAndNameAsync(String, String, String, ApiCallback<V1MetricGroup>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the current metric for the streams instance, metric group and name
getStreamsInstanceMetricByGroupAndNameCall(String, String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceMetricByGroupAndName
getStreamsInstanceMetricByGroupAndNameWithHttpInfo(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the current metric for the streams instance, metric group and name
getStreamsInstanceMetrics(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the metrics for the Kafka Streams instance
getStreamsInstanceMetricsAsync(String, ApiCallback<List<V1MetricGroup>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the metrics for the Kafka Streams instance
getStreamsInstanceMetricsByGroup(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the metrics for the Kafka Streams instance
getStreamsInstanceMetricsByGroupAsync(String, String, ApiCallback<List<V1MetricGroup>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the metrics for the Kafka Streams instance
getStreamsInstanceMetricsByGroupCall(String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceMetricsByGroup
getStreamsInstanceMetricsByGroupWithHttpInfo(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the metrics for the Kafka Streams instance
getStreamsInstanceMetricsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceMetrics
getStreamsInstanceMetricsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the metrics for the Kafka Streams instance
getStreamsInstanceMetricValue(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the current metric value for the streams application, metric group and name
getStreamsInstanceMetricValueAsync(String, String, String, ApiCallback<String>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the current metric value for the streams application, metric group and name
getStreamsInstanceMetricValueCall(String, String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceMetricValue
getStreamsInstanceMetricValueWithHttpInfo(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the current metric value for the streams application, metric group and name
getStreamsInstanceStatus(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the status about the running tasks of the KafkaStreams instance
getStreamsInstanceStatusAsync(String, ApiCallback<V1StreamsStatus>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the status about the running tasks of the KafkaStreams instance
getStreamsInstanceStatusCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceStatus
getStreamsInstanceStatusWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the status about the running tasks of the KafkaStreams instance
getStreamsInstanceStoreOffsets(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: gets the partition lag and restoration info for all local state store
getStreamsInstanceStoreOffsetsAsync(String, ApiCallback<List<V1LocalStatePartitionsInfo>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) gets the partition lag and restoration info for all local state store
getStreamsInstanceStoreOffsetsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceStoreOffsets
getStreamsInstanceStoreOffsetsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: gets the partition lag and restoration info for all local state store
getStreamsInstanceTopology(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the topology graph of the Kafka Streams instance
getStreamsInstanceTopologyAsync(String, ApiCallback<V1StreamsTopology>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: (asynchronously) get the topology graph of the Kafka Streams instance
getStreamsInstanceTopologyCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: Build call for getStreamsInstanceTopology
getStreamsInstanceTopologyWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api: get the topology graph of the Kafka Streams instance
getStreamThread() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets: Get streamThread
getStreamThreadExceptionHandler() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment: Gets the StreamThreadExceptionHandler.
getString(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getString(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams: Gets the parameter as string for the given key.
getString(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams: Gets the parameter as string for the given key.
getString(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a string.
getStringList(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a list.
getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a list.
getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a list.
getStringList(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a list.
getSubConf(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a Conf.
getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a Conf.
getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a Conf.
getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a Conf.
getSubConf(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a Conf.
getSubConfList(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter as a list of Conf.
getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter as a list of Conf.
getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter as a list of Conf.
getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter as a list of Conf.
getSubConfList(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter as a list of Conf.
getSubTopologies() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
getSubTopologies() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology: Get subTopologies
getSuccess() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getSuccess() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get success
getSuccessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getSuccessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode: Get successors
getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf: Get successors
getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode: Get successors
getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf: Get successors
getSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
getSupportedEnvironmentTypes() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all supported environment types.
getSupportedEnvironmentTypes() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets all supported environment types.
GettableComponent<T> - Interface in io.streamthoughts.azkarra.api.components: Class for getting a configurable component.
getTags() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric: Get tags
getTaskId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata: The single task-id running within the KafkaStreams application
getTempFolderPath() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: The path of temporary folder used to store downloaded files from endpoints with file response.
getThreadName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get threadName
getThreads() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus: Get threads
getThreads() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
getThreadState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata: Get threadState
getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
getThrowable() - Method in interface io.streamthoughts.azkarra.api.monad.Try
getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
getTime() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams: Get time
getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams: Get timeFrom
getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams: Get timeFrom
getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams: Get timeFrom
getTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult: Get timeout
getTimeout() - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig
getTimeoutMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams: Get timeTo
getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams: Get timeTo
getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams: Get timeTo
getTook() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getTook() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult: Get took
getTopic() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNode
getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get topic
getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode: Get topic
getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf: Get topic
getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition: The name of the topic
getTopic() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the Topic of the partition being restored.
getTopic() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig: Get the topic on which monitoring event will be sent (Default is _azkarra-streams-monitoring).
getTopicPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets: Get topicPartition
getTopicPartitions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata: The assigned Topic/Partition
getTopics() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNode
getTopics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode: Get topics
getTopics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf: Get topics
getTopology() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Returns the wrapped Topology instance.
getTopology() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
getTopology() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer: Returns the wrapped Topology instance.
getTopologyByAliasAndQualifiers(String, Qualifier<? extends TopologyProvider>) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets the TopologyDescriptor for the specified alias and qualifier.
getTopologyByAliasAndQualifiers(String, Qualifier<? extends TopologyProvider>) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets the TopologyDescriptor for the specified alias and qualifier.
getTopologyByAliasAndVersion(String, String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets the TopologyDescriptor for the specified alias and version.
getTopologyByAliasAndVersion(String, String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets the TopologyDescriptor for the specified alias and version.
getTopologyDescriptors() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all topologies registered into this AzkarraContext even those ones which are not enable.
getTopologyDescriptors() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all topologies registered into this AzkarraContext even those ones which are not enable.
getTopologyDescriptors(StreamsExecutionEnvironment<?>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all topologies registered into this AzkarraContext which are available for the given environment.
getTopologyDescriptors(StreamsExecutionEnvironment<?>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all topologies registered into this AzkarraContext which are available for the given environment.
getTopologyDescriptors(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all topologies registered into this AzkarraContext which are available for the given environment.
getTopologyDescriptors(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all topologies registered into this AzkarraContext which are available for the given environment.
getTopologyProviders() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all topologies available locally.
getTopologyProviders() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets all topologies available locally.
getTopologyVersionsByAlias(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all versions of TopologyDescriptor for the specified alias.
getTopologyVersionsByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService: Gets all versions of TopologyDescriptor for the specified alias.
getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
getTotal() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get total
getTotal() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet: Get total
getTotalRestored() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo: Get totalRestored
getTotalRestored() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo: Gets the total number of records restored.
getTrustStoreLocation() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getTruststorePassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getTruststoreType() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getType() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getType() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
getType() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query: Get type
getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet: Get type
getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode: Get type
getType() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getUserDeclaredTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
getUserDetails() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication: Gets details about the authenticated user.
getUserDetails() - Method in class io.streamthoughts.azkarra.http.security.auth.UsernamePasswordAuthentication: Gets details about the authenticated user.
getUserIdentityManager() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getUsername() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
getUsers() - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
getValue() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric: Get value
getValue() - Method in enum io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum
getValue() - Method in enum io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
getValue() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record: Get value
getValue() - Method in class io.streamthoughts.azkarra.client.openapi.Pair
getValue(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Gets a required parameter value.
getValue(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Gets a required parameter value.
getValue(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter value.
getValue(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter value.
getValue(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams: Gets the parameter for the given key.
getValue(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams: Gets the parameter for the given key.
getValue(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter value.
getVersion() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
getVersion() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
getVersion() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails: Get version
getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getVersion() - Static method in class io.streamthoughts.examples.azkarra.Version
getWriteTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Get write timeout (in milliseconds).
getX509Certificate() - Method in class io.streamthoughts.azkarra.http.security.auth.X509CertificateCredentials
getX509TrustManager(TrustManager[]) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils: Helpers method to get the first X509TrustManager in the given TrustManager.
GlobalConsumerOffsetsRegistry - Class in io.streamthoughts.azkarra.api.streams.consumer
GlobalResultSet<K,V> - Class in io.streamthoughts.azkarra.api.query.result
GlobalResultSet(String, String, String, List<ErrorResultSet>, List<SuccessResultSet<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.GlobalResultSet: Creates a new GlobalResultSet instance.
GlobalResultSet(String, String, List<ErrorResultSet>, List<SuccessResultSet<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.GlobalResultSet: Creates a new GlobalResultSet instance.
globalStores(List<V1StreamsGlobalStore>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
GrantedAuthority - Interface in io.streamthoughts.azkarra.http.security.auth
group() - Method in class io.streamthoughts.azkarra.api.model.Metric
group() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
group(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
GroupMetricFilter - Class in io.streamthoughts.azkarra.api.model.predicate
GroupMetricFilter(String) - Constructor for class io.streamthoughts.azkarra.api.model.predicate.GroupMetricFilter: Creates a new GroupMetricFilter instance.
guessContentTypeFromFile(File) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Guess Content-Type header from the given file (defaults to "application/octet-stream").

H

handle(KafkaStreamsContainer, Thread, Throwable) - Method in interface io.streamthoughts.azkarra.api.streams.errors.StreamThreadExceptionHandler: Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler: Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.CloseKafkaStreamsOnThreadException: Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.LogAndSkipOnThreadException: Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.RestartKafkaStreamsOnThreadException: Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
handle(Callback[]) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler
handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
handleDefaultResponse(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.error.ExceptionDefaultResponseListener
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiApplicationsRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiContextRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiDocHttpRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiStreamsRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiTopologyRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.WebUIHttpRoutes
handler(AzkarraStreamsService) - Method in interface io.streamthoughts.azkarra.http.spi.RoutingHandlerProvider
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.error.ExceptionDefaultHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.HeadlessHttpHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetMetricsHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsPostHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsStopHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.authorizer.AuthorizationHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.AuthenticationContextHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.SecurityHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.XMLHttpRequestAwareAuthCallHandler: Only allow the request through if successfully authenticated or if authentication is not required.
handleResponse(Response, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient: Handle the given response, return the deserialized object when the response is successful.
hashCode() - Method in class io.streamthoughts.azkarra.api.ApplicationId
hashCode() - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
hashCode() - Method in class io.streamthoughts.azkarra.api.components.Restriction
hashCode() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
hashCode() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
hashCode() - Method in class io.streamthoughts.azkarra.api.errors.Error
hashCode() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
hashCode() - Method in class io.streamthoughts.azkarra.api.model.KV
hashCode() - Method in class io.streamthoughts.azkarra.api.model.Metric
hashCode() - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
hashCode() - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
hashCode() - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
hashCode() - Method in class io.streamthoughts.azkarra.api.monad.Tuple
hashCode() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
hashCode() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
hashCode() - Method in class io.streamthoughts.azkarra.api.query.QueryOptions
hashCode() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
hashCode() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsetsState
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerThreadKey
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.OffsetAndTimestamp
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.StateChangeEvent
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
hashCode() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
hashCode() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
hashCode() - Method in class io.streamthoughts.azkarra.api.util.Endpoint
hashCode() - Method in class io.streamthoughts.azkarra.api.util.Version
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
hashCode() - Method in class io.streamthoughts.azkarra.http.health.Health
hashCode() - Method in class io.streamthoughts.azkarra.http.health.Status
hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
hashCode() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
hashCode() - Method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata
hashCode() - Method in class io.streamthoughts.azkarra.streams.components.isolation.ExternalComponent
HasId - Interface in io.streamthoughts.azkarra.api.model: An interface representing a model that has an identifier.
hasKey() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
HasName - Interface in io.streamthoughts.azkarra.api.model: An interface representing a model that has a name.
hasPath(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf: Checks whether the specified path exists into this Conf.
hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf: Checks whether the specified path exists into this Conf.
hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Checks whether the specified path exists into this Conf.
hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Checks whether the specified path exists into this Conf.
hasPath(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Checks whether the specified path exists into this Conf.
havingValue() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn: Specify the expected value for the ConditionalOn.property().
HeadlessHttpHandler - Class in io.streamthoughts.azkarra.http.handler
HeadlessHttpHandler(HttpHandler) - Constructor for class io.streamthoughts.azkarra.http.handler.HeadlessHttpHandler: Creates a new HeadlessHttpHandler instance.
Health - Class in io.streamthoughts.azkarra.http.health: The Health wraps information about a service or sub-system.
Health.Builder - Class in io.streamthoughts.azkarra.http.health: Builder for creating new Health instances.
HealthAggregator - Class in io.streamthoughts.azkarra.http.health: The HealthAggregator aggregates multiple Health instances into a single one.
HealthAggregator() - Constructor for class io.streamthoughts.azkarra.http.health.HealthAggregator
HealthAggregator(StatusAggregator) - Constructor for class io.streamthoughts.azkarra.http.health.HealthAggregator
HealthIndicator - Interface in io.streamthoughts.azkarra.http.health
HIGHEST_ORDER - Static variable in interface io.streamthoughts.azkarra.api.components.Ordered
HOSTNAME - Static variable in class io.streamthoughts.azkarra.api.util.Network
HTTP_AUTH_PRINCIPAL_BUILDER_CLASS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
HTTP_AUTH_USER_IDENTITY_MANAGER_CLASS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
HTTP_AUTHORIZATION_MANAGER_CLASS_CONFIG - Static variable in class io.strea