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
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
DeadLetterTopicExceptionHandlerConfig(Map<String, ?>) - Constructor for class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
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
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
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
getApplicationIdBuilder() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
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
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