Index (Azkarra Streams 0.4 API)

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

A

abort() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
AbstractAuthentication<T extends Credentials> - Class in io.streamthoughts.azkarra.http.security.auth
AbstractAuthentication(Principal, T) - Constructor for class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication: Creates a new AbstractAuthentication instance.
AbstractConf - Class in io.streamthoughts.azkarra.api.config
AbstractConf() - Constructor for class io.streamthoughts.azkarra.api.config.AbstractConf
AbstractResultSet - Class in io.streamthoughts.azkarra.api.query.result
accept(Class<?>) - Method in interface io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.ClassAliasExtractor
accept(Class<?>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.DropClassNameSuffixExtractor
addAliases(Set<String>) - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Adds new aliases to reference the described component.
addClassAliasExtractor(ClassComponentAliasesGenerator.ClassAliasExtractor) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator
addComponent(ComponentFactory<T>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Registers a components into this context.
addComponent(ComponentFactory<T>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Registers a components into this context.
addComponent(Class<T>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Registers a components into this context.
addComponent(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Registers a components into this context.
addComponent(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Registers a components into this context.
addComponent(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Registers a components into this context.
addConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Adds the specified Conf to the configuration of this AzkarraContext.
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.
addDescriptorFactoryForType(Class<T>, ComponentDescriptorFactory<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentClassReader: Add a descriptor factory to this reader.
addDescriptorFactoryForType(Class<T>, ComponentDescriptorFactory<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultProviderClassReader: Add a descriptor factory to this reader.
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.
addFallbackConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.
addFallbackConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Adds streamsConfig that will be used in fallback if not present in defined environment streamsConfig.
addGlobalStateListener(StateRestoreListener) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addGlobalStateListener(StateRestoreListener) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Adds a StateRestoreListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addHandler(Thread.UncaughtExceptionHandler) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler
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
addNewEnvironment(String, Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Adds a new environment to this application.
addNewEnvironment(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Adds a new environment to this application.
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.
addStateListener(KafkaStreams.StateListener) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
addStateListener(KafkaStreams.StateListener) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Adds a KafkaStreams.StateListener instance that will set to all KafkaStreams instance created in this StreamsExecutionEnvironment.
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 interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
addTopology(Supplier<TopologyProvider>) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
addTopology(Supplier<TopologyProvider>, Executed) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
addTopology(Supplier<TopologyProvider>, Executed) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Add a new TopologyProvider instance to this StreamsExecutionEnvironment to be started.
addUsers(UserDetails) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
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 class io.streamthoughts.azkarra.api.components.ComponentDescriptor: 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.WindowQueryBuilder
ALL - io.streamthoughts.azkarra.api.query.StoreOperation
allGrantedAuthorities() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
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.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.
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.
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
ApiEnvironmentRoutes - Class in io.streamthoughts.azkarra.http.routes
ApiEnvironmentRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
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
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: Creates a new ApiStreamsRoutes instance.
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
ApplicationConfig - Class in io.streamthoughts.azkarra.streams.context.internal: Class which is used to initially configure a AzkarraContext instance.
ApplicationConfig.Reader - Class in io.streamthoughts.azkarra.streams.context.internal
ApplicationGetInstancesHandler - Class in io.streamthoughts.azkarra.http.handler
ApplicationGetInstancesHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.ApplicationGetInstancesHandler: Creates a new ApplicationGetInstancesHandler instance.
ApplicationGetTopologyHandler - Class in io.streamthoughts.azkarra.http.handler
ApplicationGetTopologyHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.ApplicationGetTopologyHandler: Creates a new ApplicationGetTopologyHandler instance.
applicationId() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets configured StreamsConfig.APPLICATION_ID_CONFIG for this KafkaStreams instance.
ApplicationId - Class in io.streamthoughts.azkarra.api.streams: Simple class to wrap the value of StreamsConfig.APPLICATION_ID_CONFIG.
ApplicationId(String) - Constructor for class io.streamthoughts.azkarra.api.streams.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(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler: Creates a new ApplicationQueryStoreHandler instance.
applications() - Method in class io.streamthoughts.azkarra.api.model.Environment
applications() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Returns all KafkaStreams started applications.
applications() - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Returns all KafkaStreams started applications.
apply() - Method in interface io.streamthoughts.azkarra.runtime.util.ShutdownHook.Hook
apply(A) - Method in class io.streamthoughts.azkarra.api.monad.Reader
apply(T) - Method in interface io.streamthoughts.azkarra.api.monad.CheckedFunction
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.
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.
assignments() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Gets the set of topic-partitions assigned to this instance.
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.
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 - 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) - 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
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.
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.
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
AzkarraContextLoader - Class in io.streamthoughts.azkarra.streams.context: Class which can be used for initializing an AzkarraContext instance from a specified Conf instance.
AzkarraContextLoader() - Constructor for class io.streamthoughts.azkarra.streams.context.AzkarraContextLoader
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.
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.
AzkarraPrincipalBuilder - Interface in io.streamthoughts.azkarra.http.security.auth: Pluggable builder interface which is used to build Principal object used during authorization.
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.
AzkarraVersion - Class in io.streamthoughts.azkarra.api
AzkarraVersion() - Constructor for class io.streamthoughts.azkarra.api.AzkarraVersion

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.
BASIC_AUTH - io.streamthoughts.azkarra.http.security.SecurityMechanism
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.
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>, boolean) - Constructor for class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Creates a new BasicComponentFactory 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
build() - Method in class io.streamthoughts.azkarra.api.config.ConfBuilder
build() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
build() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder: Builds a KafkaStreams instance.
build() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
build() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.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.query.HttpRemoteQueryBuilder: Builds the HttpRemoteQueryClient instance.
build() - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder
build() - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
build(String, QueryParams) - Method in interface io.streamthoughts.azkarra.api.query.internal.LocalStoreQueryBuilder
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) - Method in interface io.streamthoughts.azkarra.api.streams.ApplicationIdBuilder: Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
buildApplicationId(TopologyMetadata) - Method in class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder: Builds the StreamsConfig.APPLICATION_ID_CONFIG for the specified topology and configuration.
Builder() - Constructor for class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
Builder() - Constructor for class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
Builder() - Constructor for class io.streamthoughts.azkarra.http.health.Health.Builder: Creates a new Health.Builder instance.
buildKafkaStreams(ApplicationId, Conf) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer: Builds a new KafkaStreams for this Topology.
buildPrincipal(AuthenticationContext) - Method in interface io.streamthoughts.azkarra.http.security.auth.AzkarraPrincipalBuilder: Builds the Principal.
buildQuery(String, StoreOperation) - Method in enum io.streamthoughts.azkarra.api.query.StoreType
buildURL(String, String, String) - Method in interface io.streamthoughts.azkarra.http.query.QueryURLBuilder: Builds the URL used for querying a remote server for the specified application and state store.

C

canBeInstantiated(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
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
CLASS_NAME - Static variable in class io.streamsthoughts.azkarra.commons.error.ExceptionHeader
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
className() - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the name of the describe component.
ClasspathComponentScanner - Class in io.streamthoughts.azkarra.streams.components: The ClasspathComponentScanner class can be used used to scan the classpath for automatically registering declared classes annotated with Component and ComponentFactory classes.
ClasspathComponentScanner(ComponentClassReader, ComponentRegistry) - Constructor for class io.streamthoughts.azkarra.streams.components.ClasspathComponentScanner: Creates a new ClasspathComponentScanner instance.
ClassUtils - Class in io.streamthoughts.azkarra.api.util
ClassUtils() - Constructor for class io.streamthoughts.azkarra.api.util.ClassUtils
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.
close() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Closes this KafkaStreams instance.
close() - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry
close(boolean) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Closes this KafkaStreams instance.
close(String, Options) - Method in class io.streamthoughts.azkarra.api.streams.rocksdb.DefaultRocksDBConfigSetter
collect() - Method in class io.streamthoughts.azkarra.http.prometheus.KafkaStreamsMetricsCollector
commit() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
compareTo(ComponentDescriptor<T>) - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor
compareTo(KV<K, V>) - Method in class io.streamthoughts.azkarra.api.model.KV
compareTo(Metric) - Method in class io.streamthoughts.azkarra.api.model.Metric
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(TopicPartitions) - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
compareTo(Version) - Method in class io.streamthoughts.azkarra.api.util.Version
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: Creates a new ComplexWordCountTopologyModule instance.
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
ComponentClassReader - Interface in io.streamthoughts.azkarra.api.components: The ComponentClassReader serves as a proxy interface for registering components to ComponentRegistry.
ComponentDescriptor<T> - Class in io.streamthoughts.azkarra.api.components: The ComponentDescriptor is the base class used fro describing components.
ComponentDescriptor(Class<T>) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Creates a new ComponentDescriptor instance.
ComponentDescriptor(Class<T>, String) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Creates a new ComponentDescriptor instance.
ComponentDescriptorFactory<T> - Interface in io.streamthoughts.azkarra.api.components: Factory to create new ComponentDescriptor instance.
ComponentFactory<T> - Interface in io.streamthoughts.azkarra.api.components: The ComponentFactory interface is used for creating new component instance.
ComponentFactory.SimpleFactory<T> - Class in io.streamthoughts.azkarra.api.components
ComponentModule<T> - Class in io.streamthoughts.azkarra.api.components
ComponentModule(Class<T>) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentModule: Creates a new ComponentModule instance.
ComponentRegistry - Interface in io.streamthoughts.azkarra.api.components: The ComponentRegistry is the main interface for managing components used in an Azkarra application.
ComponentRegistryAware - Interface in io.streamthoughts.azkarra.api.components
components() - Method in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig: Gets all registered providers class name.
ComponentScan - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
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.
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.
conf() - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
Conf - Interface in io.streamthoughts.azkarra.api.config: Class which can be used for configuring components.
ConfBuilder - Class in io.streamthoughts.azkarra.api.config: Helper class which can be used for building new Conf instance.
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.handler.EnvironmentPostHandler.EnvironmentPayload
config() - Method in class io.streamthoughts.azkarra.api.model.Environment
config() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
config() - Method in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig: Gets the configuration for this environment.
config() - Method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig: Gets the Conf to be used for configuring the TopologyProvider and KafkaStreams instance.
configDef() - Static method in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
Configurable - Interface in io.streamthoughts.azkarra.api.config
ConfigurableStopWordsService - Class in io.streamthoughts.examples.azkarra.dependency
ConfigurableStopWordsService() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
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 class io.streamthoughts.azkarra.api.components.ComponentModule
configuration() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Returns Conf defined for this TopologyProvider.
configure(Conf) - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: 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.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.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(Map<String, ?>) - Method in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
ConfSerializer - Class in io.streamthoughts.azkarra.http.json.serializers: Json serializer for Conf.
ConfSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.ConfSerializer
CONSOLE - io.streamthoughts.azkarra.api.banner.Banner.Mode
contains(char[], char) - Static method in class io.streamthoughts.azkarra.api.util.Utils
contains(String) - Method in class io.streamthoughts.azkarra.api.query.QueryParams
context() - Method in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig: Gets the context configuration.
CONTEXT_COMPONENT_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig
CONTEXT_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig
CONTEXT_ENVIRONMENTS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig
ContextGetHandler - Class in io.streamthoughts.azkarra.http.handler
ContextGetHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.ContextGetHandler: Creates a new ContextGetHandler instance.
ContextGetHandler.ContextPayload - Class in io.streamthoughts.azkarra.http.handler
ContextPayload(Conf) - Constructor for class io.streamthoughts.azkarra.http.handler.ContextGetHandler.ContextPayload: Creates a new ContextGetHandler.ContextPayload instance.
count() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
COUNT - io.streamthoughts.azkarra.api.query.StoreOperation
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.DefaultStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance using the empty configuration and a generated unique name.
create(ComponentClassReader) - 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(ComponentRegistry) - 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.DefaultStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and using a generated env name.
create(Conf, String) - Static method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Static helper that can be used to creates a new StreamsExecutionEnvironment instance from the specified Conf and env name.
create(String) - Static method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: 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(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
CREATED - io.streamthoughts.azkarra.api.streams.StreamsState
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
customHeaders() - Method in class io.streamsthoughts.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

DEAD_LETTER_HEADERS_PREFIX - Static variable in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DEAD_LETTER_TOPIC_CONFIG - Static variable in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DEAD_LETTER_TOPIC_DOC - Static variable in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
DeadLetterTopicExceptionHandler - Class in io.streamsthoughts.azkarra.commons.error: A DeserializationExceptionHandler implementation that write rejected error to an dead-letter-topic.
DeadLetterTopicExceptionHandler() - Constructor for class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
DeadLetterTopicExceptionHandlerConfig - Class in io.streamsthoughts.azkarra.commons.error: Config class for DeadLetterTopicExceptionHandler.
DeadLetterTopicExceptionHandlerConfig(Map<String, ?>) - Constructor for class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig: Creates a new DeadLetterTopicExceptionHandlerConfig instance.
DEFAULT_ENV_NAME - Static variable in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
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
DefaultComponentRegistry - Class in io.streamthoughts.azkarra.runtime.components: The default ComponentRegistry implementation.
DefaultComponentRegistry() - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Creates a new DefaultComponentRegistry instance.
defaultExecutionEnvironment() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the default StreamsExecutionEnvironment.
defaultExecutionEnvironment() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the default StreamsExecutionEnvironment.
DefaultProviderClassReader - Class in io.streamthoughts.azkarra.runtime.components: Simple implementation for ComponentClassReader interface.
DefaultProviderClassReader() - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultProviderClassReader: Creates a new DefaultProviderClassReader instance.
DefaultRocksDBConfigSetter - Class in io.streamthoughts.azkarra.api.streams.rocksdb
DefaultRocksDBConfigSetter() - Constructor for class io.streamthoughts.azkarra.api.streams.rocksdb.DefaultRocksDBConfigSetter
DefaultRocksDBConfigSetter.DefaultRocksDBConfigSetterConfig - Class in io.streamthoughts.azkarra.api.streams.rocksdb
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.
DefaultStreamsConfig - Annotation Type in io.streamthoughts.azkarra.api.annotations: Marker interface that a TopologyProvider can used to define the configuration properties to be used for creating a new KafkaStreams instance.
DefaultStreamsConfigs - Annotation Type in io.streamthoughts.azkarra.api.annotations
DefaultStreamsExecutionEnvironment - Class in io.streamthoughts.azkarra.runtime.env: The default StreamsExecutionEnvironment implementation.
DefaultStreamsExecutionEnvironment(Conf) - Constructor for class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Creates a new DefaultStreamsExecutionEnvironment instance.
deleteStreams(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Deletes the streams instance for the specified streams application.
deleteStreams(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Deletes the streams instance for the specified streams application.
deleteUsersByName(String) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
DENIED - io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult
description - Variable in class io.streamthoughts.azkarra.api.Executed
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.runtime.streams.topology.InternalExecuted
description() - Method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig: Gets the user-defined topology description.
descriptionOrElseGet(String) - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
deserialize(byte[]) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given bytes array.
deserialize(byte[], Class<T>) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given bytes array.
deserialize(JsonNode, Class<T>) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given bytes array.
deserialize(InputStream) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given InputStream.
deserialize(InputStream, Class<T>) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given InputStream.
deserialize(String, byte[]) - Static method in class io.streamthoughts.azkarra.http.query.JsonQuerySerde
deserialize(String, Class<T>) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to deserialize a given InputStream.
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.ServerConfBuilder: Disables the headless mode.
disableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Disables SSL.
DistributedQuery<K,V> - Class in io.streamthoughts.azkarra.api.query: Default class to query a state storeName either locally or remotely.
DistributedQuery(RemoteQueryClient, PreparedQuery<K, V>) - Constructor for class io.streamthoughts.azkarra.api.query.DistributedQuery: Creates a new DistributedQuery instance.
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
DTF - Static variable in interface io.streamthoughts.azkarra.api.time.Time

E

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.QueryParams
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
EmptyConf - Class in io.streamthoughts.azkarra.api.config
EmptyConf() - Constructor for class io.streamthoughts.azkarra.api.config.EmptyConf
ENABLE_WAIT_FOR_TOPICS_CONFIG - Static variable in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
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.ServerConfBuilder: Enables the headless mode.
enableHttpServer(boolean) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
enableHttpServer(boolean, Conf) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
enableHttpServer(boolean, HttpServerConf) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
enablePasswordAuthentication(boolean) - Method in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryBuilder: Sets if authentication is required.
enableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Enables the SSL.
enableUI(boolean) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets if the Web UI must be enable.
environment() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.EnableAutoStart
Environment - Class in io.streamthoughts.azkarra.api.model
Environment(String, State, Map<String, Object>, Set<String>, boolean) - Constructor for class io.streamthoughts.azkarra.api.model.Environment: Creates a new Environment instance.
ENVIRONMENT_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig
ENVIRONMENT_NAME_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig
ENVIRONMENT_STREAMS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig
EnvironmentConfig - Class in io.streamthoughts.azkarra.streams.context.internal: Class which is used to configure a StreamsExecutionEnvironment instance.
EnvironmentConfig.Reader - Class in io.streamthoughts.azkarra.streams.context.internal
EnvironmentGetListHandler - Class in io.streamthoughts.azkarra.http.handler
EnvironmentGetListHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.EnvironmentGetListHandler: Creates a new EnvironmentGetListHandler instance.
EnvironmentPayload(String, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.http.handler.EnvironmentPostHandler.EnvironmentPayload
EnvironmentPostHandler - Class in io.streamthoughts.azkarra.http.handler
EnvironmentPostHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.EnvironmentPostHandler: Creates a new EnvironmentPostHandler instance.
EnvironmentPostHandler.EnvironmentPayload - Class in io.streamthoughts.azkarra.http.handler
environments() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all StreamsExecutionEnvironment registered to this context.
environments() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all StreamsExecutionEnvironment registered to this context.
environments() - Method in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig: Gets all registered environments.
equals(Object) - Method in class io.streamthoughts.azkarra.api.errors.Error
equals(Object) - Method in class io.streamthoughts.azkarra.api.model.Environment
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.monad.Tuple
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.Queried
equals(Object) - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
equals(Object) - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.ApplicationId
equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo
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.util.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
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 storeName.
ERROR - io.streamthoughts.azkarra.api.streams.State
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.
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
exception() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the last observed exception thrown the KafkaStreams instance.
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.streamsthoughts.azkarra.commons.error: The default record-headers added to record write to the dead-letter-topic.
ExceptionHeader() - Constructor for class io.streamsthoughts.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
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueCountQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.PreparedQuery: Executes this query locally on the specified streams instance.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchKeyRangeQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchAllQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchKeyRangeQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchTimeRangeQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowGetAllQuery: Executes this query to the specified KafkaStreams application.
execute(KafkaStreamsContainer, Queried) - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreQuery: Executes this query to the specified KafkaStreams application.
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
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

failable(CheckedSupplier<V, E>) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
FAILED - io.streamthoughts.azkarra.api.streams.StreamsState
failure(Throwable) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
FATAL_ERRORS_CONFIG - Static variable in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
FATAL_ERRORS_DOC - Static variable in class io.streamsthoughts.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.WindowQueryBuilder
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.WindowQueryBuilder
fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
fetchTimeRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
findAllDescriptorByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
findAllDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
findAllDescriptorsByType(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Finds all registered providers for the specified type.
findAllDescriptorsByType(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Finds all registered providers for the specified type.
findDescriptorByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
findDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
findLatestDescriptorByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
findLatestDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Finds a ComponentDescriptor for the specified class or alias.
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>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
flatMap(Function<? super V, Try>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
flatMap(Function<? super V, Try>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
flatMap(Function<? super V, Try>) - 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
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
FutureCollectors - Class in io.streamthoughts.azkarra.api.util

G

GenericRecordSerializer - Class in io.streamthoughts.azkarra.http.json.serializers
GenericRecordSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.GenericRecordSerializer
get() - Method in class io.streamthoughts.azkarra.api.config.Property
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 interface io.streamthoughts.azkarra.api.providers.Provider: Gets the component instance.
get() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
get() - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessor.StoreSupplier
get() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Supplies a new Kafka Streams Topology instance.
get() - Method in interface io.streamthoughts.azkarra.api.streams.TopologyProvider: Supplies a new Kafka Streams Topology instance.
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.examples.azkarra.dependency.ComplexWordCountTopology
get() - Method in class io.streamthoughts.examples.azkarra.topology.BasicWordCountTopology
get() - Method in class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
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(Queried) - Method in class io.streamthoughts.azkarra.api.query.LocalStoreAccessor
get(String) - Static method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
GET - io.streamthoughts.azkarra.api.query.StoreOperation
getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentAliasesGenerator: Gets unique aliases for the specified ComponentDescriptor descriptor.
getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator: Gets unique aliases for the specified ComponentDescriptor descriptor.
getAllComponentForType(Class<T>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Get all component instances for the specified class.
getAllComponentForType(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Get all component instances for the specified class.
getAllComponents(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets all instances, which may be shared or independent, for the specified type.
getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets all instances, which may be shared or independent, for the specified type.
getAllComponentsForType(Class<C>) - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: Gets all instances, which may be shared or independent, for the specified type.
getAllDeclaredAnnotationByType(Class<?>, Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
getAllEnvironments() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all existing streams environments.
getAllEnvironments() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets all existing streams environments.
getAllMetadata() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
getAllMetadataForStore(String) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
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.
getAllStreams() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the list of all running streams applications.
getAllStreams() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the list of all running streams applications.
getAllSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
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
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
getAuthenticationUsers() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
getAuthorizationManager() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
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.ConfBuilder: 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.
getBytes(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getCertificate() - Method in class io.streamthoughts.azkarra.http.security.auth.SSLClientAuthentication
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.ConfBuilder: 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(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.ConfBuilder: 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
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.
getCode() - Method in class io.streamthoughts.azkarra.http.health.Status
getComponent(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getComponentClassReader() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the internal ComponentClassReader.
getComponentClassReader() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the internal ComponentClassReader.
getComponentForClassOrAlias(String) - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: Gets an instance, which may be shared or independent, for the specified type.
getComponentForType(Class<C>) - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: Gets an instance, which may be shared or independent, for the specified type.
getComponentForType(Class<T>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets a component instance for the specified class.
getComponentForType(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets a component instance for the specified class.
getComponentRegistry() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the internal ComponentRegistry.
getComponentRegistry() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the internal ComponentRegistry.
getConf() - Method in class io.streamthoughts.azkarra.streams.config.internal.InternalHttpServerConf
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.ConfBuilder: 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.ConfBuilder: 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 class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getConfig() - Method in class io.streamthoughts.azkarra.http.handler.ContextGetHandler.ContextPayload
getConfiguration() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Returns the global context streamsConfig of this AzkarraContext instance.
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.DefaultStreamsExecutionEnvironment: Gets this environment configuration.
getConfiguration() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Gets the configuration for this AzkarraApplication.
getContext() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Gets the AzkarraContext.
getContextConfig() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
getContextConfig() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
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
getDate(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getDefaultKeySerde() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the default Serde configured for key.
getDescription() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
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.ConfBuilder: 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.
getEnv() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getEnvironmentForNameOrCreate(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the StreamsExecutionEnvironment for the specified name or create a new one.
getEnvironmentForNameOrCreate(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the StreamsExecutionEnvironment for the specified name or create a new one.
getErrorCode() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getErrors() - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
getException() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getException() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
getFailure() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getFatalExceptions() - Method in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
getFloat(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
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
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
getId() - Method in class io.streamthoughts.azkarra.api.model.StreamsStatus
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.http.data.StreamsInstanceResponse
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.ConfBuilder: 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.
getKeyPassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
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
getLatest(Version...) - Static method in class io.streamthoughts.azkarra.api.util.Version: Static helper for returning the latest version from a list of Version.
getLatestComponent(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getLatestComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getLatestComponent(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getLatestComponent(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getList(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getLocalKeyValueStore(String) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
getLocalServerInfo() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
getLocalSessionStore(String) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
getLocalStoreAccess(String, QueryableStoreType<T>) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
getLocalWindowStore(String) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
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.ConfBuilder: 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.streams.config.AzkarraConf: Gets a required parameter as a long.
getMainApplicationClass() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
getMessage() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getMetadata() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer
getMetadataForStoreAndKey(String, K, Serializer<K>) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
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 class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
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
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
getPath() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
getPort() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
getPredecessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getPredecessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
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
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
getRecords() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
getResult() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getRetries() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
getRetryBackoff() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
getRoles() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
getSecurityMechanism() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext
getSecurityMechanism() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext
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
getShort(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.State
getSource() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
getSSLContext() - Method in class io.streamthoughts.azkarra.http.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.
getState() - Method in class io.streamthoughts.azkarra.api.model.StreamsStatus
getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.State
getStatus() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getStatus() - Method in class io.streamthoughts.azkarra.http.health.Health: Gets the health indicator status.
getStore() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getStores() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNode
getStreamBuilder() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider: Returns the StreamsBuilder which is used to build the Topology instance.
getStreamsById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the KafkaStreamsContainer for the specified streams application.
getStreamsById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the KafkaStreamsContainer for the specified streams application.
getStreamsConfigById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the Conf for the specified streams application.
getStreamsConfigById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the Conf for the specified streams application.
getStreamsInstancesById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all local and remote streams instances for the specified streams application.
getStreamsInstancesById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets all local and remote streams instances for the specified streams application.
getStreamsMetricsById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all metrics for the specified streams application.
getStreamsMetricsById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets all metrics for the specified streams application.
getStreamsMetricsById(String, Predicate<Tuple<String, Metric>>) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets metrics for the specified streams application matching a predicate.
getStreamsMetricsById(String, Predicate<Tuple<String, Metric>>) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets metrics for the specified streams application matching a predicate.
getStreamsStatusById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the status for the specified streams application.
getStreamsStatusById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the status for the specified streams application.
getStreamsTopologyById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Returns the StreamsTopologyGraph for the specified streams application.
getStreamsTopologyById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Returns the StreamsTopologyGraph for the specified streams application.
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 a a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.ConfBuilder: Gets a required parameter a a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf: Gets a required parameter a a string.
getString(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf: Gets a required parameter a a string.
getString(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf: Gets a required parameter a 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.ConfBuilder
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.ConfBuilder: 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.ConfBuilder: 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
getSuccess() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getSuccessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
getSuccessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
getSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
getThreads() - Method in class io.streamthoughts.azkarra.api.model.StreamsStatus
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
getTook() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
getTopic() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNode
getTopics() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNode
getTopology() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer
getTopology(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets the topology for the specified class name or alias.
getTopology(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets the topology for the specified class name or alias.
getTopologyProviders() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Gets all topologies available locally.
getTopologyProviders() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Gets all topologies available locally.
getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
getTrustManager() - Method in class io.streamthoughts.azkarra.http.security.SSLContextFactory
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 interface io.streamthoughts.azkarra.api.components.ComponentFactory: Returns the type of the component created by this ComponentFactory.
getType() - Method in class io.streamthoughts.azkarra.api.components.ComponentFactory.SimpleFactory: Returns the type of the component created by this ComponentFactory.
getType() - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: Returns the type of the component created by this ComponentFactory.
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.http.data.StreamsTopologyRequest
getType() - Method in class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Returns the type of the component created by this ComponentFactory.
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
getUsers() - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
getValue(String) - Method in class io.streamthoughts.azkarra.api.query.QueryParams
getVersion() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
getVersion() - Static method in class io.streamthoughts.examples.azkarra.Version
getVersionedComponent(String, String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getVersionedComponent(String, String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Gets an instance, which may be shared or independent, for the specified type.
getX509Certificate() - Method in class io.streamthoughts.azkarra.http.security.auth.X509CertificateCredentials
GlobalResultSet<K,V> - Class in io.streamthoughts.azkarra.api.query.result
GlobalResultSet(String, String, List<ErrorResultSet>, List<SuccessResultSet<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.GlobalResultSet: Creates a new GlobalResultSet instance.
GrantedAuthority - Interface in io.streamthoughts.azkarra.http.security.auth
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.

H

handle(Callback[]) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler
handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - Method in class io.streamsthoughts.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.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.ContextGetHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.EnvironmentGetListHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.EnvironmentPostHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.HeadlessHttpHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetListHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsPostHandler
handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.TopologyListHandler
handleRequest(HttpServerExchange) - Method in interface io.streamthoughts.azkarra.http.handler.WithApplication
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.
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.ApplicationGetInstancesHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.ApplicationGetTopologyHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsDeleteHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetConfigHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetDetailsHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetMetricsHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetStatusHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsRestartHandler
handleRequest(HttpServerExchange, String) - Method in class io.streamthoughts.azkarra.http.handler.StreamsStopHandler
handleRequest(HttpServerExchange, String) - Method in interface io.streamthoughts.azkarra.http.handler.WithApplication
hashCode() - Method in class io.streamthoughts.azkarra.api.errors.Error
hashCode() - Method in class io.streamthoughts.azkarra.api.model.Environment
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.monad.Tuple
hashCode() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery
hashCode() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery
hashCode() - Method in class io.streamthoughts.azkarra.api.query.Queried
hashCode() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
hashCode() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.ApplicationId
hashCode() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo
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.util.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
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.ConfBuilder: 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.
HeadlessHttpHandler - Class in io.streamthoughts.azkarra.http.handler
HeadlessHttpHandler(boolean, 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
host() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Gets the stream application host.
hostAndPort() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo
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.streamthoughts.azkarra.http.security.SecurityConfig
HTTP_ENABLE_UI - Static variable in class io.streamthoughts.azkarra.http.ServerConfBuilder
HTTP_HEADLESS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
HTTP_LISTENER_LISTER_CONFIG - Static variable in class io.streamthoughts.azkarra.http.ServerConfBuilder
HTTP_PORT_CONFIG - Static variable in class io.streamthoughts.azkarra.http.ServerConfBuilder
HTTP_RESTRICTED_ROLES_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
httpMethod() - Method in class io.streamthoughts.azkarra.http.security.authorizer.HttpResource
HttpRemoteQueryBuilder - Class in io.streamthoughts.azkarra.http.query: Builder class for creating a new HttpRemoteQueryClient instance.
HttpRemoteQueryBuilder() - Constructor for class io.streamthoughts.azkarra.http.query.HttpRemoteQueryBuilder
HttpRemoteQueryClient - Class in io.streamthoughts.azkarra.http.query
HttpRemoteQueryClient(OkHttpClient, QueryURLBuilder) - Constructor for class io.streamthoughts.azkarra.http.query.HttpRemoteQueryClient: Creates a new HttpRemoteQueryClient instance.
HttpResource - Class in io.streamthoughts.azkarra.http.security.authorizer
HttpResource(String, String) - Constructor for class io.streamthoughts.azkarra.http.security.authorizer.HttpResource: Creates a new HttpResource instance.
HttpServerConf - Class in io.streamthoughts.azkarra.streams.config
HttpServerConf(HttpServerConf) - Constructor for class io.streamthoughts.azkarra.streams.config.HttpServerConf: Creates a new HttpServerConf instance.
HttpServerConf(String, Integer, Map<String, Object>, Conf) - Constructor for class io.streamthoughts.azkarra.streams.config.HttpServerConf: Creates a new HttpServerConf instance.

I

id() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Gets the stream application id.
ifExceptionOfType(Class<? extends Exception>) - Method in class io.streamthoughts.azkarra.api.monad.Retry
immediatly() - Static method in class io.streamthoughts.azkarra.api.query.Queried
incrementalVersion() - Method in class io.streamthoughts.azkarra.api.util.Version
info() - Method in interface io.streamthoughts.azkarra.api.server.EmbeddedHttpServer
info() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
InMemoryUserIdentityManager - Class in io.streamthoughts.azkarra.http.security.auth
InMemoryUserIdentityManager() - Constructor for class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager: Creates a new InMemoryUserIdentityManager instance.
INTERNAL_ENV_NAME_PREFIX - Static variable in class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder
InternalExecuted - Class in io.streamthoughts.azkarra.runtime.streams.topology
InternalExecuted() - Constructor for class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted: Creates a new InternalExecuted instance.
InternalExecuted(Executed) - Constructor for class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted: Creates a new InternalExecuted instance.
InternalHttpServerConf - Class in io.streamthoughts.azkarra.streams.config.internal
InternalHttpServerConf(HttpServerConf) - Constructor for class io.streamthoughts.azkarra.streams.config.internal.InternalHttpServerConf: Creates a new InternalHttpServerConf instance.
InternalHttpServerConf(String, int) - Constructor for class io.streamthoughts.azkarra.streams.config.internal.InternalHttpServerConf
INVALID - io.streamthoughts.azkarra.api.query.result.QueryStatus: The query is not valid.
InvalidConfException - Exception in io.streamthoughts.azkarra.api.errors
InvalidConfException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.InvalidConfException: Creates a new InvalidConfException instance.
InvalidConfException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.InvalidConfException: Creates a new InvalidConfException instance.
InvalidHttpQueryParamException - Exception in io.streamthoughts.azkarra.http.error: Exception which is thrown when a param is missing or invalid.
InvalidHttpQueryParamException(String) - Constructor for exception io.streamthoughts.azkarra.http.error.InvalidHttpQueryParamException: Creates a new InvalidHttpQueryParamException instance.
InvalidStateStoreQueryException - Exception in io.streamthoughts.azkarra.http.error: Exception which is thrown when an invalid query is received.
InvalidStateStoreQueryException(String) - Constructor for exception io.streamthoughts.azkarra.http.error.InvalidStateStoreQueryException
InvalidStateStoreQueryException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.http.error.InvalidStateStoreQueryException
io.streamsthoughts.azkarra.commons.error - package io.streamsthoughts.azkarra.commons.error
io.streamthoughts.azkarra.api - package io.streamthoughts.azkarra.api
io.streamthoughts.azkarra.api.annotations - package io.streamthoughts.azkarra.api.annotations
io.streamthoughts.azkarra.api.banner - package io.streamthoughts.azkarra.api.banner
io.streamthoughts.azkarra.api.components - package io.streamthoughts.azkarra.api.components
io.streamthoughts.azkarra.api.config - package io.streamthoughts.azkarra.api.config
io.streamthoughts.azkarra.api.errors - package io.streamthoughts.azkarra.api.errors
io.streamthoughts.azkarra.api.model - package io.streamthoughts.azkarra.api.model
io.streamthoughts.azkarra.api.model.predicate - package io.streamthoughts.azkarra.api.model.predicate
io.streamthoughts.azkarra.api.monad - package io.streamthoughts.azkarra.api.monad
io.streamthoughts.azkarra.api.providers - package io.streamthoughts.azkarra.api.providers
io.streamthoughts.azkarra.api.query - package io.streamthoughts.azkarra.api.query
io.streamthoughts.azkarra.api.query.internal - package io.streamthoughts.azkarra.api.query.internal
io.streamthoughts.azkarra.api.query.result - package io.streamthoughts.azkarra.api.query.result
io.streamthoughts.azkarra.api.server - package io.streamthoughts.azkarra.api.server
io.streamthoughts.azkarra.api.spi - package io.streamthoughts.azkarra.api.spi
io.streamthoughts.azkarra.api.streams - package io.streamthoughts.azkarra.api.streams
io.streamthoughts.azkarra.api.streams.admin - package io.streamthoughts.azkarra.api.streams.admin
io.streamthoughts.azkarra.api.streams.listener - package io.streamthoughts.azkarra.api.streams.listener
io.streamthoughts.azkarra.api.streams.rocksdb - package io.streamthoughts.azkarra.api.streams.rocksdb
io.streamthoughts.azkarra.api.streams.topology - package io.streamthoughts.azkarra.api.streams.topology
io.streamthoughts.azkarra.api.time - package io.streamthoughts.azkarra.api.time
io.streamthoughts.azkarra.api.util - package io.streamthoughts.azkarra.api.util
io.streamthoughts.azkarra.http - package io.streamthoughts.azkarra.http
io.streamthoughts.azkarra.http.data - package io.streamthoughts.azkarra.http.data
io.streamthoughts.azkarra.http.error - package io.streamthoughts.azkarra.http.error
io.streamthoughts.azkarra.http.handler - package io.streamthoughts.azkarra.http.handler
io.streamthoughts.azkarra.http.health - package io.streamthoughts.azkarra.http.health
io.streamthoughts.azkarra.http.health.internal - package io.streamthoughts.azkarra.http.health.internal
io.streamthoughts.azkarra.http.json - package io.streamthoughts.azkarra.http.json
io.streamthoughts.azkarra.http.json.serializers - package io.streamthoughts.azkarra.http.json.serializers
io.streamthoughts.azkarra.http.prometheus - package io.streamthoughts.azkarra.http.prometheus
io.streamthoughts.azkarra.http.query - package io.streamthoughts.azkarra.http.query
io.streamthoughts.azkarra.http.routes - package io.streamthoughts.azkarra.http.routes
io.streamthoughts.azkarra.http.security - package io.streamthoughts.azkarra.http.security
io.streamthoughts.azkarra.http.security.auth - package io.streamthoughts.azkarra.http.security.auth
io.streamthoughts.azkarra.http.security.authorizer - package io.streamthoughts.azkarra.http.security.authorizer
io.streamthoughts.azkarra.http.security.handler - package io.streamthoughts.azkarra.http.security.handler
io.streamthoughts.azkarra.http.security.jaas.spi - package io.streamthoughts.azkarra.http.security.jaas.spi
io.streamthoughts.azkarra.http.spi - package io.streamthoughts.azkarra.http.spi
io.streamthoughts.azkarra.runtime.components - package io.streamthoughts.azkarra.runtime.components
io.streamthoughts.azkarra.runtime.context - package io.streamthoughts.azkarra.runtime.context
io.streamthoughts.azkarra.runtime.env - package io.streamthoughts.azkarra.runtime.env
io.streamthoughts.azkarra.runtime.service - package io.streamthoughts.azkarra.runtime.service
io.streamthoughts.azkarra.runtime.streams - package io.streamthoughts.azkarra.runtime.streams
io.streamthoughts.azkarra.runtime.streams.topology - package io.streamthoughts.azkarra.runtime.streams.topology
io.streamthoughts.azkarra.runtime.util - package io.streamthoughts.azkarra.runtime.util
io.streamthoughts.azkarra.streams - package io.streamthoughts.azkarra.streams
io.streamthoughts.azkarra.streams.autoconfigure - package io.streamthoughts.azkarra.streams.autoconfigure
io.streamthoughts.azkarra.streams.autoconfigure.annotations - package io.streamthoughts.azkarra.streams.autoconfigure.annotations
io.streamthoughts.azkarra.streams.banner - package io.streamthoughts.azkarra.streams.banner
io.streamthoughts.azkarra.streams.banner.internal - package io.streamthoughts.azkarra.streams.banner.internal
io.streamthoughts.azkarra.streams.components - package io.streamthoughts.azkarra.streams.components
io.streamthoughts.azkarra.streams.config - package io.streamthoughts.azkarra.streams.config
io.streamthoughts.azkarra.streams.config.internal - package io.streamthoughts.azkarra.streams.config.internal
io.streamthoughts.azkarra.streams.context - package io.streamthoughts.azkarra.streams.context
io.streamthoughts.azkarra.streams.context.internal - package io.streamthoughts.azkarra.streams.context.internal
io.streamthoughts.examples.azkarra - package io.streamthoughts.examples.azkarra
io.streamthoughts.examples.azkarra.dependency - package io.streamthoughts.examples.azkarra.dependency
io.streamthoughts.examples.azkarra.healthcheck - package io.streamthoughts.examples.azkarra.healthcheck
io.streamthoughts.examples.azkarra.noannotation - package io.streamthoughts.examples.azkarra.noannotation
io.streamthoughts.examples.azkarra.security - package io.streamthoughts.examples.azkarra.security
io.streamthoughts.examples.azkarra.topology - package io.streamthoughts.examples.azkarra.topology
isAnnotationOfType(Annotation, Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
isAuthenticated() - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication: Checks whether the user has been authenticated successfully.
isAuthenticated() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication: Checks whether the user has been authenticated successfully.
isBasicAuthenticationSilent() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
isCloseable() - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Checks whether the describe component implement Closeable.
isConfigurable(Class) - Static method in interface io.streamthoughts.azkarra.api.config.Configurable
isDefault() - Method in class io.streamthoughts.azkarra.api.model.Environment
isFailure() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
isFailure() - Method in interface io.streamthoughts.azkarra.api.monad.Try
isFailure() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
isFailure() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
isHeadless() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
isHostnameVerificationIgnored() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
isKeyedQuery() - Method in class io.streamthoughts.azkarra.api.query.internal.PreparedQuery
isLeft() - Method in class io.streamthoughts.azkarra.api.monad.Either: Returns true if this is a Either.Left, false otherwise.
isLeft() - Method in class io.streamthoughts.azkarra.api.monad.Either.Left
isLeft() - Method in class io.streamthoughts.azkarra.api.monad.Either.Right
isLocal() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Checks whether this instance is local.
isNullKey() - Method in class io.streamthoughts.azkarra.api.model.KV
isNullOrEmpty(String) - Static method in class io.streamthoughts.azkarra.api.util.Utils
isNumber(String) - Static method in class io.streamthoughts.azkarra.api.util.Utils
isRegistered(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Checks whether the specified components class or alias is already registered.
isRegistered(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Checks whether the specified components class or alias is already registered.
isRemote() - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
isRemoteAccessAllowed() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
isRestAuthenticationEnable() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
isRight() - Method in class io.streamthoughts.azkarra.api.monad.Either: Returns true if this is a Either.Right, false otherwise.
isRight() - Method in class io.streamthoughts.azkarra.api.monad.Either.Left
isRight() - Method in class io.streamthoughts.azkarra.api.monad.Either.Right
isSingleton() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Returns the if the instance created from this ComponentFactory must be shared across the application.
isSingleton() - Method in class io.streamthoughts.azkarra.api.components.ComponentFactory.SimpleFactory: Returns the if the instance created from this ComponentFactory must be shared across the application.
isSingleton() - Method in class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Returns the if the instance created from this ComponentFactory must be shared across the application.
isSslEnable() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
isSuccess() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
isSuccess() - Method in interface io.streamthoughts.azkarra.api.monad.Try
isSuccess() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
isSuccess() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
isSuperTypesAnnotatedWith(Class<?>, Class<A>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
isTimeout() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
isValid() - Method in class io.streamthoughts.azkarra.api.monad.Validator
isVersioned() - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Checks whether the described component has a valid versioned.

J

JAASAuthentication - Class in io.streamthoughts.azkarra.http.security.auth
JAASAuthentication(Principal, PasswordCredentials) - Constructor for class io.streamthoughts.azkarra.http.security.auth.JAASAuthentication: Creates a new UsernamePasswordAuthentication instance.
JAASAuthentication(Principal, PasswordCredentials, LoginContext) - Constructor for class io.streamthoughts.azkarra.http.security.auth.JAASAuthentication: Creates a new UsernamePasswordAuthentication instance.
JSON - Static variable in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryClient
JsonQuerySerde - Class in io.streamthoughts.azkarra.http.query: Class which is used to serialize / deserialize a JSON query.
JsonQuerySerde() - Constructor for class io.streamthoughts.azkarra.http.query.JsonQuerySerde
JsonSerdes - Class in io.streamthoughts.azkarra.http.json: Helper class for wrapping ObjectMapper.
JsonSerdes() - Constructor for class io.streamthoughts.azkarra.http.json.JsonSerdes

K

KafkaStreamContainerBuilder - Class in io.streamthoughts.azkarra.api.streams: Default builder class for creating and configuring a new wrapped KafkaStreams instance.
KafkaStreamsContainer - Class in io.streamthoughts.azkarra.api.streams
KafkaStreamsFactory - Interface in io.streamthoughts.azkarra.api.streams: The interface which is used for creating new KafkaStreams instance.
KafkaStreamsMetricsCollector - Class in io.streamthoughts.azkarra.http.prometheus: Simple Collector implementation for collecting metrics from KafkaStreams instance.
KafkaStreamsMetricsCollector(AzkarraStreamsService, Predicate<Tuple<String, Metric>>, String...) - Constructor for class io.streamthoughts.azkarra.http.prometheus.KafkaStreamsMetricsCollector: Creates a new KafkaStreamsMetricsCollector instance.
key() - Method in class io.streamthoughts.azkarra.api.model.KV
key() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery
key() - Method in class io.streamthoughts.azkarra.api.query.internal.PreparedQuery
KEY_VALUE - io.streamthoughts.azkarra.api.query.StoreType: Key-Value storeName.
KeyedLocalStoreQuery<T,K,V> - Class in io.streamthoughts.azkarra.api.query.internal
keySerializer() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery
keySerializer() - Method in class io.streamthoughts.azkarra.api.query.internal.PreparedQuery
keyValue() - Method in class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Key-Value storeName.
KeyValueCountQuery - Class in io.streamthoughts.azkarra.api.query.internal
KeyValueGetAllQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
KeyValueGetQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
KeyValueGetRangeQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
KeyValueQueryBuilder - Class in io.streamthoughts.azkarra.api.query.internal
KV<K,V> - Class in io.streamthoughts.azkarra.api.model: Simple key/value pair.
KV(K, V) - Constructor for class io.streamthoughts.azkarra.api.model.KV: Creates a new KV instance.

L

left() - Method in class io.streamthoughts.azkarra.api.monad.Either
left() - Method in class io.streamthoughts.azkarra.api.monad.Tuple
left(L) - Static method in class io.streamthoughts.azkarra.api.monad.Either
listener - Variable in class io.streamthoughts.azkarra.streams.config.HttpServerConf
load(AzkarraContext, Conf) - Static method in class io.streamthoughts.azkarra.streams.context.AzkarraContextLoader: Initialize the specified AzkarraContext using the specified Conf.
load(AzkarraContext, ApplicationConfig) - Static method in class io.streamthoughts.azkarra.streams.context.AzkarraContextLoader: Initialize the specified AzkarraContext using the specified ApplicationConfig.
load(AzkarraApplication) - Method in class io.streamthoughts.azkarra.streams.autoconfigure.AutoConfigure
LocalAzkarraStreamsService - Class in io.streamthoughts.azkarra.runtime.service: The default AzkarraStreamsService implementations.
LocalAzkarraStreamsService(AzkarraContext, RemoteQueryClient) - Constructor for class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Creates a new LocalAzkarraStreamsService instance.
locally() - Static method in class io.streamthoughts.azkarra.api.query.Queried
LocalStoreAccessor<T> - Class in io.streamthoughts.azkarra.api.query: Default class to wrap access to local state store.
LocalStoreAccessor(LocalStoreAccessor.StoreSupplier<T>) - Constructor for class io.streamthoughts.azkarra.api.query.LocalStoreAccessor: Creates a new LocalStoreAccessor instance.
LocalStoreAccessor.StoreSupplier<T> - Interface in io.streamthoughts.azkarra.api.query
LocalStoreQuery<K,V> - Interface in io.streamthoughts.azkarra.api.query: Default interface to execute a local state storeName.
LocalStoreQueryBuilder<K,V> - Interface in io.streamthoughts.azkarra.api.query.internal
LocalStoreQueryBuilder.MissingRequiredKeyError - Class in io.streamthoughts.azkarra.api.query.internal
LOG - io.streamthoughts.azkarra.api.banner.Banner.Mode
LOG - Static variable in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry
login() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
logout() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule

M

main(String[]) - Static method in class io.streamthoughts.examples.azkarra.dependency.StreamsApplication
main(String[]) - Static method in class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample
main(String[]) - Static method in class io.streamthoughts.examples.azkarra.noannotation.StreamsApplication
main(String[]) - Static method in class io.streamthoughts.examples.azkarra.security.BasicAuthenticationExample
main(String[]) - Static method in class io.streamthoughts.examples.azkarra.security.SSLAuthenticationExample
majorVersion() - Method in class io.streamthoughts.azkarra.api.util.Version
make() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory: Creates a new instance for the specified type.
make() - Method in class io.streamthoughts.azkarra.api.components.ComponentFactory.SimpleFactory: Creates a new instance for the specified type.
make() - Method in class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory: Creates a new instance for the specified type.
make() - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopologyModule
make(KafkaStreamsContainer) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory: Creates a new KafkaStreams instance for the specified container.
make(TopologyProvider, Conf, Executed) - Method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyFactory: Makes a Topology instance using the specified TopologyDescriptor.
make(SecurityConfig, HttpHandler) - Method in class io.streamthoughts.azkarra.http.security.handler.SecurityHandlerFactory: Creates a new SecurityHandler for the specified configuration.
make(Class<? extends TopologyProvider>, String) - Method in class io.streamthoughts.azkarra.runtime.components.TopologyDescriptorFactory: Makes a new ComponentDescriptor instance.
make(Class<? extends T>, String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorFactory: Makes a new ComponentDescriptor instance.
map(Function<? super B, ? extends BB>) - Method in class io.streamthoughts.azkarra.api.monad.Reader
map(Function<? super L, ? extends LL>) - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
map(Function<? super R, ? extends RR>) - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
map(Function<? super V, ? extends B>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
map(Function<? super V, ? extends B>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
map(Function<? super V, ? extends B>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
map(Function<? super V, ? extends B>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
MapConf - Class in io.streamthoughts.azkarra.api.config: A simple Conf implementation which is backed by a HashMap.
mapKey(Function<L, LL>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
mapValue(Function<R, RR>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
mayConfigure(Object, Conf) - Static method in interface io.streamthoughts.azkarra.api.config.Configurable
MD5 - io.streamthoughts.azkarra.http.security.auth.PasswordCredentials.Type
message() - Method in class io.streamthoughts.azkarra.api.errors.Error
message() - Method in class io.streamthoughts.azkarra.api.query.result.QueryError
MESSAGE - Static variable in class io.streamsthoughts.azkarra.commons.error.ExceptionHeader
Metric - Class in io.streamthoughts.azkarra.api.model
Metric(String, String, Map<String, String>, Object) - Constructor for class io.streamthoughts.azkarra.api.model.Metric
MetricGroup - Class in io.streamthoughts.azkarra.api.model
MetricGroup(String, Set<Metric>) - Constructor for class io.streamthoughts.azkarra.api.model.MetricGroup: Creates a new MetricGroup instance.
MetricNotFoundException - Exception in io.streamthoughts.azkarra.http.error
MetricNotFoundException(String) - Constructor for exception io.streamthoughts.azkarra.http.error.MetricNotFoundException: Creates a new MetricNotFoundException instance.
metrics() - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
metrics() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets all the current Metrics for this KafkaStreams instance.
milliseconds() - Method in class io.streamthoughts.azkarra.api.time.SystemTime: Returns the current time in milliseconds.
milliseconds() - Method in interface io.streamthoughts.azkarra.api.time.Time: Returns the current time in milliseconds.
minorVersion() - Method in class io.streamthoughts.azkarra.api.util.Version
MissingConfException - Exception in io.streamthoughts.azkarra.api.errors
MissingConfException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.MissingConfException: Creates a new MissingConfException instance.
MyCustomerHealthCheck() - Constructor for class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample.MyCustomerHealthCheck

N

name - Variable in class io.streamthoughts.azkarra.api.Executed
name - Variable in class io.streamthoughts.azkarra.http.handler.EnvironmentPostHandler.EnvironmentPayload
name() - Method in annotation type io.streamthoughts.azkarra.api.annotations.DefaultStreamsConfig
name() - Method in class io.streamthoughts.azkarra.api.model.Environment
name() - Method in class io.streamthoughts.azkarra.api.model.Metric
name() - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
name() - Method in class io.streamthoughts.azkarra.api.providers.TopologyDescriptor
name() - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
name() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
name() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets the name of this StreamsExecutionEnvironment.
name() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
name() - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Gets the name of this StreamsExecutionEnvironment.
name() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
name() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.EnableAutoConfig
name() - Method in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig: Gets the environment name.
name() - Method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig: Gets the user-defined topology name.
NameMetricFilter - Class in io.streamthoughts.azkarra.api.model.predicate
NameMetricFilter(String) - Constructor for class io.streamthoughts.azkarra.api.model.predicate.NameMetricFilter: Creates a new NameMetricFilter instance.
nameOrElseGet(String) - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
nanoseconds() - Method in class io.streamthoughts.azkarra.api.time.SystemTime: Returns the current value of the running JVM's high-resolution time source, in nanoseconds.
nanoseconds() - Method in interface io.streamthoughts.azkarra.api.time.Time: Returns the current value of the running JVM's high-resolution time source, in nanoseconds.
Network - Class in io.streamthoughts.azkarra.api.util
Network() - Constructor for class io.streamthoughts.azkarra.api.util.Network
newAdminClient(Conf) - Static method in class io.streamthoughts.azkarra.api.streams.admin.AdminClientUtils: Creates a new AdminClient instance.
newBuilder() - Static method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder: Creates a new builder instance.
newBuilder() - Static method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder: Creates a new KafkaStreamContainerBuilder instance.
newBuilder() - Static method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer
newBuilder() - Static method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
newBuilder() - Static method in class io.streamthoughts.azkarra.http.ServerConfBuilder
newBuilder() - Static method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
newConf() - Static method in class io.streamthoughts.azkarra.api.config.ConfBuilder
newConf(Conf) - Static method in class io.streamthoughts.azkarra.api.config.ConfBuilder
newInstance(Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
next - Variable in class io.streamthoughts.azkarra.http.security.handler.SecurityHandler
NO_OP - Static variable in interface io.streamthoughts.azkarra.api.banner.BannerPrinter
NO_RESULT - io.streamthoughts.azkarra.api.query.result.QueryStatus: The query is executed successfully but no result found.
NonNullMetricFilter - Class in io.streamthoughts.azkarra.api.model.predicate
NonNullMetricFilter() - Constructor for class io.streamthoughts.azkarra.api.model.predicate.NonNullMetricFilter
NoSuchComponentException - Exception in io.streamthoughts.azkarra.api.components
NoSuchComponentException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.NoSuchComponentException: Creates a new NoSuchComponentException instance.
NOT_CREATED - io.streamthoughts.azkarra.api.streams.State
NOT_RUNNING - io.streamthoughts.azkarra.api.streams.State
NotFoundException - Exception in io.streamthoughts.azkarra.api.errors
NotFoundException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.NotFoundException: Creates a new NotFoundException instance.
NoUniqueComponentException - Exception in io.streamthoughts.azkarra.api.components
NoUniqueComponentException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.NoUniqueComponentException: Creates a new NoUniqueComponentException instance.
nullableKey() - Method in class io.streamthoughts.azkarra.api.model.KV
nullableValue() - Method in class io.streamthoughts.azkarra.api.model.KV

O

of(String) - Static method in class io.streamthoughts.azkarra.api.query.internal.LocalStoreQueryBuilder.MissingRequiredKeyError
of(Throwable) - Static method in class io.streamthoughts.azkarra.api.query.result.QueryError: Creates a new error instance from the specified Throwable.
of(Function<S, A>) - Static method in class io.streamthoughts.azkarra.api.monad.Reader
of(Map.Entry<L, R>) - Static method in class io.streamthoughts.azkarra.api.monad.Tuple
of(K, V) - Static method in class io.streamthoughts.azkarra.api.model.KV
of(L, R) - Static method in class io.streamthoughts.azkarra.api.monad.Tuple
of(KeyValue<K, V>) - Static method in class io.streamthoughts.azkarra.api.model.KV
of(T) - Static method in class io.streamthoughts.azkarra.api.monad.Validator
OFF - io.streamthoughts.azkarra.api.banner.Banner.Mode
onBatchRestored(TopicPartition, String, long, long) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
onChange(KafkaStreams.State, KafkaStreams.State) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener
onContextStart(AzkarraContext) - Method in interface io.streamthoughts.azkarra.api.AzkarraContextListener
onContextStop(AzkarraContext) - Method in interface io.streamthoughts.azkarra.api.AzkarraContextListener
onRestoreEnd(TopicPartition, String, long) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
onRestoreStart(TopicPartition, String, long, long) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
operation() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
operation(StoreOperation) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
operation(StoreOperation) - Method in interface io.streamthoughts.azkarra.api.query.internal.QueryOperationBuilder
operation(StoreOperation) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
operation(StoreOperation) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueCountQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetAllQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchKeyRangeQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchAllQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchKeyRangeQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchTimeRangeQuery: The operation type supported by this query.
operationType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowGetAllQuery: The operation type supported by this query.
operationType() - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreQuery: The operation type supported by this query.
OptimizedTopologyProvider - Class in io.streamthoughts.azkarra.api.streams: A TopologyProvider that can be used to build an optimized Topology instance.
OptimizedTopologyProvider() - Constructor for class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider
originals - Variable in class io.streamthoughts.azkarra.streams.config.HttpServerConf
originals() - Method in class io.streamthoughts.azkarra.api.query.QueryParams
outputTopic() - Method in class io.streamsthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
overrides - Variable in class io.streamthoughts.azkarra.streams.config.HttpServerConf

P

parameters() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
parse(String) - Static method in enum io.streamthoughts.azkarra.api.query.StoreOperation
parse(String) - Static method in enum io.streamthoughts.azkarra.api.query.StoreType
parse(String) - Static method in class io.streamthoughts.azkarra.api.util.Version: Static helper for creating a new version based on the specified string.
ParsingConfException - Exception in io.streamthoughts.azkarra.api.errors
ParsingConfException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.ParsingConfException: Creates a new ParsingConfException instance.
ParsingConfException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ParsingConfException: Creates a new ParsingConfException instance.
PARTIAL - io.streamthoughts.azkarra.api.query.result.QueryStatus: The query is executed successfully partially (some instances failed to respond).
partitions() - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
password - Variable in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
password() - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
PasswordCredentials - Class in io.streamthoughts.azkarra.http.security.auth
PasswordCredentials(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials: Creates a new PasswordCredentials instance.
PasswordCredentials.Type - Enum in io.streamthoughts.azkarra.http.security.auth
path() - Method in class io.streamthoughts.azkarra.http.security.authorizer.HttpResource
PATH - Static variable in class io.streamthoughts.azkarra.http.routes.ApiContextRoutes
PATH - Static variable in class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
PATH_V1 - Static variable in class io.streamthoughts.azkarra.http.APIVersions
PENDING_SHUTDOWN - io.streamthoughts.azkarra.api.streams.State
PENDING_SHUTDOWN - io.streamthoughts.azkarra.api.streams.StreamsState
PlainPasswordCredentials - Class in io.streamthoughts.azkarra.http.security.auth: Representation of a plain text user password.
PlainPasswordCredentials(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.PlainPasswordCredentials: Creates a new PlainPasswordCredentials instance.
port - Variable in class io.streamthoughts.azkarra.streams.config.HttpServerConf
port() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Gets the stream application port.
prefix() - Method in enum io.streamthoughts.azkarra.http.security.auth.PasswordCredentials.Type
prepare() - Method in class io.streamthoughts.azkarra.api.query.internal.Query
prepare(QueryParams) - Method in class io.streamthoughts.azkarra.api.query.internal.Query
PreparedQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
prettyName() - Method in enum io.streamthoughts.azkarra.api.query.StoreOperation
prettyName() - Method in enum io.streamthoughts.azkarra.api.query.StoreType
principal() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext: Gets the current authenticated principal.
print(Banner) - Method in interface io.streamthoughts.azkarra.api.banner.BannerPrinter: Prints the specified Banner.
print(Banner) - Method in class io.streamthoughts.azkarra.streams.banner.DefaultBannerPrinter: Prints the specified Banner.
print(PrintStream) - Method in interface io.streamthoughts.azkarra.api.banner.Banner
print(PrintStream) - Method in class io.streamthoughts.azkarra.streams.banner.AzkarraBanner
PROCESSOR - io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node.Type
ProcessorNodeBuilder() - Constructor for class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNodeBuilder
PropertiesFileLoginModule - Class in io.streamthoughts.azkarra.http.security.jaas.spi: This LoginModule imports a user's Principal and credentials information (BasicUserPrincipal, BasicRolePrincipal, UserPasswordCredentials) and associates them with the current Subject.
PropertiesFileLoginModule() - Constructor for class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
PropertiesFileUsersIdentityManager - Class in io.streamthoughts.azkarra.http.security.auth
PropertiesFileUsersIdentityManager(String, boolean) - Constructor for class io.streamthoughts.azkarra.http.security.auth.PropertiesFileUsersIdentityManager: Creates a new PropertiesFileUsersIdentityManager instance.
PropertiesFileUsersIdentityManager.PropertiesFileLoaderTask - Class in io.streamthoughts.azkarra.http.security.auth: Default thread scheduling periodic scans of the targeted file-system.
Property - Class in io.streamthoughts.azkarra.api.config: A single key-value with configuration.
prototypeOf(T) - Static method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
Provider<T> - Interface in io.streamthoughts.azkarra.api.providers: Interface to provide versioned components.
pruneSuffix(String, String) - Static method in class io.streamthoughts.azkarra.api.util.Utils

Q

qualifier() - Method in class io.streamthoughts.azkarra.api.util.Version
Queried - Class in io.streamthoughts.azkarra.api.query
Queried(int, Duration, Duration, boolean) - Constructor for class io.streamthoughts.azkarra.api.query.Queried: Creates a new Queried instance.
query(KafkaStreamsContainer, Queried) - Method in class io.streamthoughts.azkarra.api.query.DistributedQuery: Executes a state storeName query for specified arguments.
query(StreamsServerInfo, QueryInfo, Queried) - Method in interface io.streamthoughts.azkarra.api.query.RemoteQueryClient: Executes a query to the specified server.
query(StreamsServerInfo, QueryInfo, Queried) - Method in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryClient: Executes a query to the specified server.
query(String, Query<K, V>, QueryParams, Queried) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Executes an interactive query for the specified streams application.
query(String, Query<K, V>, QueryParams, Queried) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Executes an interactive query for the specified streams application.
Query<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
QUERY_PARAM_ID - Static variable in interface io.streamthoughts.azkarra.http.handler.WithApplication
QUERY_PARAM_KEY - Static variable in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
QUERY_PARAM_KEY - Static variable in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
QUERY_PARAM_KEY - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QUERY_PARAM_KEY_FROM - Static variable in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
QUERY_PARAM_KEY_FROM - Static variable in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
QUERY_PARAM_KEY_FROM - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QUERY_PARAM_KEY_TO - Static variable in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
QUERY_PARAM_KEY_TO - Static variable in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
QUERY_PARAM_KEY_TO - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QUERY_PARAM_TIME - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QUERY_PARAM_TIME_FROM - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QUERY_PARAM_TIME_TO - Static variable in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
QueryBuilder - Class in io.streamthoughts.azkarra.api.query.internal
QueryBuilder(String) - Constructor for class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Creates a new QueryBuilder instance.
QueryError - Class in io.streamthoughts.azkarra.api.query.result: A serializable error.
QueryError(Error) - Constructor for class io.streamthoughts.azkarra.api.query.result.QueryError: Creates a new QueryError instance.
QueryError(String) - Constructor for class io.streamthoughts.azkarra.api.query.result.QueryError: Creates a new QueryError instance.
QueryInfo - Class in io.streamthoughts.azkarra.api.query: Class which is use to wrap information about the store to be query.
QueryInfo(String, StoreType, StoreOperation, QueryParams) - Constructor for class io.streamthoughts.azkarra.api.query.QueryInfo: Creates a new QueryInfo instance.
QueryOperationBuilder - Interface in io.streamthoughts.azkarra.api.query.internal
QueryOptionsRequest - Class in io.streamthoughts.azkarra.http.data: Class which is used for serializing and de-serializing state store query options.
QueryOptionsRequest(Integer, Long, Long, Boolean) - Constructor for class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
QueryParams - Class in io.streamthoughts.azkarra.api.query
QueryParams(Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.api.query.QueryParams: Creates a new QueryParams instance.
QueryResult<K,V> - Class in io.streamthoughts.azkarra.api.query.result
QueryResultBuilder<K,V> - Class in io.streamthoughts.azkarra.api.query.result
QueryResultBuilder() - Constructor for class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
QueryStatus - Enum in io.streamthoughts.azkarra.api.query.result
queryTimeout() - Method in class io.streamthoughts.azkarra.api.query.Queried: Gets the maximum duration for executing the execute.
QueryURLBuilder - Interface in io.streamthoughts.azkarra.http.query

R

range() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
RANGE - io.streamthoughts.azkarra.api.query.StoreOperation
read(Conf) - Static method in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig: Static helper that can be used to creates a new ApplicationConfig instance from the provided Conf.
read(Conf) - Method in class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig.Reader
read(Conf) - Static method in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig: Static helper that can be used to creates a new EnvironmentConfig instance from the provided Conf.
read(Conf) - Static method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig: Static helper that can be used to creates a new TopologyConfig instance from the provided Conf.
read(Conf) - Method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig.Reader
Reader<A,B> - Class in io.streamthoughts.azkarra.api.monad
Reader() - Constructor for class io.streamthoughts.azkarra.streams.context.internal.ApplicationConfig.Reader
Reader() - Constructor for class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig.Reader
Reader() - Constructor for class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig.Reader
readJsonRequest(HttpServerExchange) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to read JSON object from HTTP-request payload.
readJsonRequest(HttpServerExchange, Class<T>) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to read JSON object from HTTP-request payload.
REBALANCING - io.streamthoughts.azkarra.api.streams.State
REBALANCING - io.streamthoughts.azkarra.api.streams.StreamsState
recover(Function<? super Throwable, Try<V>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
recover(Function<? super Throwable, Try<V>>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
recover(Function<? super Throwable, Try<V>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
recover(Function<? super Throwable, Try<V>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
RECOVERING - io.streamthoughts.azkarra.api.streams.StreamsState
register(ShutdownHook.Hook) - Static method in class io.streamthoughts.azkarra.runtime.util.ShutdownHook
registerComponent(ComponentDescriptor<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Registers the specified ComponentDescriptor to this ComponentRegistry.
registerComponent(ComponentDescriptor<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Registers the specified ComponentDescriptor to this ComponentRegistry.
registerComponent(ComponentDescriptor<T>, ComponentFactory<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Registers the specified ComponentDescriptor to this ComponentRegistry.
registerComponent(ComponentDescriptor<T>, ComponentFactory<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Registers the specified ComponentDescriptor to this ComponentRegistry.
registerComponent(ComponentFactory<T>, ComponentRegistry) - Method in interface io.streamthoughts.azkarra.api.components.ComponentClassReader: Registers the Provider class using the specified ComponentRegistry.
registerComponent(ComponentFactory<T>, ComponentRegistry) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultProviderClassReader: Registers the Provider class using the specified ComponentRegistry.
registerComponent(Class<T>, ComponentRegistry) - Method in interface io.streamthoughts.azkarra.api.components.ComponentClassReader: Registers the Provider class using the specified ComponentRegistry.
registerComponent(Class<T>, ComponentRegistry) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultProviderClassReader: Registers the Provider class using the specified ComponentRegistry.
registerComponent(String, ComponentRegistry) - Method in interface io.streamthoughts.azkarra.api.components.ComponentClassReader: Registers the Provider class using the specified ComponentRegistry.
registerComponent(String, ComponentRegistry) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultProviderClassReader: Registers the Provider class using the specified ComponentRegistry.
remoteAccessAllowed() - Method in class io.streamthoughts.azkarra.api.query.Queried: Gets whether remote access is allowed.
RemoteQueryClient - Interface in io.streamthoughts.azkarra.api.query: Default interface to query a remote streams state store.
remove(ApplicationId) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Stops the streams instance for the specified application id and remove the associated topology from this environment.
remove(ApplicationId) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Stops the streams instance for the specified application id and remove the associated topology from this environment.
resource() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext: Gets the requested resource.
REST_AUTHENTICATION_BASIC_SILENT_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
REST_AUTHENTICATION_MECHANISM_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
REST_AUTHENTICATION_REALM_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
REST_AUTHENTICATION_ROLES_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
REST_AUTHENTICATION_USERS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
restart() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
restartStreams(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Restarts the streams instance for the specified streams application.
restartStreams(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Restarts the streams instance for the specified streams application.
retriable(CheckedSupplier<V, E>, Retry) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
retries() - Method in class io.streamthoughts.azkarra.api.query.Queried: Gets the maximum number of attempts.
Retry - Class in io.streamthoughts.azkarra.api.monad
retryBackoff() - Method in class io.streamthoughts.azkarra.api.query.Queried: Gets the time interval before attempting a new operation.
right() - Method in class io.streamthoughts.azkarra.api.monad.Either
right() - Method in class io.streamthoughts.azkarra.api.monad.Tuple
right(R) - Static method in class io.streamthoughts.azkarra.api.monad.Either
ROCKS_DB_LOG_DIR_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_LOG_LEVEL_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_LOG_MAX_FILE_SIZE_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_MAX_WRITE_BUFFER_NUMBER_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_STATS_DUMP_PERIOD_SEC_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_STATS_ENABLE_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
ROCKS_DB_WRITE_BUFFER_SIZE_CONFIG - Static variable in class io.streamthoughts.azkarra.api.config.RocksDBConfig
RocksDBConfig - Class in io.streamthoughts.azkarra.api.config: Configuration class for setting internal RocksDB options.
RoleGrantedAuthority - Class in io.streamthoughts.azkarra.http.security.auth
RoleGrantedAuthority(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority: Creates a new RoleGrantedAuthority instance.
RoutingHandlerProvider - Interface in io.streamthoughts.azkarra.http.spi
run() - Method in class io.streamthoughts.azkarra.http.security.auth.PropertiesFileUsersIdentityManager.PropertiesFileLoaderTask
run() - Static method in class io.streamthoughts.azkarra.streams.AzkarraApplication
run(Class<?>[], String[]) - Static method in class io.streamthoughts.azkarra.streams.AzkarraApplication
run(Class<?>, String[]) - Static method in class io.streamthoughts.azkarra.streams.AzkarraApplication
run(String[]) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Runs this AzkarraApplication.
RUNNING - io.streamthoughts.azkarra.api.streams.State
RUNNING - io.streamthoughts.azkarra.api.streams.StreamsState

S

scan() - Method in class io.streamthoughts.azkarra.streams.components.ClasspathComponentScanner
scan(Package) - Method in class io.streamthoughts.azkarra.streams.components.ClasspathComponentScanner
SecurityConfException - Exception in io.streamthoughts.azkarra.http.security
SecurityConfException(String) - Constructor for exception io.streamthoughts.azkarra.http.security.SecurityConfException: Creates a new SecurityConfException instance.
SecurityConfException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.http.security.SecurityConfException: Creates a new SecurityConfException instance.
SecurityConfException(Throwable) - Constructor for exception io.streamthoughts.azkarra.http.security.SecurityConfException: Creates a new SecurityConfException instance.
SecurityConfig - Class in io.streamthoughts.azkarra.http.security
SecurityConfig(Conf) - Constructor for class io.streamthoughts.azkarra.http.security.SecurityConfig: Creates a new SecurityConfig instance.
SecurityHandler - Class in io.streamthoughts.azkarra.http.security.handler: AbstractAuthenticationHandler.
SecurityHandlerFactory - Class in io.streamthoughts.azkarra.http.security.handler: Default factory class for building a new SecurityHandler object.
SecurityHandlerFactory(AzkarraContext) - Constructor for class io.streamthoughts.azkarra.http.security.handler.SecurityHandlerFactory: Creates a new AzkarraContext instance.
securityMechanism() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext: Gets the security mechanism used by the client to authenticate.
SecurityMechanism - Enum in io.streamthoughts.azkarra.http.security: List of security mechanism currently supported for authenticating users.
sendErrorMessage(HttpServerExchange, Throwable) - Static method in class io.streamthoughts.azkarra.http.error.ExceptionDefaultHandler
sendJsonResponse(HttpServerExchange, Object) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to write a JSON object to HTTP-response with StatusCodes.OK.
sendJsonResponseWithCode(HttpServerExchange, Object, int) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper: Static helper that can be used to write a JSON object to HTTP-response with the specified status code.
SerializationException - Exception in io.streamthoughts.azkarra.http.error
SerializationException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.http.error.SerializationException: Creates a new SerializationException instance.
serialize(Conf, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.ConfSerializer
serialize(TopologyDescriptor, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.TopologyDescriptorSerializer
serialize(QueryInfo, Queried) - Static method in class io.streamthoughts.azkarra.http.query.JsonQuerySerde
serialize(Long, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.TimestampSerializer
serialize(Object) - Static method in class io.streamthoughts.azkarra.http.json.JsonSerdes: Static helper that can be used to serialize a given object.
serialize(GenericRecord, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.GenericRecordSerializer
serialize(TopicPartition, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.TopicPartitionSerializer
serialize(Windowed, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.WindowedSerializer
serialize(TaskMetadata, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.TaskMetadataSerializer
serialize(ThreadMetadata, JsonGenerator, SerializerProvider) - Method in class io.streamthoughts.azkarra.http.json.serializers.ThreadMetadataSerializer
server - Variable in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet: The server returning the records.
ServerConfBuilder - Class in io.streamthoughts.azkarra.http: An helper class for build a Conf used for configuring embedded http-server.
ServerInfo - Class in io.streamthoughts.azkarra.api.server
ServerInfo(String, int) - Constructor for class io.streamthoughts.azkarra.api.server.ServerInfo: Creates a new ServerInfo instance.
session() - Method in class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Session storeName.
SESSION - io.streamthoughts.azkarra.api.query.StoreType: Session storeName.
SessionFetchKeyRangeQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
SessionFetchQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
SessionQueryBuilder - Class in io.streamthoughts.azkarra.api.query.internal
setApplicationIdBuilder(Supplier<ApplicationIdBuilder>) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Sets the ApplicationIdBuilder that should be used for building streams application.id.
setApplicationIdBuilder(Supplier<ApplicationIdBuilder>) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Sets the ApplicationIdBuilder that should be used for building streams application.id.
setAuthenticated(boolean) - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication
setAuthenticated(boolean) - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication
setAuthentication(Authentication) - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext: Sets the currently authenticated principal.
setAuthentication(Authentication) - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext: Sets the currently authenticated principal.
setAuthentication(Authentication) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler
setAuthentication(T) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.AuthenticationCallback
setAuthenticationContext(AuthenticationContext) - Static method in class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder: Sets a new AuthenticationContext with the current thread of execution.
setAuthenticationMethod(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the authentication mode.
setAuthenticationRealm(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the authentication realm.
setAuthenticationRestricted(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the authentication roles.
setAuthenticationRoles(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the authentication roles.
setAuthenticationUsers(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the authentication users.
setAutoStart(boolean) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets if all registered topologies must be automatically added to the default environment and started when this AzkarraApplication is started.
setAutoStart(boolean, String) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets if all registered topologies must be automatically added to the specified environment and started when this AzkarraApplication is started.
setAzkarraContext(AzkarraContext) - Method in interface io.streamthoughts.azkarra.api.AzkarraContextAware: Set the AzkarraContext that this object runs in.
setAzkarraContext(AzkarraContext) - Method in class io.streamthoughts.azkarra.http.health.internal.StreamsHealthIndicator: Set the AzkarraContext that this object runs in.
setAzkarraContext(AzkarraContext) - Method in class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes: Set the AzkarraContext that this object runs in.
setAzkarraContext(AzkarraContext) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Set the AzkarraContext that this object runs in.
setAzkarraPrincipalBuilder(AzkarraPrincipalBuilder) - Method in class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager
setBanner(Banner) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets the Banner to print when this AzkarraContext is started.
setBannerMode(Banner.Mode) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets the mode used to print the Banner instance when this AzkarraContext is started.
setBasePath(String) - Method in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryBuilder: Sets the relative URL base path.
setBasicSilentAuthentication(boolean) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets if the basic authentication must be silent.
setComponentAliasesGenerator(ComponentAliasesGenerator) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistry: Sets the ComponentAliasesGenerator instance.
setComponentAliasesGenerator(ComponentAliasesGenerator) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentRegistry: Sets the ComponentAliasesGenerator instance.
setComponentClassReader(ComponentClassReader) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Sets the internal the ComponentClassReader which is used for registering components to this context.
setComponentClassReader(ComponentClassReader) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Sets the internal the ComponentClassReader which is used for registering components to this context.
setComponentRegistry(ComponentRegistry) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Sets the internal the ComponentRegistry which is used for registering components to this context.
setComponentRegistry(ComponentRegistry) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Sets the internal the ComponentRegistry which is used for registering components to this context.
setConfig(String, Options, Map<String, Object>) - Method in class io.streamthoughts.azkarra.api.streams.rocksdb.DefaultRocksDBConfigSetter
setConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Sets the default configuration to be used for this AzkarraContext.
setConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Sets this environment configuration.
setConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Sets the default configuration to be used for this AzkarraContext.
setConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Sets this environment configuration.
setConfiguration(Conf) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets the AzkarraApplication configuration.
setContext(AzkarraContext) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets the AzkarraContext that must be used for this AzkarraApplication.
setDescription(String) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setEnableComponentScan(boolean) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets if the classpath must be scanned for searching components.
setException(String) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setExecutionEnvironment(StreamsExecutionEnvironment) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentAware: Set the StreamsExecutionEnvironment.
setExecutionEnvironment(StreamsExecutionEnvironment) - Method in class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder: Set the StreamsExecutionEnvironment.
setFailedResultSet(ErrorResultSet) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setFailedResultSet(List<ErrorResultSet>) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setId(String) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setIgnoreHostnameVerification(boolean) - Method in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryBuilder: Sets if hostname verification must be ignore when SSL is enable.
setIgnoreSslHostnameVerification(boolean) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Enables the SSL.
setKeyPassword(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the password of the private key in the key store file.
setKeyStoreLocation(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the location of the key store file.
setKeyStorePassword(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the store password for the key store file.
setKeyStoreType(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the file format of the key store file.
setListener(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the http server listener.
setLogger(Logger) - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
setLoggerLevel(Level) - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
setLoginContext(LoginContext) - Method in class io.streamthoughts.azkarra.http.security.auth.JAASAuthentication
setMode(Banner.Mode) - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
setName(String) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setPort(int) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the http server port.
setRegisterShutdownHook(boolean) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Sets if the created AzkarraContext should have a shutdown hook registered.
setRegisterShutdownHook(boolean) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Sets if the created AzkarraContext should have a shutdown hook registered.
setRegisterShutdownHook(boolean) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication: Sets if the created AzkarraContext should have a shutdown hook registered.
setRegistry(ComponentRegistry) - Method in class io.streamthoughts.azkarra.api.components.ComponentModule: Sets the registry.
setRegistry(ComponentRegistry) - Method in interface io.streamthoughts.azkarra.api.components.ComponentRegistryAware: Sets the registry.
setRocksDBConfig(RocksDBConfig) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Sets the RocksDBConfig streamsConfig used by topology persistent stores.
setRocksDBConfig(RocksDBConfig) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Sets the RocksDBConfig streamsConfig used by topology persistent stores.
setServer(String) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setSince(long) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setSSLContextFactory(SSLContextFactory) - Method in class io.streamthoughts.azkarra.http.query.HttpRemoteQueryBuilder: Sets the SSLContextFactory which is used for initializing HTTP client with SSL.
setState(State) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
setState(State) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment
setState(String, long) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setStatus(QueryStatus) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setStopWordsService(StopWordsService) - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
setStoreName(String) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setStoreType(String) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setSuccessResultSet(List<SuccessResultSet<K, V>>) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setTimeout(boolean) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setTook(long) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
setTrustStoreLocation(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the location of the trust store file.
setTrustStorePassword(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the store password for the trust store file.
setTrustStoreType(String) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder: Sets the file format of the key trust file.
setUserDetails(UserDetails) - Method in class io.streamthoughts.azkarra.http.security.auth.UsernamePasswordAuthentication
setUserIdentityManager(UsersIdentityManager) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicAuthenticator
setUserIdentityManager(Class<? extends UsersIdentityManager>) - Method in class io.streamthoughts.azkarra.http.ServerConfBuilder
setVersion(String) - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.Builder
setWaitForTopicsToBeCreated(boolean) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Sets if the streams instances should wait for topics source to be created before starting.
setWaitForTopicsToBeCreated(boolean) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Sets if the streams instances should wait for topics source to be created before starting.
SHUTDOWN - io.streamthoughts.azkarra.api.streams.StreamsState
ShutdownHook - Class in io.streamthoughts.azkarra.runtime.util: Utility class for registering shutdown hooks.
ShutdownHook.Hook - Interface in io.streamthoughts.azkarra.runtime.util
SimpleAuthorizationManager - Class in io.streamthoughts.azkarra.http.security.authorizer: SimpleAuthorizationManager.
SimpleAuthorizationManager() - Constructor for class io.streamthoughts.azkarra.http.security.authorizer.SimpleAuthorizationManager: Creates a new SimpleAuthorizationManager instance.
Singleton - Annotation Type in io.streamthoughts.azkarra.api.annotations: Marker interface that any Component can used to indicate it can be registered as a shared instance across the application.
singletonOf(T) - Static method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
SINK - io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node.Type
SinkNodeBuilder() - Constructor for class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNodeBuilder
SL4JLoggerPrintStream - Class in io.streamthoughts.azkarra.streams.banner.internal
SL4JLoggerPrintStream(Logger, Level) - Constructor for class io.streamthoughts.azkarra.streams.banner.internal.SL4JLoggerPrintStream
sleep(Duration) - Method in class io.streamthoughts.azkarra.api.time.SystemTime
sleep(Duration) - Method in interface io.streamthoughts.azkarra.api.time.Time
SOURCE - io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node.Type
SourceNodeBuilder() - Constructor for class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNodeBuilder
SSL_ENABLE - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_IGNORE_HOSTNAME_VERIFICATION - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_KEY_PASSWORD_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_KEYSTORE_LOCATION - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_KEYSTORE_PASSWORD - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_KEYSTORE_TYPE - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_TRUSTSTORE_LOCATION - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_TRUSTSTORE_PASSWORD - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSL_TRUSTSTORE_TYPE - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
SSLAuthenticationContext - Class in io.streamthoughts.azkarra.http.security.auth: SSLSecurityContext.
SSLAuthenticationContext(SecurityMechanism, InetAddress, SecurityContext, SSLSession) - Constructor for class io.streamthoughts.azkarra.http.security.auth.SSLAuthenticationContext: Creates a new SSLAuthenticationContext instance.
SSLAuthenticationExample - Class in io.streamthoughts.examples.azkarra.security: Example to configure an azkarra application with SSL-Two-Way authentication.
SSLAuthenticationExample() - Constructor for class io.streamthoughts.examples.azkarra.security.SSLAuthenticationExample
SSLClientAuthentication - Class in io.streamthoughts.azkarra.http.security.auth
SSLClientAuthentication(Principal, X509CertificateCredentials) - Constructor for class io.streamthoughts.azkarra.http.security.auth.SSLClientAuthentication: Creates a new AbstractAuthentication instance.
SSLContextFactory - Class in io.streamthoughts.azkarra.http.security: Default class for retrieving a new SSLContext instance.
SSLContextFactory(SecurityConfig) - Constructor for class io.streamthoughts.azkarra.http.security.SSLContextFactory: Creates a new SSLContextFactory instance.
STACKTRACE - Static variable in class io.streamsthoughts.azkarra.commons.error.ExceptionHeader
start() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Starts this AzkarraContext instance.
start() - Method in interface io.streamthoughts.azkarra.api.server.EmbeddedHttpServer: Starts this server.
start() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Starts this StreamsExecutionEnvironment instance.
start() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer: Starts this server.
start() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Starts this AzkarraContext instance.
start() - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Starts this StreamsExecutionEnvironment instance.
start(Executor, boolean) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Asynchronously start the underlying KafkaStreams instance.
startAutoReload(Duration) - Method in class io.streamthoughts.azkarra.http.security.auth.PropertiesFileUsersIdentityManager
STARTED - io.streamthoughts.azkarra.api.State
startedSince() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the started epoch-time in milliseconds.
startStreamsTopology(String, String, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Creates and starts a new streams job for the specified topology into the specified environment.
startStreamsTopology(String, String, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Creates and starts a new streams job for the specified topology into the specified environment.
state() - Method in class io.streamthoughts.azkarra.api.model.Environment
state() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the current state of the streams.
state() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Gets the state f this StreamsExecutionEnvironment.
state() - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Gets the state f this StreamsExecutionEnvironment.
State - Enum in io.streamthoughts.azkarra.api: The states.
State - Enum in io.streamthoughts.azkarra.api.streams: The status for a KafkaStreams instance.
State(String, long) - Constructor for class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse.State
Status - Class in io.streamthoughts.azkarra.http.health
Status(String) - Constructor for class io.streamthoughts.azkarra.http.health.Status: Creates a new Status instance.
StatusAggregator - Interface in io.streamthoughts.azkarra.http.health: The StatusAggregator is used to aggregate multiple Status instance.
stop() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Stops this AzkarraContext instance.
stop() - Method in interface io.streamthoughts.azkarra.api.server.EmbeddedHttpServer: Stops this server and close any open resources.
stop() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.
stop() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer: Stops this server and close any open resources.
stop() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Stops this AzkarraContext instance.
stop(boolean) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Stops this AzkarraContext instance.
stop(boolean) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.
stop(boolean) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Stops this AzkarraContext instance.
stop(boolean) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Stops this StreamsExecutionEnvironment instance and all running KafkaStreams instance.
stop(ApplicationId, boolean) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment: Stops the streams instance for the specified application id.
stop(ApplicationId, boolean) - Method in class io.streamthoughts.azkarra.runtime.env.DefaultStreamsExecutionEnvironment: Stops the streams instance for the specified application id.
stopAfterDuration(Duration) - Method in class io.streamthoughts.azkarra.api.monad.Retry
stopAfterMaxAttempts(int) - Method in class io.streamthoughts.azkarra.api.monad.Retry
stopAutoReload() - Method in class io.streamthoughts.azkarra.http.security.auth.PropertiesFileUsersIdentityManager
STOPPED - io.streamthoughts.azkarra.api.State
stopStreams(String, boolean) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService: Stops the streams instance for the specified streams application.
stopStreams(String, boolean) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService: Stops the streams instance for the specified streams application.
StopWordsService - Interface in io.streamthoughts.examples.azkarra.dependency
storeName() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyedLocalStoreQuery
storeName() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
StoreOperation - Enum in io.streamthoughts.azkarra.api.query
stores() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Gets the set of store names hosted by this instance.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueCountQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetAllQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchKeyRangeQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchAllQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchKeyRangeQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchTimeRangeQuery: The storeName type on which this query can be executed.
storeType() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowGetAllQuery: The storeName type on which this query can be executed.
storeType() - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreQuery: The storeName type on which this query can be executed.
StoreType - Enum in io.streamthoughts.azkarra.api.query: The storeName types supported by KafkaStreams.
StreamsApplication - Class in io.streamthoughts.examples.azkarra.dependency
StreamsApplication - Class in io.streamthoughts.examples.azkarra.noannotation: Example to manually register a topology.
StreamsApplication() - Constructor for class io.streamthoughts.examples.azkarra.dependency.StreamsApplication
StreamsApplication() - Constructor for class io.streamthoughts.examples.azkarra.noannotation.StreamsApplication
streamsConfig() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the configuration for this KafkaStreams instance.
streamsConfig() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
streamsConfigs() - Method in class io.streamthoughts.azkarra.api.providers.TopologyDescriptor
StreamsDeleteHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsDeleteHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsDeleteHandler: Creates a new StreamsDeleteHandler instance.
StreamsExecutionEnvironment - Interface in io.streamthoughts.azkarra.api: A StreamsExecutionEnvironment manages the lifecycle of Topology instances.
StreamsExecutionEnvironmentAware - Interface in io.streamthoughts.azkarra.api
StreamsGetConfigHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsGetConfigHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsGetConfigHandler: Creates a new StreamsGetConfigHandler instance.
StreamsGetDetailsHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsGetDetailsHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsGetDetailsHandler: Creates a new StreamsGetDetailsHandler instance.
StreamsGetListHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsGetListHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsGetListHandler: Creates a new StreamsGetListHandler instance.
StreamsGetMetricsHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsGetMetricsHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsGetMetricsHandler: Creates a new StreamsGetMetricsHandler instance.
StreamsGetStatusHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsGetStatusHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsGetStatusHandler: Creates a new StreamsGetStatusHandler instance.
StreamsHealthIndicator - Class in io.streamthoughts.azkarra.http.health.internal
StreamsHealthIndicator() - Constructor for class io.streamthoughts.azkarra.http.health.internal.StreamsHealthIndicator: Creates a new StreamsHealthIndicator instance.
StreamsInstanceResponse - Class in io.streamthoughts.azkarra.http.data
StreamsInstanceResponse(String, long, String, String, String, StreamsInstanceResponse.State, String) - Constructor for class io.streamthoughts.azkarra.http.data.StreamsInstanceResponse
StreamsInstanceResponse.Builder - Class in io.streamthoughts.azkarra.http.data
StreamsInstanceResponse.State - Class in io.streamthoughts.azkarra.http.data
StreamsName - Annotation Type in io.streamthoughts.azkarra.api.annotations: Marker interface that a TopologyProvider can used to set the default name attached to the streams instance.
StreamsPostHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsPostHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsPostHandler: Creates a new StreamsPostHandler instance.
StreamsRestartHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsRestartHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsRestartHandler: Creates a new StreamsRestartHandler instance.
StreamsServerInfo - Class in io.streamthoughts.azkarra.api.streams: Class which is used to describe a stream application instance.
StreamsServerInfo(String, String, int, Set<String>, Set<TopicPartitions>) - Constructor for class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Creates a new StreamsServerInfo instance.
StreamsServerInfo(String, String, int, Set<String>, Set<TopicPartitions>, boolean) - Constructor for class io.streamthoughts.azkarra.api.streams.StreamsServerInfo: Creates a new StreamsServerInfo instance.
StreamsState - Enum in io.streamthoughts.azkarra.api.streams
StreamsStatus - Class in io.streamthoughts.azkarra.api.model
StreamsStatus(String, String, Set<ThreadMetadata>) - Constructor for class io.streamthoughts.azkarra.api.model.StreamsStatus: Creates a new StreamsStatus instance.
StreamsStopHandler - Class in io.streamthoughts.azkarra.http.handler
StreamsStopHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.StreamsStopHandler: Creates a new StreamsStopHandler instance.
StreamsTopologyGraph - Class in io.streamthoughts.azkarra.api.model: A Serializable streams topology graph.
StreamsTopologyGraph.AbstractNode - Class in io.streamthoughts.azkarra.api.model: An abstract topology node.
StreamsTopologyGraph.GlobalStore - Class in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.Node - Interface in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.Node.Type - Enum in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.ProcessorNode - Class in io.streamthoughts.azkarra.api.model: A topology processor-node.
StreamsTopologyGraph.ProcessorNodeBuilder - Class in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.SinkNode - Class in io.streamthoughts.azkarra.api.model: A topology sink-node.
StreamsTopologyGraph.SinkNodeBuilder - Class in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.SourceNode - Class in io.streamthoughts.azkarra.api.model: A topology source-node.
StreamsTopologyGraph.SourceNodeBuilder - Class in io.streamthoughts.azkarra.api.model
StreamsTopologyGraph.SubTopologyGraph - Class in io.streamthoughts.azkarra.api.model
StreamsTopologyRequest - Class in io.streamthoughts.azkarra.http.data
StreamsTopologyRequest(String, String, String, String, String, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
success(V) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
SUCCESS - io.streamthoughts.azkarra.api.query.result.QueryStatus: The query is executed successfully.
SuccessResultSet<K,V> - Class in io.streamthoughts.azkarra.api.query.result
SuccessResultSet(String, boolean, List<KV<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
swap() - Method in class io.streamthoughts.azkarra.api.model.KV
SYSTEM - Static variable in interface io.streamthoughts.azkarra.api.time.Time
SystemTime - Class in io.streamthoughts.azkarra.api.time
SystemTime() - Constructor for class io.streamthoughts.azkarra.api.time.SystemTime

T

tags() - Method in class io.streamthoughts.azkarra.api.model.Metric
TaskMetadataSerializer - Class in io.streamthoughts.azkarra.http.json.serializers
TaskMetadataSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.TaskMetadataSerializer
test(Tuple<String, Metric>) - Method in class io.streamthoughts.azkarra.api.model.predicate.GroupMetricFilter
test(Tuple<String, Metric>) - Method in class io.streamthoughts.azkarra.api.model.predicate.NameMetricFilter
test(Tuple<String, Metric>) - Method in class io.streamthoughts.azkarra.api.model.predicate.NonNullMetricFilter
test(String) - Method in class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
test(String) - Method in interface io.streamthoughts.examples.azkarra.dependency.StopWordsService: Checks whether a word is a stop word.
threadMetadata() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the local thread metadata.
ThreadMetadataSerializer - Class in io.streamthoughts.azkarra.http.json.serializers
ThreadMetadataSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.ThreadMetadataSerializer
Time - Interface in io.streamthoughts.azkarra.api.time
timestamp() - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue: Returns the timestamp in milliseconds for this value.
TIMESTAMP - Static variable in class io.streamsthoughts.azkarra.commons.error.ExceptionHeader
TIMESTAMPED_KEY_VALUE - io.streamthoughts.azkarra.api.query.StoreType: Timestamped Key-Value storeName.
TIMESTAMPED_WINDOW - io.streamthoughts.azkarra.api.query.StoreType: Timestamped Window storeName
timestampedKeyValue() - Method in class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Timestamped Key-Value storeName.
TimestampedValue<V> - Class in io.streamthoughts.azkarra.api.model
TimestampedValue(long, V) - Constructor for class io.streamthoughts.azkarra.api.model.TimestampedValue: Creates a new TimestampedValue instance.
TimestampedValue(V) - Constructor for class io.streamthoughts.azkarra.api.model.TimestampedValue: Creates a new TimestampedValue instance.
timestampedWindow() - Method in class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Timestamped Window storeName
TimestampSerializer - Class in io.streamthoughts.azkarra.http.json.serializers
TimestampSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.TimestampSerializer
toEither() - Method in class io.streamthoughts.azkarra.api.monad.Validator
toInvalidQueryException(List<Error>) - Static method in interface io.streamthoughts.azkarra.api.query.internal.LocalStoreQueryBuilder
toISODate() - Static method in interface io.streamthoughts.azkarra.api.time.Time
toISODate(long) - Static method in interface io.streamthoughts.azkarra.api.time.Time
toISODate(long, ZoneId) - Static method in interface io.streamthoughts.azkarra.api.time.Time
toKafkaKeyValue() - Method in class io.streamthoughts.azkarra.api.model.KV
toKeyValueListAndClose(KeyValueIterator<K, V>) - Static method in interface io.streamthoughts.azkarra.api.query.LocalStoreQuery
toOptional() - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
toOptional() - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
toOptional() - Method in interface io.streamthoughts.azkarra.api.monad.Try
toOptional() - Method in class io.streamthoughts.azkarra.api.monad.Validator
TopicPartitions - Class in io.streamthoughts.azkarra.api.streams: This class represents topic-partitions assignment for a streams application.
TopicPartitions(String, Set<Integer>) - Constructor for class io.streamthoughts.azkarra.api.streams.TopicPartitions: Creates a new TopicPartitions instance.
TopicPartitionSerializer - Class in io.streamthoughts.azkarra.http.json.serializers: The JsonSerializer to serialize TopicPartition instance.
TopicPartitionSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.TopicPartitionSerializer
topology() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
TOPOLOGY_DESCRIPTION_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig
TOPOLOGY_NAME_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig
TOPOLOGY_PROVIDER_ALIAS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig
TOPOLOGY_STREAMS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig
TopologyConfig - Class in io.streamthoughts.azkarra.streams.context.internal: Class which is used to configure a TopologyProvider instance.
TopologyConfig.Reader - Class in io.streamthoughts.azkarra.streams.context.internal
TopologyContainer - Class in io.streamthoughts.azkarra.api.streams.topology: Default class to encapsulate a Topology instance.
TopologyContainer.Builder - Class in io.streamthoughts.azkarra.api.streams.topology
TopologyDescriptor<T extends TopologyProvider> - Class in io.streamthoughts.azkarra.api.providers: A ComponentDescriptor for describing a TopologyProvider implementation.
TopologyDescriptor(String, Class<T>, String) - Constructor for class io.streamthoughts.azkarra.api.providers.TopologyDescriptor: Creates a new TopologyDescriptor instance.
TopologyDescriptor(String, Class<T>, String, Conf) - Constructor for class io.streamthoughts.azkarra.api.providers.TopologyDescriptor: Creates a new TopologyDescriptor instance.
TopologyDescriptorFactory - Class in io.streamthoughts.azkarra.runtime.components
TopologyDescriptorFactory() - Constructor for class io.streamthoughts.azkarra.runtime.components.TopologyDescriptorFactory
TopologyDescriptorSerializer - Class in io.streamthoughts.azkarra.http.json.serializers: The JsonSerializer to serialize TopologyDescriptor instance.
TopologyDescriptorSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.TopologyDescriptorSerializer
TopologyFactory - Class in io.streamthoughts.azkarra.runtime.streams.topology: TopologyFactory.
TopologyFactory(StreamsExecutionEnvironment) - Constructor for class io.streamthoughts.azkarra.runtime.streams.topology.TopologyFactory: Creates a new TopologyFactory instance.
TopologyInfo - Annotation Type in io.streamthoughts.azkarra.api.annotations: Marker interface that a TopologyProvider can used to describe the behavior of the provided Topology.
TopologyListHandler - Class in io.streamthoughts.azkarra.http.handler
TopologyListHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.TopologyListHandler: Creates a new TopologyListHandler instance.
topologyMetadata() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer: Gets the TopologyMetadata about the topology runs by this KafkaStreams instance.
TopologyMetadata - Class in io.streamthoughts.azkarra.api.streams.topology
TopologyMetadata(String, String, String, TopologyDescription, Conf) - Constructor for class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata: Creates a new TopologyMetadata instance.
TopologyProvider - Interface in io.streamthoughts.azkarra.api.streams: The default interface to supply a Kafka Streams Topology instance.
topologyProviders() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext: Gets all topologies registered into this AzkarraContext.
topologyProviders() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext: Gets all topologies registered into this AzkarraContext.
topologyStreamConfigs() - Method in class io.streamthoughts.azkarra.streams.context.internal.EnvironmentConfig: Gets all the topology streams configurations for this environment.
toString() - Method in class io.streamthoughts.azkarra.api.config.ConfBuilder
toString() - Method in class io.streamthoughts.azkarra.api.config.MapConf
toString() - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
toString() - Method in class io.streamthoughts.azkarra.api.errors.Error
toString() - Method in class io.streamthoughts.azkarra.api.model.Environment
toString() - Method in class io.streamthoughts.azkarra.api.model.KV
toString() - Method in class io.streamthoughts.azkarra.api.model.Metric
toString() - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
toString() - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
toString() - Method in class io.streamthoughts.azkarra.api.monad.Retry
toString() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
toString() - Method in class io.streamthoughts.azkarra.api.monad.Tuple
toString() - Method in class io.streamthoughts.azkarra.api.providers.TopologyDescriptor
toString() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery
toString() - Method in class io.streamthoughts.azkarra.api.query.Queried
toString() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
toString() - Method in class io.streamthoughts.azkarra.api.query.QueryParams
toString() - Method in class io.streamthoughts.azkarra.api.query.result.QueryError
toString() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
toString() - Method in class io.streamthoughts.azkarra.api.streams.ApplicationId
toString() - Method in class io.streamthoughts.azkarra.api.streams.StreamsServerInfo
toString() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
toString() - Method in class io.streamthoughts.azkarra.api.util.Version
toString() - Method in class io.streamthoughts.azkarra.http.health.Health
toString() - Method in class io.streamthoughts.azkarra.http.health.Status
toString() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
toString() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
toString() - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
transform(Function<V, Try>, Function<Throwable, Try>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
transform(Function<V, Try>, Function<Throwable, Try>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
transform(Function<V, Try>, Function<Throwable, Try>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
transform(Function<V, Try>, Function<Throwable, Try>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
Try<V> - Interface in io.streamthoughts.azkarra.api.monad
Try.Failure<V> - Class in io.streamthoughts.azkarra.api.monad
Try.Retriable<V> - Class in io.streamthoughts.azkarra.api.monad
Try.Success<V> - Class in io.streamthoughts.azkarra.api.monad
Tuple<L,R> - Class in io.streamthoughts.azkarra.api.monad
Tuple(L, R) - Constructor for class io.streamthoughts.azkarra.api.monad.Tuple: Creates a new Tuple instance.
type() - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the type of the described component.
type() - Method in class io.streamthoughts.azkarra.api.query.QueryInfo
type() - Method in class io.streamthoughts.azkarra.streams.context.internal.TopologyConfig: Gets the TopologyProvider class of alias to be used.
TypeConverter - Class in io.streamthoughts.azkarra.api.util: Class which can be used to convert an object to a specific type.
TypeConverter() - Constructor for class io.streamthoughts.azkarra.api.util.TypeConverter

U

UnauthorizedAccessException - Exception in io.streamthoughts.azkarra.http.security
UnauthorizedAccessException(String) - Constructor for exception io.streamthoughts.azkarra.http.security.UnauthorizedAccessException: Creates a new UnauthorizedAccessException instance.
uncaughtException(Thread, Throwable) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler
UndertowAuthenticationContext - Class in io.streamthoughts.azkarra.http.security.auth
UndertowAuthenticationContext(SecurityMechanism, InetAddress, SecurityContext) - Constructor for class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext: Creates a new UndertowAuthenticationContext instance.
UndertowEmbeddedServer - Class in io.streamthoughts.azkarra.http
UndertowEmbeddedServerProvider - Class in io.streamthoughts.azkarra.http: Provides an UndertowEmbeddedServer instance.
UndertowEmbeddedServerProvider() - Constructor for class io.streamthoughts.azkarra.http.UndertowEmbeddedServerProvider
unknown() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the status for the Health indicator to be built Status.UNKNOWN.
UNKNOWN - Static variable in class io.streamthoughts.azkarra.http.health.Status
UnsupportedCredentialException(String) - Constructor for exception io.streamthoughts.azkarra.http.security.auth.Credentials.UnsupportedCredentialException
UnsupportedCredentialException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.http.security.auth.Credentials.UnsupportedCredentialException
UnsupportedCredentialException(Throwable) - Constructor for exception io.streamthoughts.azkarra.http.security.auth.Credentials.UnsupportedCredentialException
UNVAILABLE - io.streamthoughts.azkarra.api.query.result.QueryStatus: The requested storeName is not available for querying.
unwrap() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
unwrap() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext
up() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the status for the Health indicator to be built to Status.UP.
UP - Static variable in class io.streamthoughts.azkarra.http.health.Status
userDetails() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
UserDetails - Class in io.streamthoughts.azkarra.http.security.auth
UserDetails(String, PasswordCredentials, Collection<GrantedAuthority>) - Constructor for class io.streamthoughts.azkarra.http.security.auth.UserDetails: Creates a new UserDetails instance.
UsernamePasswordAuthentication - Class in io.streamthoughts.azkarra.http.security.auth
UsernamePasswordAuthentication(Principal, PasswordCredentials) - Constructor for class io.streamthoughts.azkarra.http.security.auth.UsernamePasswordAuthentication: Creates a new UsernamePasswordAuthentication instance.
UsersIdentityManager - Interface in io.streamthoughts.azkarra.http.security.auth: Default interface to load UserDetails.
Utils - Class in io.streamthoughts.azkarra.api.util
Utils() - Constructor for class io.streamthoughts.azkarra.api.util.Utils

V

validate(QueryParams) - Method in class io.streamthoughts.azkarra.api.query.internal.Query
validates(QueryParams) - Method in interface io.streamthoughts.azkarra.api.query.internal.LocalStoreQueryBuilder
validates(Predicate<? super T>, Error) - Method in class io.streamthoughts.azkarra.api.monad.Validator
validates(Predicate<? super T>, String) - Method in class io.streamthoughts.azkarra.api.monad.Validator
Validator<T> - Class in io.streamthoughts.azkarra.api.monad
value() - Method in annotation type io.streamthoughts.azkarra.api.annotations.DefaultStreamsConfig
value() - Method in annotation type io.streamthoughts.azkarra.api.annotations.DefaultStreamsConfigs
value() - Method in annotation type io.streamthoughts.azkarra.api.annotations.StreamsName
value() - Method in class io.streamthoughts.azkarra.api.model.KV
value() - Method in class io.streamthoughts.azkarra.api.model.Metric
value() - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue: Returns this value TimestampedValue.
value() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.ComponentScan
value() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.EnableEmbeddedHttpServer
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.banner.Banner.Mode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.query.result.QueryStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.query.StoreOperation: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.query.StoreType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.State: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.streams.State: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.api.streams.StreamsState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.http.security.auth.PasswordCredentials.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.streamthoughts.azkarra.http.security.SecurityMechanism: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.streamthoughts.azkarra.api.banner.Banner.Mode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.query.result.QueryStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.query.StoreOperation: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.query.StoreType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.State: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.streams.State: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.api.streams.StreamsState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.http.security.auth.PasswordCredentials.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.streamthoughts.azkarra.http.security.SecurityMechanism: Returns an array containing the constants of this enum type, in the order they are declared.
verify(Account) - Method in class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager
verify(Credential) - Method in class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager
verify(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
verify(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
verify(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.PlainPasswordCredentials
verify(String, Credential) - Method in class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager
verify(String, SSLSession) - Method in class io.streamthoughts.azkarra.http.security.AllowAllHostNameVerifier
version() - Method in class io.streamthoughts.azkarra.api.components.ComponentDescriptor: Gets the version of the described component.
version() - Method in interface io.streamthoughts.azkarra.api.components.Versioned: Returns the version of this component.
version() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
version() - Method in interface io.streamthoughts.azkarra.api.streams.TopologyProvider: Returns the version for this Topology.
version() - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
version() - Method in class io.streamthoughts.examples.azkarra.topology.BasicWordCountTopology
version() - Method in class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
Version - Class in io.streamthoughts.azkarra.api.util: A version class which supports the following pattern : ..- Supported qualifier are : alpha, beta, snapshot, rc, release.
Version - Class in io.streamthoughts.examples.azkarra
Version() - Constructor for class io.streamthoughts.examples.azkarra.Version
Version(int, int, int, String) - Constructor for class io.streamthoughts.azkarra.api.util.Version: Creates a new Version instance.
Versioned - Interface in io.streamthoughts.azkarra.api.components
VisibleForTesting - Annotation Type in io.streamthoughts.azkarra.api.annotations

W

waitForTopicToExist(AdminClient, Set<String>) - Static method in class io.streamthoughts.azkarra.api.streams.admin.AdminClientUtils: Wait indefinitely for the specified topics to be created on the cluster.
WAITING_FOR_TOPICS - io.streamthoughts.azkarra.api.streams.State
WebUIHttpRoutes - Class in io.streamthoughts.azkarra.http.routes
WebUIHttpRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.WebUIHttpRoutes
window() - Method in class io.streamthoughts.azkarra.api.query.internal.QueryBuilder: Window storeName.
WINDOW - io.streamthoughts.azkarra.api.query.StoreType: Window storeName.
WindowedSerializer - Class in io.streamthoughts.azkarra.http.json.serializers: The JsonSerializer to serialize Windowed instance.
WindowedSerializer() - Constructor for class io.streamthoughts.azkarra.http.json.serializers.WindowedSerializer
WindowFetchAllQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
WindowFetchKeyRangeQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
WindowFetchQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
WindowFetchTimeRangeQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
WindowGetAllQuery<K,V> - Class in io.streamthoughts.azkarra.api.query.internal
WindowQueryBuilder - Class in io.streamthoughts.azkarra.api.query.internal
with(Conf) - 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 configuration.
with(Conf) - Static method in class io.streamthoughts.azkarra.streams.config.HttpServerConf
with(String, int) - Static method in class io.streamthoughts.azkarra.streams.config.HttpServerConf
with(String, Object) - Static method in interface io.streamthoughts.azkarra.api.config.Conf: Static helper that can be used to creates a new empty Conf instance using the specified key-value pair.
with(String, Object) - Method in class io.streamthoughts.azkarra.api.config.ConfBuilder
with(Duration) - Static method in class io.streamthoughts.azkarra.api.query.Queried
with(Map<String, ?>) - Static method in interface io.streamthoughts.azkarra.api.config.Conf: Static helper that can be used to creates a new empty Conf instance using the specified Map.
WithApplication - Interface in io.streamthoughts.azkarra.http.handler: An helper HttpHandler which can be used for routes requiring query param 'id'.
withApplicationId(ApplicationId) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
withBufferSize(int) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withConf(Conf) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
withConfig(Conf) - Method in class io.streamthoughts.azkarra.api.Executed
withConfig(String, Object) - Method in class io.streamthoughts.azkarra.streams.config.HttpServerConf
withDescription(String) - Method in class io.streamthoughts.azkarra.api.Executed
withDescription(String) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
withDetails(String, Object) - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Adds a details entry for the Health indicator.
withException(Throwable) - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the exception for the Health indicator.
withFallback(Conf) - Method in interface io.streamthoughts.azkarra.api.config.Conf
withFallback(Conf) - Method in class io.streamthoughts.azkarra.api.config.ConfBuilder
withFallback(Conf) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
withFallback(Conf) - Method in class io.streamthoughts.azkarra.api.config.MapConf
withFallback(Conf) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
withFixedWaitDuration(Duration) - Method in class io.streamthoughts.azkarra.api.monad.Retry
withListener(String) - Method in class io.streamthoughts.azkarra.streams.config.HttpServerConf: Sets the http server listener.
withLogDir(String) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withLogLevel(String) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withLogMaxFileSize(int) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withMaxAttempts(int) - Static method in class io.streamthoughts.azkarra.api.monad.Retry
withMaxWriteBufferNumber(int) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withName(String) - Method in class io.streamthoughts.azkarra.api.Executed
withName(String) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
withName(String) - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the name of service or sub-system.
withPort(int) - Method in class io.streamthoughts.azkarra.streams.config.HttpServerConf: Sets the http server port.
withQueryTimeout(Duration) - Method in class io.streamthoughts.azkarra.api.query.Queried
withRemoteAccessAllowed(boolean) - Method in class io.streamthoughts.azkarra.api.query.Queried
withRestoreListeners(List<StateRestoreListener>) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
withRetries(int) - Method in class io.streamthoughts.azkarra.api.query.Queried
withRetries(int, Duration) - Static method in class io.streamthoughts.azkarra.api.query.Queried
withRetryBackoffMs(Duration) - Method in class io.streamthoughts.azkarra.api.query.Queried
withStateListeners(List<KafkaStreams.StateListener>) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
withStatsDisable() - Static method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withStatsDumpPeriod(Duration) - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withStatsEnable() - Static method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
withStatus(Status) - Method in class io.streamthoughts.azkarra.http.health.Health.Builder: Sets the Status for the Health indicator.
withTopology(Topology) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
withTopologyContainer(TopologyContainer) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
withUncaughtExceptionHandler(List<Thread.UncaughtExceptionHandler>) - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
withVersion(String) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyContainer.Builder
write(byte[], int, int) - Method in class io.streamthoughts.azkarra.streams.banner.internal.SL4JLoggerPrintStream
write(int) - Method in class io.streamthoughts.azkarra.streams.banner.internal.SL4JLoggerPrintStream

X

X509CertificateCredentials - Class in io.streamthoughts.azkarra.http.security.auth: X509CertificateCredentials.
X509CertificateCredentials(X509Certificate) - Constructor for class io.streamthoughts.azkarra.http.security.auth.X509CertificateCredentials: Creates a new X509Certificate instance.
XMLHttpRequestAwareAuthCallHandler - Class in io.streamthoughts.azkarra.http.security.handler: This is the final HttpHandler in the security chain, it's purpose is to act as a barrier at the end of the chain to ensure authenticate is called after the mechanisms have been associated with the context and the constraint checked.
XMLHttpRequestAwareAuthCallHandler(HttpHandler) - Constructor for class io.streamthoughts.azkarra.http.security.handler.XMLHttpRequestAwareAuthCallHandler

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