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
All Classes All Packages
A
- abort() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
- AbstractAuthentication<T extends Credentials> - Class in io.streamthoughts.azkarra.http.security.auth
- AbstractAuthentication(Principal, T) - Constructor for class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication
-
Creates a new
AbstractAuthentication
instance. - AbstractAzkarraStreamsService - Class in io.streamthoughts.azkarra.runtime.service
- AbstractAzkarraStreamsService() - Constructor for class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Creates a new
AbstractAzkarraStreamsService
instance. - AbstractConf - Class in io.streamthoughts.azkarra.api.config
- AbstractConf() - Constructor for class io.streamthoughts.azkarra.api.config.AbstractConf
- AbstractConfigEntryLoader - Class in io.streamthoughts.azkarra.streams
- AbstractConfigEntryLoader(String) - Constructor for class io.streamthoughts.azkarra.streams.AbstractConfigEntryLoader
-
Creates a new
AbstractConfigEntryLoader
instance. - AbstractResultSet - Class in io.streamthoughts.azkarra.api.query.result
- AbstractStreamHttpHandler - Class in io.streamthoughts.azkarra.http.handler
- AbstractStreamHttpHandler(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.http.handler.AbstractStreamHttpHandler
-
Creates a new
AbstractStreamHttpHandler
instance. - AbstractTopologyStreamsExecution<E extends StreamsExecutionEnvironment<E>> - Class in io.streamthoughts.azkarra.runtime
- AbstractTopologyStreamsExecution(E, StreamsTopologyMeta, Executed) - Constructor for class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
-
Creates a new
AbstractTopologyStreamsExecution
instance. - accept(State) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.StateChangeWatcher
-
Should this watcher be called for the given
State
. - accept(Class<?>) - Method in interface io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.ClassAliasExtractor
- accept(Class<?>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.DropClassNameSuffixExtractor
- accept(String) - Method in class io.streamthoughts.azkarra.streams.AbstractConfigEntryLoader
-
Checks whether this loader supported the specified root config key.
- accept(String) - Method in interface io.streamthoughts.azkarra.streams.ApplicationConfigEntryLoader
-
Checks whether this loader supported the specified root config key.
- accept(String) - Method in class io.streamthoughts.azkarra.streams.NoopConfigEntryLoader
- activeTasks(List<V1TaskMetadata>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- Adapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum.Adapter
- Adapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum.Adapter
- add(String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- add(String, Object, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- addActiveTasksItem(V1TaskMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- addAliases(Set<String>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Adds new aliases to reference the described component.
- addAliases(Set<String>) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Adds new aliases to reference the described component.
- addAliases(Set<String>) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Adds new aliases to reference the described component.
- addAssignmentsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- addAttribute(ComponentAttribute) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Adds the specified attribute.
- addClassAliasExtractor(ClassComponentAliasesGenerator.ClassAliasExtractor) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator
- addConfigEntryLoader(ApplicationConfigEntryLoader) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Adds a new
ApplicationConfigEntryLoader
to be used for reading the application configuration. - addConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds the specified
Conf
to the configuration of thisAzkarraContext
. - addConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Adds a new configuration to this environment.
- addConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds the specified
Conf
to the configuration of thisAzkarraContext
. - addConfiguration(Conf) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Adds the specified
Conf
to the configuration of thisAzkarraApplication
. - addConfiguration(Supplier<Conf>) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Adds a new configuration to this environment.
- addConfiguration(Supplier<Conf>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a new configuration to this environment.
- addConsumersItem(V1StreamsConsumerClientOffsets) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
- addDefaultCookie(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Add a default cookie.
- addDefaultHeader(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Add a default header.
- addErrorsItem(V1Error) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
- addEventStream(EventStream<K, V>) - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport
- addEventStreamsWithDefaults(String...) - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport
- addExecutionEnvironment(StreamsExecutionEnvironment<?>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds the
StreamsExecutionEnvironment
to this context. - addExecutionEnvironment(StreamsExecutionEnvironment<?>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds the
StreamsExecutionEnvironment
to this context. - addFactory(StreamsExecutionEnvironmentFactory<?>) - Method in class io.streamthoughts.azkarra.runtime.StreamsExecutionEnvironmentAbstractFactory
-
Adds a new
StreamsExecutionEnvironmentFactory
to this one. - addFailureItem(V1QueryErrorResultSet) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- addFallbackConfiguration(Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.
- addFallbackConfiguration(Conf) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds settings to this environment that will be used in fallback if not present in the defined environment configuration.
- addGlobalStateListener(StateRestoreListener) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a
StateRestoreListener
instance that will set to allKafkaStreams
instance created in thisStreamsExecutionEnvironment
. - addGlobalStoresItem(V1StreamsGlobalStore) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
- addHandler(Thread.UncaughtExceptionHandler) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler
- addInterceptors(Collection<StreamsLifecycleInterceptor>) - Method in class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor
- addListener(AzkarraContextListener) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Registers a new listener instance to this context.
- addListener(AzkarraContextListener) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Registers a new listener instance to this context.
- addListener(KafkaStreams.StateListener) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateListener
- addListener(StateRestoreListener) - Method in class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
- addMetricsItem(V1Metric) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
- addNewEnvironment(String, String, Conf) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Adds a new environment to this application.
- addNewEnvironment(String, String, Conf) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
-
Adds a new environment to this application.
- addNodesItem(V1StreamsTopologyNode) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
- addPartitionLagInfosItem(V1StatePartitionLagInfo) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
- addPartitionRestoreInfosItem(V1StatePartitionRestoreInfo) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
- addPositionsItem(V1StreamsConsumerLogOffsets) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
- addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
- addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
- addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
- addPredecessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
- addProducerClientIdsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- addRecordsItem(V1Record) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
- address() - Method in class io.streamthoughts.azkarra.api.util.Endpoint
- addSource(Class<?>) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Adds a class source which must be used for initializing this
AzkarraApplication
. - addSources(Class<?>...) - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Adds a class sources which must be used for initializing this
AzkarraApplication
. - addStandbyAssignmentsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- addStandbyStateStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- addStandbyTasksItem(V1TaskMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Register a watcher to be notified of
KafkaStreams.State
change event. - addStateChangeWatcher(KafkaStreamsContainer.StateChangeWatcher) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Register a watcher to be notified of
KafkaStreams.State
change event. - addStateListener(KafkaStreams.StateListener) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a
KafkaStreams.StateListener
instance that will set to allKafkaStreams
instance created in thisStreamsExecutionEnvironment
. - addStateStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- addStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
- addStoresItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
- addStreamsConfiguration(Supplier<Conf>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Helper method to add a configuration prefixed with 'streams.'.
- addStreamsLifecycleInterceptor(Supplier<StreamsLifecycleInterceptor>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a streams interceptor that will set to all
KafkaStreams
instance created in thisStreamsExecutionEnvironment
. - addSubTopologiesItem(V1StreamsSubTopology) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
- addSuccessItem(V1QuerySuccessResultSet) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
- addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
- addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
- addSuccessorsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
- addThreadsItem(V1ThreadMetadata) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
- addTopicPartitionsItem(V1TopicPartition) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
- addTopicsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
- addTopicsItem(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
- addTopology(Class<? extends TopologyProvider>, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds a topology to the default environment of this context.
- addTopology(Class<? extends TopologyProvider>, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds a topology to the default environment of this context.
- addTopology(Class<? extends TopologyProvider>, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds a topology to a specified environment.
- addTopology(Class<? extends TopologyProvider>, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds a topology to a specified environment.
- addTopology(String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds a topology to the default environment of this context.
- addTopology(String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds a topology to the default environment of this context.
- addTopology(String, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds a topology to a specified environment.
- addTopology(String, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds a topology to a specified environment.
- addTopology(String, String, String, Executed) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Adds a topology to a specified environment.
- addTopology(String, String, String, Executed) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Adds a topology to a specified environment.
- addTopology(Supplier<TopologyProvider>) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a new
TopologyProvider
instance to thisStreamsExecutionEnvironment
. - addTopology(Supplier<TopologyProvider>, Executed) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Adds a new
TopologyProvider
instance to thisStreamsExecutionEnvironment
. - addUsers(UserDetails) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
- adminClientId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- AdminClientUtils - Class in io.streamthoughts.azkarra.api.streams.admin
- AdminClientUtils() - Constructor for class io.streamthoughts.azkarra.api.streams.admin.AdminClientUtils
- aggregate(List<Health>) - Method in class io.streamthoughts.azkarra.http.health.HealthAggregator
-
Aggregates the specified
Health
instances to a single one. - aggregateStatus(List<Status>) - Method in class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator
-
Aggregates the the specified list of status.
- aggregateStatus(List<Status>) - Method in interface io.streamthoughts.azkarra.http.health.StatusAggregator
-
Aggregates the the specified list of status.
- aliases() - Method in annotation type io.streamthoughts.azkarra.api.annotations.TopologyInfo
-
Gets the aliases used to register this the
Topology
. - aliases() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Gets the set of aliases for this component.
- aliases() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Gets the set of aliases for this component.
- aliases() - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
- aliases() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Gets the set of aliases for this component.
- all() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
- all() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueQueryBuilder
- all() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
- all() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
- all() - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
- all(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
- all(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- ALL - io.streamthoughts.azkarra.api.query.StoreOperation
- allGrantedAuthorities() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
- allInstances() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
- allLocalStorePartitionInfos() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets the partition restoration and lag for all local state store.
- allLocalStorePartitionInfos() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets the partition restoration and lag for all local state store.
- allOf() - Static method in class io.streamthoughts.azkarra.api.util.FutureCollectors
- allOf(List<Error>) - Static method in class io.streamthoughts.azkarra.api.query.result.QueryError
- AllowAllHostNameVerifier - Class in io.streamthoughts.azkarra.http.security
-
A
HostnameVerifier
that accept all certificates. - AllowAllHostNameVerifier() - Constructor for class io.streamthoughts.azkarra.client.HttpClientBuilder.AllowAllHostNameVerifier
- AllowAllHostNameVerifier() - Constructor for class io.streamthoughts.azkarra.http.security.AllowAllHostNameVerifier
- ALLOWED - io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult
- AlreadyExistsException - Exception in io.streamthoughts.azkarra.api.errors
-
Thrown if an application or an environment already exists.
- AlreadyExistsException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AlreadyExistsException
-
Creates a new
AlreadyExistsException
instance. - AnnotationResolver - Class in io.streamthoughts.azkarra.api.util
- AnnotationResolver() - Constructor for class io.streamthoughts.azkarra.api.util.AnnotationResolver
- AnnotationResolver.AnnotationFilter - Interface in io.streamthoughts.azkarra.api.util
- AnnotationResolver.PackageAnnotationFilter - Class in io.streamthoughts.azkarra.api.util
- AnnotationResolver.TypeAnnotationFilter - Class in io.streamthoughts.azkarra.api.util
- any(Condition...) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions
-
Specify that ANY of the given condition should be
true
for a component to be eligible for use. - any(List<? extends Condition>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions
-
Specify that ANY of the given condition should be
true
for a component to be eligible for use. - AnyQualifier<T> - Class in io.streamthoughts.azkarra.api.components.qualifier
- AnyQualifier(List<Qualifier<T>>) - Constructor for class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
-
Creates a new
AnyQualifier
instance. - ApiApplicationsRoutes - Class in io.streamthoughts.azkarra.http.routes
-
This class defines all routes for API '/applications'.
- ApiApplicationsRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiApplicationsRoutes
-
Creates a new
ApiApplicationsRoutes
instance. - ApiCallback<T> - Interface in io.streamthoughts.azkarra.client.openapi
-
Callback for asynchronous API call.
- ApiClient - Class in io.streamthoughts.azkarra.client.openapi
- ApiClient() - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiClient
- ApiClient(OkHttpClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiClient
- ApiContextRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiContextRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiContextRoutes
- ApiDefaultRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiDefaultRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes
- ApiDocHttpRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiDocHttpRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiDocHttpRoutes
- ApiEnvironmentRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiEnvironmentRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
- ApiException - Exception in io.streamthoughts.azkarra.client.openapi
- ApiException() - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(int, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(int, String, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(String, int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(String, Throwable, int, Map<String, List<String>>) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(String, Throwable, int, Map<String, List<String>>, String) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiException(Throwable) - Constructor for exception io.streamthoughts.azkarra.client.openapi.ApiException
- ApiHealthRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiHealthRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
- ApiInfoRoutes - Class in io.streamthoughts.azkarra.http.routes
- ApiInfoRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
- ApiKeyAuth - Class in io.streamthoughts.azkarra.client.openapi.auth
- ApiKeyAuth(String, String) - Constructor for class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- ApiOnFailureCallback - Interface in io.streamthoughts.azkarra.http.query
- ApiResponse<T> - Class in io.streamthoughts.azkarra.client.openapi
-
API response returned by API call.
- ApiResponse(int, Map<String, List<String>>) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiResponse
- ApiResponse(int, Map<String, List<String>>, T) - Constructor for class io.streamthoughts.azkarra.client.openapi.ApiResponse
- ApiStreamsRoutes - Class in io.streamthoughts.azkarra.http.routes
-
This class defines all routes for API '/streams'.
- ApiStreamsRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiStreamsRoutes
- ApiTopologyRoutes - Class in io.streamthoughts.azkarra.http.routes
-
This class defines all routes for API '/topologies'.
- ApiTopologyRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiTopologyRoutes
-
Creates a new
ApiTopologyRoutes
instance. - ApiVersionRoutes - Class in io.streamthoughts.azkarra.http.routes
-
This class defines all routes for API '/version'.
- ApiVersionRoutes() - Constructor for class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
- APIVersions - Class in io.streamthoughts.azkarra.http
- APIVersions() - Constructor for class io.streamthoughts.azkarra.http.APIVersions
- application() - Static method in class io.streamthoughts.azkarra.api.components.Restriction
- ApplicationConfigEntryLoader - Interface in io.streamthoughts.azkarra.streams
- ApplicationConfigLoader - Class in io.streamthoughts.azkarra.streams
- ApplicationConfigLoader(List<ApplicationConfigEntryLoader>) - Constructor for class io.streamthoughts.azkarra.streams.ApplicationConfigLoader
- applicationId() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets configured
StreamsConfig.APPLICATION_ID_CONFIG
for thisKafkaStreams
instance. - applicationId() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleContext
- applicationId() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- applicationId() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets configured
StreamsConfig.APPLICATION_ID_CONFIG
for thisKafkaStreams
instance. - ApplicationId - Class in io.streamthoughts.azkarra.api
-
An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.
- ApplicationId(String) - Constructor for class io.streamthoughts.azkarra.api.ApplicationId
-
Creates a new
ApplicationId
for specified id. - ApplicationIdBuilder - Interface in io.streamthoughts.azkarra.api.streams
-
Class for building
StreamsConfig.APPLICATION_ID_CONFIG
. - ApplicationQueryStoreHandler - Class in io.streamthoughts.azkarra.http.handler
- ApplicationQueryStoreHandler(InteractiveQueryService, boolean) - Constructor for class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler
-
Creates a new
ApplicationQueryStoreHandler
instance. - applications() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
- applicationServer() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- apply() - Method in interface io.streamthoughts.azkarra.commons.rocksdb.internal.ResourceInitializer
-
Creates a new resource.
- apply() - Method in interface io.streamthoughts.azkarra.runtime.util.ShutdownHook.Hook
- apply(A) - Method in class io.streamthoughts.azkarra.api.monad.Reader
- apply(MeterRegistry) - Method in class io.streamthoughts.azkarra.metrics.micrometer.MicrometerMeterRegistryConfigurer
-
Applies this configurer to the given meter registry.
- apply(ComponentDescriptor<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorModifier
-
Modifies the given
ComponentDescriptor
. - apply(String) - Method in interface io.streamthoughts.examples.azkarra.conditional.ConditionalStreamsApplication.Normalize
- apply(T) - Method in interface io.streamthoughts.azkarra.api.monad.CheckedFunction
- apply(T) - Method in interface io.streamthoughts.azkarra.metrics.micrometer.MeterRegistryConfigurer
-
Applies this configurer to the given meter registry.
- applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in interface io.streamthoughts.azkarra.client.openapi.auth.Authentication
-
Apply authentication settings to header and query params.
- applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
- applyToParams(List<Pair>, Map<String, String>, Map<String, String>) - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBearerAuth
- ArgsConf - Class in io.streamthoughts.azkarra.api.config
-
A
Conf
which is build from a list of arguments. - ArgsConf(String[]) - Constructor for class io.streamthoughts.azkarra.api.config.ArgsConf
-
Creates a new
ArgsConf
instance. - arrayValue(String, String) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Gets the array value for the specified attribute name and member.
- as(String) - Static method in class io.streamthoughts.azkarra.api.Executed
-
Static helper that can be used to creates a new
Executed
instance with the specified streams name. - as(String, String) - Static method in class io.streamthoughts.azkarra.api.Executed
-
Static helper that can be used to creates a new
Executed
instance with the specified streams name and description. - asBoolean() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as an boolean.
- asDouble() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a double.
- asEager() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers
-
Gets a modifier implementation that will set a component as eager.
- asInt() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as an integer.
- asLong() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets valuer as a long.
- asPrimary() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers
-
Gets a modifier implementation that will set a component as primary.
- asProperty() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
- asSecondary() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers
-
Gets a modifier implementation that will set a component as secondary.
- assignments() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsMetadata
-
Gets the set of topic-partitions assigned to this instance.
- assignments(Set<V1TopicPartition>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- asString() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a string.
- asStringList() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a list.
- asSubConf() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a
Conf
. - asSubConfList() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a list of
Conf
. - AsyncMulticastEventStreamPublisher<K,V> - Class in io.streamthoughts.azkarra.api.events.reactive
-
The AsyncMulticastEventStreamPublisher is an implementation of Reactive Streams
Flow.Publisher
which executes asynchronously, using an internal single-threadExecutor
. - AsyncMulticastEventStreamPublisher(EventStream<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.reactive.AsyncMulticastEventStreamPublisher
-
Creates a new
AsyncMulticastEventStreamPublisher
instance. - AsyncQueryApiCallback<K,V> - Class in io.streamthoughts.azkarra.http.query
- AsyncQueryApiCallback(CompletableFuture<QueryResult<K, V>>, ApiOnFailureCallback) - Constructor for class io.streamthoughts.azkarra.http.query.AsyncQueryApiCallback
-
Creates a new
AsyncQueryApiCallback
instance. - AtLeastOnce - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to automatically set the streams property
processing.guarantee
toat_least_once
. - attributes() - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Gets all attributes.
- attributes() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
- attributesForName(String) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Gets all attributes for the given name.
- authenticate(Authentication) - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationManager
-
Performs the authentication.
- authenticate(AuthorizationContext) - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationManager
- authenticate(AuthorizationContext) - Method in class io.streamthoughts.azkarra.http.security.authorizer.SimpleAuthorizationManager
- authenticate(Principal, Credentials) - Method in interface io.streamthoughts.azkarra.http.security.auth.Authenticator
-
Authenticates the current user for the specified principal and credentials.
- authenticate(Principal, Credentials) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicAuthenticator
-
Authenticates the current user for the specified principal and credentials.
- authenticate(Principal, Credentials) - Method in class io.streamthoughts.azkarra.http.security.auth.CertClientAuthenticator
-
Authenticates the current user for the specified principal and credentials.
- authenticate(Route, Response) - Method in class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator
- Authentication - Interface in io.streamthoughts.azkarra.client.openapi.auth
- Authentication - Interface in io.streamthoughts.azkarra.http.security.auth
- AuthenticationCallback<T extends Authentication> - Class in io.streamthoughts.azkarra.http.security.jaas.spi
- AuthenticationCallback() - Constructor for class io.streamthoughts.azkarra.http.security.jaas.spi.AuthenticationCallback
- AuthenticationContext - Interface in io.streamthoughts.azkarra.http.security.auth
- AuthenticationContextHandler - Class in io.streamthoughts.azkarra.http.security.handler
- AuthenticationContextHandler(SecurityMechanism, HttpHandler) - Constructor for class io.streamthoughts.azkarra.http.security.handler.AuthenticationContextHandler
-
Creates a new
AuthenticationContextHandler
instance. - AuthenticationContextHolder - Class in io.streamthoughts.azkarra.http.security.auth
-
Class used to hold information about current authenticated principal.
- AuthenticationContextHolder() - Constructor for class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder
- AuthenticationManager - Interface in io.streamthoughts.azkarra.http.security.auth
- authenticator(Authenticator) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder
- Authenticator - Interface in io.streamthoughts.azkarra.http.security.auth
-
Interface to authenticate users.
- authorities() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext
-
Gets the list of authorities granted to the authenticated used.
- AuthorizationContext - Interface in io.streamthoughts.azkarra.http.security.authorizer
- AuthorizationHandler - Class in io.streamthoughts.azkarra.http.security.authorizer
- AuthorizationHandler(HttpHandler, AuthorizationManager, AzkarraPrincipalBuilder) - Constructor for class io.streamthoughts.azkarra.http.security.authorizer.AuthorizationHandler
-
Creates a new
AuthorizationHandler
instance. - AuthorizationManager - Interface in io.streamthoughts.azkarra.http.security.authorizer
-
Pluggable interface which is used to authenticate users.
- AuthorizationResult - Enum in io.streamthoughts.azkarra.http.security.authorizer
- AUTO_CREATE_TOPICS_CONFIGS_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
auto.create.topics.configs
- AUTO_CREATE_TOPICS_ENABLE_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
auto.create.topics.enable
- AUTO_CREATE_TOPICS_NUM_PARTITIONS_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
auto.create.topics.num.partitions
- AUTO_CREATE_TOPICS_NUM_PARTITIONS_DEFAULT - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
- AUTO_CREATE_TOPICS_REPLICATION_FACTOR_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
auto.create.topics.replication.factor
- AUTO_CREATE_TOPICS_REPLICATION_FACTOR_DEFAULT - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
- AUTO_DELETE_TOPICS_ENABLE_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
auto.delete.topics.enable
- AutoConfigure - Class in io.streamthoughts.azkarra.streams.autoconfigure
-
This class is used for auto-configuring the
AzkarraApplication
instance. - AutoConfigure() - Constructor for class io.streamthoughts.azkarra.streams.autoconfigure.AutoConfigure
-
Creates a new
AutoConfigure
instance. - AutoCreateTopicsInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors
-
This
StreamsLifecycleInterceptor
create both topics source and sink before starting the streams instance. - AutoCreateTopicsInterceptor() - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor
-
Creates a new
AutoCreateTopicsInterceptor
instance. - AutoCreateTopicsInterceptor(AdminClient) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor
-
Creates a new
AutoCreateTopicsInterceptor
instance. - AutoCreateTopicsInterceptorConfig - Class in io.streamthoughts.azkarra.runtime.interceptors
-
The configuration class for
AutoCreateTopicsInterceptor
. - AutoCreateTopicsInterceptorConfig(Conf) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
Creates a new
AutoCreateTopicsInterceptorConfig
instance. - AutoStartConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
- AutoStartConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.AutoStartConfigEntryLoader
- AZKARRA_ROOT_CONFIG_KEY - Static variable in class io.streamthoughts.azkarra.streams.AzkarraApplication
- AzkarraAccount - Class in io.streamthoughts.azkarra.http.security
-
AzkarraAccount.
- AzkarraAccount(Principal, Credentials, UserDetails) - Constructor for class io.streamthoughts.azkarra.http.security.AzkarraAccount
-
Creates a new
AzkarraAccount
instance. - AzkarraApplication - Class in io.streamthoughts.azkarra.streams
-
AzkarraApplication
is the high-level class which can be used to deploy a simple server for managing multipleKafkaStreams
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
- AzkarraConf(Config) - Constructor for class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Creates a new
AzkarraConf
instance. - AzkarraContext - Interface in io.streamthoughts.azkarra.api
-
The AzkarraContext.
- AzkarraContextAware - Interface in io.streamthoughts.azkarra.api
-
Interface to be implemented by any object that wishes to be notified of the
AzkarraContext
that it runs in. - AzkarraContextException - Exception in io.streamthoughts.azkarra.api.errors
- AzkarraContextException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraContextException
-
Creates a new
AzkarraContextException
instance. - AzkarraContextException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraContextException
-
Creates a new
AzkarraContextException
instance. - AzkarraContextListener - Interface in io.streamthoughts.azkarra.api
- AzkarraException - Exception in io.streamthoughts.azkarra.api.errors
-
AzkarraException is the top-level error type generated by the core-api.
- AzkarraException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException
-
Creates a new
AzkarraException
instance. - AzkarraException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException
-
Creates a new
AzkarraException
instance. - AzkarraException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraException
-
Creates a new
AzkarraException
instance. - AzkarraExceptionMapper - Class in io.streamthoughts.azkarra.http.error
-
The default JAX-RS
ExceptionMapper
implementation. - AzkarraExceptionMapper() - Constructor for class io.streamthoughts.azkarra.http.error.AzkarraExceptionMapper
- AzkarraIdentityManager - Class in io.streamthoughts.azkarra.http.security
-
BasicMapIdentityManager.
- AzkarraIdentityManager(Authenticator) - Constructor for class io.streamthoughts.azkarra.http.security.AzkarraIdentityManager
-
Creates a new
AzkarraIdentityManager
instance. - AzkarraMetricsConfig - Class in io.streamthoughts.azkarra.metrics
-
Properties to configure metrics.
- AzkarraMetricsConfig(Conf) - Constructor for class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfig
-
Creates a new
AzkarraMetricsConfig
instance. - AzkarraMetricsConfigEntryLoader - Class in io.streamthoughts.azkarra.metrics
- AzkarraMetricsConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfigEntryLoader
-
Creates a new
AzkarraMetricsConfigEntryLoader
instance. - AzkarraPrincipalBuilder - Interface in io.streamthoughts.azkarra.http.security.auth
-
Pluggable builder interface which is used to build
Principal
object used during authorization. - AzkarraRestExtension - Interface in io.streamthoughts.azkarra.api.server
-
A pluggable interface to allow registration of new JAX-RS resources like REST endpoints.
- AzkarraRestExtensionContext - Interface in io.streamthoughts.azkarra.api.server
-
This interfaces provides the capability for
AzkarraRestExtension
implementations to register JAX-RS resources using the providedConfigurable
and to get access to theAzkarraContext
instance. - AzkarraRetriableException - Exception in io.streamthoughts.azkarra.api.errors
- AzkarraRetriableException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraRetriableException
-
Creates a new
AzkarraRetriableException
instance. - AzkarraRetriableException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.AzkarraRetriableException
-
Creates a new
AzkarraRetriableException
instance. - AzkarraRocksDBConfigSetter - Class in io.streamthoughts.azkarra.commons.rocksdb
-
This
RocksDBConfigSetter
implementation allows fine-tuning of RocksDB instances. - AzkarraRocksDBConfigSetter() - Constructor for class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
- AzkarraRocksDBConfigSetterConfig - Class in io.streamthoughts.azkarra.commons.rocksdb
-
The
AzkarraRocksDBConfigSetterConfig
is used to configure theAzkarraRocksDBConfigSetter
. - AzkarraSimpleModule - Class in io.streamthoughts.azkarra.serialization.json
-
A simple module with all registered serializers.
- AzkarraSimpleModule() - Constructor for class io.streamthoughts.azkarra.serialization.json.AzkarraSimpleModule
-
Creates a new
AzkarraSimpleModule
instance. - AzkarraStreamsApplication - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
- AzkarraStreamsService - Interface in io.streamthoughts.azkarra.api
-
The
AzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. - AzkarraV1Api - Class in io.streamthoughts.azkarra.client.openapi.apis
- AzkarraV1Api() - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
- AzkarraV1Api(ApiClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
- azkarraVersion(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
- AzkarraVersion - Class in io.streamthoughts.azkarra.api
-
A
AzkarraVersion
is used to get version information about the running azkarra library. - AzkarraVersion() - Constructor for class io.streamthoughts.azkarra.api.AzkarraVersion
- AzkarraVersionApi - Class in io.streamthoughts.azkarra.client.openapi.apis
- AzkarraVersionApi() - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
- AzkarraVersionApi(ApiClient) - Constructor for class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
- AzkarraWorker - Class in io.streamthoughts.azkarra
-
The default main class for starting an Azkarra worker.
- AzkarraWorker() - Constructor for class io.streamthoughts.azkarra.AzkarraWorker
B
- BadRequestException - Exception in io.streamthoughts.azkarra.http.error
- BadRequestException(String) - Constructor for exception io.streamthoughts.azkarra.http.error.BadRequestException
-
Creates a new
BadRequestException
instance. - Banner - Interface in io.streamthoughts.azkarra.api.banner
- Banner.Mode - Enum in io.streamthoughts.azkarra.api.banner
- BannerPrinter - Interface in io.streamthoughts.azkarra.api.banner
- BannerPrinterBuilder - Class in io.streamthoughts.azkarra.streams.banner
-
Default class for building
BannerPrinter
instance. - BaseAsyncQueryCall<K,V,Q extends Query> - Class in io.streamthoughts.azkarra.runtime.query
- BaseAsyncQueryCall(Q) - Constructor for class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall
-
Creates a new
BaseAsyncQueryCall
instance. - BaseComponentModule - Class in io.streamthoughts.azkarra.api.components
-
An abstract base class that can be extended to supply configurable components.
- BaseComponentModule() - Constructor for class io.streamthoughts.azkarra.api.components.BaseComponentModule
- BaseKeyedLocalStoreQuery<K1,K2,V> - Class in io.streamthoughts.azkarra.api.query.internal
- BASIC_AUTH - io.streamthoughts.azkarra.http.security.SecurityMechanism
- BasicAuthAuthenticator - Class in io.streamthoughts.azkarra.client.authentication
-
BasicAuthAuthenticator.
- BasicAuthAuthenticator(Supplier<BasicAuthAuthenticator.Credential>) - Constructor for class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator
- BasicAuthAuthenticator.Credential - Class in io.streamthoughts.azkarra.client.authentication
- BasicAuthenticationExample - Class in io.streamthoughts.examples.azkarra.security
-
Example to configure an azkarra application with Basic authentication.
- BasicAuthenticationExample() - Constructor for class io.streamthoughts.examples.azkarra.security.BasicAuthenticationExample
- BasicAuthenticator - Class in io.streamthoughts.azkarra.http.security.auth
-
BasicAuthenticator.
- BasicAuthenticator(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicAuthenticator
-
Creates a new
BasicAuthenticator
instance. - BasicBlockingRecordQueue<K,V> - Class in io.streamthoughts.azkarra.api.events
-
A simple
BlockingRecordQueue
backed by aBlockingQueue
. - BasicBlockingRecordQueue() - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
-
Creates a new
BasicBlockingRecordQueue
instance. - BasicBlockingRecordQueue(int) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
-
Creates a new
BasicBlockingRecordQueue
instance. - BasicBlockingRecordQueue(int, Duration) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
-
Creates a new
BasicBlockingRecordQueue
instance. - BasicBlockingRecordQueue(int, Duration, LimitHandler) - Constructor for class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
-
Creates a new
BasicBlockingRecordQueue
instance. - BasicComponentFactory<T> - Class in io.streamthoughts.azkarra.runtime.components
- BasicComponentFactory(Class<T>) - Constructor for class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory
-
Creates a new
BasicComponentFactory
instance. - BasicComponentFactory(Class<T>, ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory
-
Creates a new
BasicComponentFactory
instance. - BasicContainerId - Class in io.streamthoughts.azkarra.runtime.env.internal
- BasicContainerId(String) - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
-
Creates a new
BasicContainerId
instance. - BasicRolePrincipal - Class in io.streamthoughts.azkarra.http.security.auth
- BasicRolePrincipal(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
-
Creates a new
BasicRolePrincipal
instance. - BasicUserPrincipal - Class in io.streamthoughts.azkarra.http.security.auth
-
BasicUserPrincipal.
- BasicUserPrincipal(String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
-
Creates a new
BasicUserPrincipal
instance. - BasicWordCountTopology - Class in io.streamthoughts.examples.azkarra.topology
-
A basic WordCount topology.
- BasicWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.topology.BasicWordCountTopology
- BlockingRecordQueue<K,V> - Interface in io.streamthoughts.azkarra.api.events
-
A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.
- branch(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
- build() - Method in class io.streamthoughts.azkarra.api.events.EventStream.Builder
- build() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResultBuilder
- build() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
- build() - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder
-
Builds the http client.
- build() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.Builder
- build() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder
-
Builds a new
Health
instance. - build() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
- build() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
- build() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsBuilder
-
Builds a new cloud event entity
- build() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.StreamsExtensionBuilder
- build() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainerBuilder
-
Builds a
KafkaStreams
instance. - build() - Method in class io.streamthoughts.azkarra.streams.banner.BannerPrinterBuilder
- build(TopologyDescription) - Static method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
- build(TopologyDescription.Processor) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNodeBuilder
- build(TopologyDescription.Sink) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNodeBuilder
- build(TopologyDescription.Source) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNodeBuilder
- buildApplicationId(TopologyMetadata, Conf) - Method in interface io.streamthoughts.azkarra.api.streams.ApplicationIdBuilder
-
Builds the
StreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. - buildApplicationId(TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder
-
Builds the
StreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. - buildApplicationId(TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder
-
Builds the
StreamsConfig.APPLICATION_ID_CONFIG
for the specified topology and configuration. - buildCall(String, String, List<Pair>, List<Pair>, Object, Map<String, String>, Map<String, String>, Map<String, Object>, String[], ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Build HTTP call with the given options.
- buildConditionsForAnnotations(List<ConditionalOn>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions
-
Static helper to build a list of
Condition
s based on the given annotation. - buildContainerId(ApplicationId, TopologyMetadata, Conf) - Method in interface io.streamthoughts.azkarra.runtime.env.ContainerIdBuilder
-
Builds the identifier that will be used for identifying the
KafkaStreamsContainer
running the topology. - buildContainerId(ApplicationId, TopologyMetadata, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
-
Builds the identifier that will be used for identifying the
KafkaStreamsContainer
running the topology. - Builder() - Constructor for class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
- Builder() - Constructor for class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.Builder
- Builder() - Constructor for class io.streamthoughts.azkarra.http.health.Health.Builder
-
Creates a new
Health.Builder
instance. - Builder(String) - Constructor for class io.streamthoughts.azkarra.api.events.EventStream.Builder
-
Creates a new
EventStream.Builder
instance. - buildInternalErrorResult(String, String, Throwable) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
- buildNotAvailableResult(String) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
- buildPrincipal(AuthenticationContext) - Method in interface io.streamthoughts.azkarra.http.security.auth.AzkarraPrincipalBuilder
-
Builds the
Principal
. - buildQueryResult(List<Either<SuccessResultSet<K, V>, ErrorResultSet>>) - Static method in class io.streamthoughts.azkarra.runtime.query.internal.QueryResultUtils
- buildRequest(String, String, List<Pair>, List<Pair>, Object, Map<String, String>, Map<String, String>, Map<String, Object>, String[], ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Build an HTTP request with the given options.
- buildRequestBodyFormEncoding(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Build a form-encoding request body with the given form parameters.
- buildRequestBodyMultipart(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Build a multipart (file uploading) request body with the given form parameters, which could contain text fields and file fields.
- buildUrl(String, List<Pair>, List<Pair>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Build full URL by concatenating base path, the given sub path and query parameters.
- byAnyRestrictions(Restriction...) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byLatestVersion() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byName(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byPrimary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byQualifiers(Qualifier<T>...) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byRestriction(Restriction) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byRestriction(String, String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- bySecondary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- ByteArrayAdapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.ByteArrayAdapter
- byVersion(Version) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- byVersion(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
C
- calculateRemainingFormatted(TopicPartition, long) - Method in class io.streamthoughts.azkarra.commons.streams.LoggingStateRestoreListener
- call() - Method in interface io.streamthoughts.azkarra.api.StreamsTopologyExecution
- canBeInstantiated(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
- cancel() - Method in interface io.streamthoughts.azkarra.api.query.QueryCall
-
Cancels the
QueryCall
, if possible. - cancel() - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall
-
Cancels the
QueryCall
, if possible. - cancel() - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall
-
Cancels the
QueryCall
, if possible. - capped(Instant) - Static method in class io.streamthoughts.azkarra.api.util.Utils
-
Instant.toEpochMilli() could result in an arithmetic overflow/underflow (e.g.
- CertClientAuthenticator - Class in io.streamthoughts.azkarra.http.security.auth
- CertClientAuthenticator() - Constructor for class io.streamthoughts.azkarra.http.security.auth.CertClientAuthenticator
- CheckedFunction<T,R,E extends Exception> - Interface in io.streamthoughts.azkarra.api.monad
- CheckedSupplier<R,E extends Throwable> - Interface in io.streamthoughts.azkarra.api.monad
- checkEndpoint(Endpoint) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Checks whether the given
Endpoint
is the same as this container. - checkEndpoint(Endpoint) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Checks whether the given
Endpoint
is the same as this container. - ClassComponentAliasesGenerator - Class in io.streamthoughts.azkarra.runtime.components
-
ClassComponentAliasesGenerator
can be used to generate aliases from component class. - ClassComponentAliasesGenerator() - Constructor for class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator
-
Creates a new
ClassComponentAliasesGenerator
instance. - ClassComponentAliasesGenerator.ClassAliasExtractor - Interface in io.streamthoughts.azkarra.runtime.components
- ClassComponentAliasesGenerator.DropClassNameSuffixExtractor - Class in io.streamthoughts.azkarra.runtime.components
- classLoader() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Gets the classloader used to load the component.
- classLoader() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Gets the classloader used to load the component.
- classLoader() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
- classLoader() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Gets the classloader used to load the component.
- classLoader(ClassLoader) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Sets the classLoader of the component.
- ClassLoaderAwareKafkaStreamsFactory - Class in io.streamthoughts.azkarra.runtime.context.internal
- ClassLoaderAwareKafkaStreamsFactory(KafkaStreamsFactory, ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ClassLoaderAwareKafkaStreamsFactory
-
Creates a new
ClassLoaderAwareKafkaStreamsFactory
instance. - classLoaderMetrics() - Method in class io.streamthoughts.azkarra.metrics.binders.JvmMeterRegistryBinderFactory
-
Return the JVM Class loader metrics component.
- ClassloadingIsolationInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors
- ClassloadingIsolationInterceptor(ClassLoader) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.ClassloadingIsolationInterceptor
-
Creates a new
ClassloadingIsolationInterceptor
instance. - className() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Gets the name of the describe component.
- className() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Gets the name of the describe component.
- ClassUtils - Class in io.streamthoughts.azkarra.api.util
- ClassUtils() - Constructor for class io.streamthoughts.azkarra.api.util.ClassUtils
- cleanup(Boolean) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
- clear() - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
- clear() - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue
- clear() - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
- clearContext() - Static method in class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder
-
Clears the context value from the current thread.
- CLIENT_CERT_AUTH - io.streamthoughts.azkarra.http.security.SecurityMechanism
- clientAddress() - Method in interface io.streamthoughts.azkarra.http.security.authorizer.AuthorizationContext
-
Gets the client address.
- clientId() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
- clientId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
- close() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
- close() - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- close() - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent
-
Closes the created component.
- close() - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
-
Close the queue.
- close() - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue
-
Close the queue.
- close() - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
-
Close the queue.
- close() - Method in class io.streamthoughts.azkarra.api.events.EventStream
- close() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtension
- close() - Method in class io.streamthoughts.azkarra.api.streams.consumer.MonitorOffsetsConsumerInterceptor
- close() - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer
-
{@inheritDoc
- close() - Method in class io.streamthoughts.azkarra.commons.rocksdb.internal.OpaqueMemoryResource
-
Releases this resource.
- close() - Method in class io.streamthoughts.azkarra.metrics.endpoints.PrometheusEndpoint.PrometheusEndpointExtension
- close() - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
- close() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaMonitoringReporter
-
Closes this
MonitoringReporter
. - close() - Method in interface io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringReporter
-
Closes this
MonitoringReporter
. - close() - Method in interface io.streamthoughts.azkarra.serialization.Serdes
-
Close this
Serdes
. - close(boolean, Duration) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Closes this
KafkaStreams
instance and wait up to the timeout for the streams to be closed. - close(boolean, Duration) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Closes this
KafkaStreams
instance and wait up to the timeout for the streams to be closed. - close(String, Options) - Method in class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
- close(Duration) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Closes this
KafkaStreams
instance. - close(Duration) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Closes this
KafkaStreams
instance. - CloseKafkaStreamsOnThreadException - Class in io.streamthoughts.azkarra.runtime.streams.errors
-
Closes immediately the
KafkaStreams
instance when a StreamThread abruptly terminates due to an uncaught exception. - CloseKafkaStreamsOnThreadException() - Constructor for class io.streamthoughts.azkarra.runtime.streams.errors.CloseKafkaStreamsOnThreadException
- closeQuietly(AutoCloseable) - Static method in class io.streamthoughts.azkarra.api.util.Utils
- cloudEventId(ZonedDateTime) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- CloudEventsAttributes - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
-
This class describes the required attributes for streams events, following CloudEvents Specification.
- CloudEventsBuilder<T> - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
- CloudEventsContext - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
-
This class is used to wrap information about a Cloud Events in the context of Kafka Streams.
- CloudEventsContext(String, String, String) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
-
Creates a new
CloudEventsContext
instance. - CloudEventsEntity<T> - Class in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
- CloudEventsExtension - Interface in io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce
-
Represents a list of Cloud Events Extension.
- cloudEventSource() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- cloudEventSubject() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- collect() - Method in class io.streamthoughts.azkarra.http.prometheus.KafkaStreamsMetricsCollector
- collectionPathParameterToString(String, Collection) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Formats the specified collection path parameter to a string value.
- commit() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.PropertiesFileLoginModule
- commitId(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
- committedOffset() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- committedOffset(OffsetAndTimestamp) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- committedOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- committedTimestamp(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- compareAndSwapLoaders(ClassLoader) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
- compareTo(Ordered) - Method in interface io.streamthoughts.azkarra.api.components.Ordered
- compareTo(KV<K, V>) - Method in class io.streamthoughts.azkarra.api.model.KV
- compareTo(MetricGroup) - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
- compareTo(StreamsTopologyGraph.Node) - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
- compareTo(StreamsTopologyGraph.SubTopologyGraph) - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
- compareTo(TimestampedValue) - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
- compareTo(ConsumerLogOffsets) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- compareTo(TopicPartitions) - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
- compareTo(Version) - Method in class io.streamthoughts.azkarra.api.util.Version
- compile() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- compile(QueryParams) - Method in interface io.streamthoughts.azkarra.api.query.LocalPreparedQuery
-
Builds a new
LocalExecutableQuery
based on the givenQuery
. - ComplexWordCountTopology - Class in io.streamthoughts.examples.azkarra.dependency
- ComplexWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
- ComplexWordCountTopologyModule - Class in io.streamthoughts.examples.azkarra.dependency
-
A
ComponentModule
for providing a new @{link ComplexWordCountTopology} instance. - ComplexWordCountTopologyModule() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopologyModule
- Component - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
Marker interface that any class having a no-arg constructor can used to indicate it can be registered.
- ComponentAliasesGenerator - Interface in io.streamthoughts.azkarra.api.components
- ComponentAttribute - Class in io.streamthoughts.azkarra.api.components
- ComponentAttribute(String) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentAttribute
-
Creates a new
ComponentAttribute
instance. - ComponentAttribute(String, Map<String, Object>, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.api.components.ComponentAttribute
-
Creates a new
ComponentAttribute
instance. - ComponentClassLoader - Class in io.streamthoughts.azkarra.streams.components.isolation
-
Default ClassLoader for loading components using a 'child-first strategy'.
- ComponentConditionalContext<T extends ComponentDescriptor<?>> - Interface in io.streamthoughts.azkarra.api.components.condition
-
Interface to verify if a conditional component is enabled for a given context.
- ComponentConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
- ComponentConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.ComponentConfigEntryLoader
-
Creates a new
ComponentConfigEntryLoader
instance. - ComponentDescriptor<T> - Interface in io.streamthoughts.azkarra.api.components
-
Describes a single component managed by a
ComponentFactory
. - ComponentDescriptorBuilder<T> - Class in io.streamthoughts.azkarra.runtime.components
- ComponentDescriptorBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
- ComponentDescriptorFactory - Interface in io.streamthoughts.azkarra.api.components
-
Factory to create new
SimpleComponentDescriptor
instance. - ComponentDescriptorModifier - Interface in io.streamthoughts.azkarra.api.components
-
Callback for modifying a given component descriptor.
- ComponentDescriptorModifierResolver - Interface in io.streamthoughts.azkarra.streams.components.annotation
-
This interface can be used to resolve a
ComponentDescriptorModifier
to be used for registering a component. - ComponentDescriptorModifierResolver.ApplyModifierOnAnnotationExist - Class in io.streamthoughts.azkarra.streams.components.annotation
- ComponentDescriptorModifierResolver.ApplyModifierOnAnnotations<T extends Annotation> - Class in io.streamthoughts.azkarra.streams.components.annotation
- ComponentDescriptorModifiers - Class in io.streamthoughts.azkarra.runtime.components
- ComponentDescriptorModifiers() - Constructor for class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorModifiers
- ComponentDescriptorRegistry - Interface in io.streamthoughts.azkarra.api.components
- ComponentFactory - Interface in io.streamthoughts.azkarra.api.components
- ComponentFactoryAware - Interface in io.streamthoughts.azkarra.api.components
- componentLocation() - Method in interface io.streamthoughts.azkarra.api.components.ExternalComponentClassLoader
- componentLocation() - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
- ComponentMetadata - Class in io.streamthoughts.azkarra.api.components
- ComponentMetadata() - Constructor for class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Creates a new
ComponentMetadata
instance. - ComponentModule<T> - Class in io.streamthoughts.azkarra.api.components
-
A configurable component supplier which has access to the
ComponentFactory
. - ComponentModule() - Constructor for class io.streamthoughts.azkarra.api.components.ComponentModule
- ComponentNameGenerator - Interface in io.streamthoughts.azkarra.api.components
-
Interface which is used for generating component name.
- ComponentRegistrationException - Exception in io.streamthoughts.azkarra.api.components
- ComponentRegistrationException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.ComponentRegistrationException
-
Creates a new
ComponentRegistrationException
instance. - ComponentRegistrationException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.components.ComponentRegistrationException
-
Creates a new
ComponentRegistrationException
instance. - ComponentRegistry - Interface in io.streamthoughts.azkarra.api.components
-
The
ComponentRegistry
is the main interface for managing components used in an Azkarra application. - ComponentResolver - Class in io.streamthoughts.azkarra.streams.components.isolation
- ComponentResolver(Path) - Constructor for class io.streamthoughts.azkarra.streams.components.isolation.ComponentResolver
-
Creates a new
ComponentResolver
instance. - components() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn
-
Specify that components of the given types must be registered for the component to be enabled.
- ComponentScan - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
- ComponentScanner - Interface in io.streamthoughts.azkarra.api.components
- compose(Condition...) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions
-
Specify that ALL of the given condition should be
true
for a component to be eligible for use. - compose(List<? extends Condition>) - Static method in class io.streamthoughts.azkarra.api.components.condition.Conditions
-
Specify that ALL of the given condition should be
true
for a component to be eligible for use. - compositeMeterRegistry() - Method in class io.streamthoughts.azkarra.metrics.micrometer.MeterRegistryFactory
- CompositeQualifier<T> - Class in io.streamthoughts.azkarra.api.components.qualifier
- CompositeQualifier(List<Qualifier<T>>) - Constructor for class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
-
Creates a new
CompositeQualifier
instance. - CompositeStateListener - Class in io.streamthoughts.azkarra.api.streams.listener
-
A
KafkaStreams.StateListener
that delegates to one or moreKafkaStreams.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 moreStateRestoreListener
in order. - CompositeStateRestoreListener(Collection<StateRestoreListener>) - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeStateRestoreListener
-
Creates a new
CompositeStateRestoreListener
instance. - CompositeStreamsInterceptor - Class in io.streamthoughts.azkarra.runtime.interceptors
- CompositeStreamsInterceptor() - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor
-
Creates a new
CompositeStreamsInterceptor
instance. - CompositeStreamsInterceptor(Collection<StreamsLifecycleInterceptor>) - Constructor for class io.streamthoughts.azkarra.runtime.interceptors.CompositeStreamsInterceptor
-
Creates a new
CompositeStreamsInterceptor
instance. - CompositeUncaughtExceptionHandler - Class in io.streamthoughts.azkarra.api.streams.listener
- CompositeUncaughtExceptionHandler() - Constructor for class io.streamthoughts.azkarra.api.streams.listener.CompositeUncaughtExceptionHandler
-
Creates a new
CompositeUncaughtExceptionHandler
instance. - condition() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Gets the
Condition
that need to be fulfilled for this component to be eligible for use in the application. - condition() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Gets the
Condition
that need to be fulfilled for this component to be eligible for use in the application. - condition() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Gets the
Condition
that need to be fulfilled for this component to be eligible for use in the application. - condition(Condition) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
- Condition - Interface in io.streamthoughts.azkarra.api.components.condition
-
Define a single condition that need to be fulfilled for a component to be eligible for use in the application.
- ConditionalDescriptorRegistry - Interface in io.streamthoughts.azkarra.api.components
-
The main interface that defines methods to find registered
ComponentDescriptor
for enable components. - ConditionalOn - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to indicate the condition(s) that need to be fulfilled for a component to be eligible for use in the application.
- ConditionalOnMetricsEnable - Annotation Type in io.streamthoughts.azkarra.metrics.annotations
- Conditionals - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to indicate all the conditions that need to be fulfilled for a component to be eligible for use in the application.
- ConditionalStreamsApplication - Class in io.streamthoughts.examples.azkarra.conditional
-
This example demonstrates how conditional components can be used to dynamically change the behavior of a stream topology based on its configuration.
- ConditionalStreamsApplication() - Constructor for class io.streamthoughts.examples.azkarra.conditional.ConditionalStreamsApplication
- ConditionalStreamsApplication.Normalize - Interface in io.streamthoughts.examples.azkarra.conditional
- ConditionalStreamsApplication.Normalizes - Class in io.streamthoughts.examples.azkarra.conditional
- ConditionalStreamsApplication.NormalizeStreamsTopology - Class in io.streamthoughts.examples.azkarra.conditional
- ConditionContext<T extends ComponentDescriptor> - Interface in io.streamthoughts.azkarra.api.components.condition
-
The context information for use by a
Condition
matching aComponentDescriptor
. - conditions() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn
-
Specify one or more conditions that the component must match.
- Conditions - Class in io.streamthoughts.azkarra.api.components.condition
- Conditions() - Constructor for class io.streamthoughts.azkarra.api.components.condition.Conditions
- Conf - Interface in io.streamthoughts.azkarra.api.config
-
A
Conf
represents an immutable object which can be used for configuring components. - ConfEntry - Class in io.streamthoughts.azkarra.api.config
- ConfException - Exception in io.streamthoughts.azkarra.api.errors
-
ConfException is the top-level error type generated by the Conf api.
- ConfException(String) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
- ConfException(String, Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
- ConfException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ConfException
- config - Variable in class io.streamthoughts.azkarra.api.Executed
- config - Variable in class io.streamthoughts.azkarra.http.data.EnvironmentRequestBody
- config() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
- config() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
- config() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
-
Gets the configuration for this environment.
- config() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.TopologyConfig
- CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.metrics.AzkarraMetricsConfigEntryLoader
- CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.streams.config.loader.AutoStartConfigEntryLoader
- CONFIG_ENTRY_KEY - Static variable in class io.streamthoughts.azkarra.streams.config.loader.StreamsConfigEntryLoader
- ConfigConditionalContext<T> - Class in io.streamthoughts.azkarra.runtime.components.condition
-
Default
ComponentConditionalContext
implementation.. - ConfigConditionalContext(Conf) - Constructor for class io.streamthoughts.azkarra.runtime.components.condition.ConfigConditionalContext
-
Creates a new
ConfigConditionalContext
instance. - configDef() - Static method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- configDef(ConfigDef.Type) - Static method in class io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig
- configurable() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtensionContext
-
Provides an implementation of
Configurable
that must be used to register JAX-RS resources. - configurable() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer.InternalRestExtensionContext
- Configurable - Interface in io.streamthoughts.azkarra.api.config
- ConfigurableComponentFactory - Interface in io.streamthoughts.azkarra.api.components
- ConfigurableStopWordsService - Class in io.streamthoughts.examples.azkarra.dependency
- ConfigurableStopWordsService() - Constructor for class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
- ConfigurableSupplier<T> - Class in io.streamthoughts.azkarra.api.config
-
A configurable supplier.
- ConfigurableSupplier() - Constructor for class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
- ConfigurableWordCountTopology - Class in io.streamthoughts.examples.azkarra.topology
-
A basic WordCount topology.
- ConfigurableWordCountTopology() - Constructor for class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
- configuration() - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptor
-
Gets the default configuration that will pass to the describe component if it implements the
Configurable
interface. - configuration() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
-
Gets the default configuration that will pass to the describe component if it implements the
Configurable
interface. - configuration() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider
-
Returns
Conf
defined for thisTopologyProvider
. - configuration() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
- configuration() - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Gets the default configuration that will pass to the describe component if it implements the
Configurable
interface. - configuration(Conf) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
- configuration(Conf) - Method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
- Configuration - Class in io.streamthoughts.azkarra.client.openapi
- Configuration() - Constructor for class io.streamthoughts.azkarra.client.openapi.Configuration
- configure(Conf) - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in interface io.streamthoughts.azkarra.api.config.Configurable
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtension
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.http.security.authorizer.SimpleAuthorizationManager
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.metrics.interceptor.MeterKafkaStreamsInterceptor
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptor
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptor
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaMonitoringReporter
-
Configure this
StreamsMetadataReporter
. - configure(Conf) - Method in interface io.streamthoughts.azkarra.runtime.interceptors.monitoring.MonitoringReporter
-
Configure this
StreamsMetadataReporter
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptor
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptor
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in interface io.streamthoughts.azkarra.serialization.Serdes
-
Configure this
Serdes
. - configure(Conf) - Method in class io.streamthoughts.azkarra.streams.components.ReflectMethodComponentSupplier
-
Configures this instance with the specified
Conf
. - configure(Conf) - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopology
- configure(Conf) - Method in class io.streamthoughts.examples.azkarra.dependency.ConfigurableStopWordsService
- configure(Conf) - Method in class io.streamthoughts.examples.azkarra.topology.ConfigurableWordCountTopology
- configure(Consumer<ObjectMapper>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
- configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.api.streams.consumer.MonitorOffsetsConsumerInterceptor
- configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
- configure(Map<String, ?>) - Method in class io.streamthoughts.azkarra.commons.rocksdb.AzkarraRocksDBConfigSetter
- configure(Map<String, ?>, boolean) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer
-
{@inheritDoc
- ConflictingComponentDefinitionException - Exception in io.streamthoughts.azkarra.api.components
- ConflictingComponentDefinitionException(String) - Constructor for exception io.streamthoughts.azkarra.api.components.ConflictingComponentDefinitionException
-
Creates a new
ConflictingComponentDefinitionException
instance. - ConfSerializer - Class in io.streamthoughts.azkarra.serialization.json
-
Json serializer for
Conf
. - ConfSerializer() - Constructor for class io.streamthoughts.azkarra.serialization.json.ConfSerializer
- ConfValue - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to provide default config values to a configurable component.
- ConfValues - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to provide default config values to a configurable component.
- connected(ServerSentEventConnection, String) - Method in class io.streamthoughts.azkarra.http.sse.EventStreamConnectionCallback
- connectTimeout(int) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder
-
Sets the connect timeout (in milliseconds).
- CONSOLE - io.streamthoughts.azkarra.api.banner.Banner.Mode
- Constants - Class in io.streamthoughts.azkarra.http.utils
-
Helpers class for HTTP query params.
- Constants() - Constructor for class io.streamthoughts.azkarra.http.utils.Constants
- consumedOffset() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- consumedOffset(OffsetAndTimestamp) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- consumedOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- consumedTimestamp(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- ConsumerClientOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
- ConsumerClientOffsets(String, String, Set<ConsumerLogOffsets>) - Constructor for class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
-
Creates a new
ConsumerClientOffsets
instance. - ConsumerGroupOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
- ConsumerGroupOffsets(String, Set<ConsumerClientOffsets>) - Constructor for class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
-
Creates a new
ConsumerGroupOffsets
instance. - ConsumerGroupOffsetsRegistry - Interface in io.streamthoughts.azkarra.api.streams.consumer
- ConsumerGroupOffsetsState - Class in io.streamthoughts.azkarra.api.streams.consumer
- ConsumerLogOffsets - Class in io.streamthoughts.azkarra.api.streams.consumer
- consumers() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
- consumers(List<V1StreamsConsumerClientOffsets>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
- ConsumerThreadKey - Class in io.streamthoughts.azkarra.api.streams.consumer
- container() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleContext
- CONTAINER_ID_CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
- containerId() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets the id for this container.
- containerId() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets the id for this container.
- ContainerId - Interface in io.streamthoughts.azkarra.api
-
An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.
- ContainerIdBuilder - Interface in io.streamthoughts.azkarra.runtime.env
-
A
ContainerIdBuilder
is used to buildContainerId
. - contains(char[], char) - Static method in class io.streamthoughts.azkarra.api.util.Utils
- contains(Qualifier) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
- contains(String) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- contains(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Checks whether this
QueryParams
contains the given key param. - contains(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams
-
Checks whether this
QueryParams
contains the given key param. - contains(String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- contains(String, String, Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentMetadata
-
Checks whether the metadata contains the given value for the given attribute name and member.
- containsComponent(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Checks if at least one component is registered for the given type.
- containsComponent(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- containsComponent(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Checks if at least one component is registered for the given type.
- containsComponent(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Checks if at least one component is registered for the given type and qualifier.
- containsComponent(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- containsComponent(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Checks if at least one component is registered for the given type and qualifier.
- containsComponent(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Checks if at least one component is registered for the given type.
- containsComponent(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- containsComponent(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Checks if at least one component is registered for the given type.
- containsComponent(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Checks if at least one component is registered for the given type and qualifier.
- containsComponent(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- containsComponent(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Checks if at least one component is registered for the given type and qualifier.
- containsIgnoreCase(String[], String) - Static method in class io.streamthoughts.azkarra.client.openapi.StringUtil
-
Check if the given array contains the given value (with case-insensitive comparison).
- contentLength() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressRequestBody
- contentLength() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressResponseBody
- contentType() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressRequestBody
- contentType() - Method in class io.streamthoughts.azkarra.client.openapi.ProgressResponseBody
- contentType() - Method in class io.streamthoughts.azkarra.http.serialization.json.SpecificJsonSerdes
-
Get the content-type attached to this
Serdes
. - contentType() - Method in interface io.streamthoughts.azkarra.serialization.Serdes
-
Get the content-type attached to this
Serdes
. - context - Variable in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareComponentSupplier
- context - Variable in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
- context() - Method in interface io.streamthoughts.azkarra.api.server.AzkarraRestExtensionContext
-
Provides the
AzkarraContext
instance that can be used to retrieve registered components. - context() - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServer.InternalRestExtensionContext
- ContextAwareApplicationIdBuilderSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareApplicationIdBuilderSupplier(AzkarraContext, GettableComponent<ApplicationIdBuilder>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier
- ContextAwareApplicationIdBuilderSupplier.DelegateApplicationIdBuilder - Class in io.streamthoughts.azkarra.runtime.context.internal
-
A delegating
KafkaStreamsFactory
which is notConfigurable
. - ContextAwareComponentFactory - Class in io.streamthoughts.azkarra.api.components
- ContextAwareComponentFactory(AzkarraContext, ComponentFactory) - Constructor for class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Creates a new
ContextAwareComponentFactory
instance. - ContextAwareComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareGettableComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.context.internal
-
Supplier class which is used to get a specific component from
AzkarraContext
. - ContextAwareKafkaStreamsFactorySupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareKafkaStreamsFactorySupplier(AzkarraContext, GettableComponent<KafkaStreamsFactory>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareKafkaStreamsFactorySupplier
- ContextAwareKafkaStreamsFactorySupplier.DelegateKafkaStreamsFactory - Class in io.streamthoughts.azkarra.runtime.context.internal
-
A delegating
KafkaStreamsFactory
which is notConfigurable
. - ContextAwareLifecycleInterceptorSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareLifecycleInterceptorSupplier(AzkarraContext, GettableComponent<StreamsLifecycleInterceptor>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareLifecycleInterceptorSupplier
- ContextAwareThreadExceptionHandlerSupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareThreadExceptionHandlerSupplier(AzkarraContext, GettableComponent<StreamThreadExceptionHandler>) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier
- ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler - Class in io.streamthoughts.azkarra.runtime.context.internal
-
A delegating
StreamThreadExceptionHandler
which is notConfigurable
. - ContextAwareTopologySupplier - Class in io.streamthoughts.azkarra.runtime.context.internal
- ContextAwareTopologySupplier(AzkarraContext, StreamsTopologyMeta) - Constructor for class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier
-
Creates a new
ContextAwareTopologySupplier
instance. - ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider - Class in io.streamthoughts.azkarra.runtime.context.internal
-
A delegating
TopologyProvider
which is notConfigurable
. - count() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
- count(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
- count(Map<String, Object>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- COUNT - io.streamthoughts.azkarra.api.query.StoreOperation
- create() - Static method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
-
Helper method to create a new
StreamsTopologyMeta.Builder
instance. - create() - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Static helper method for creating a new
ComponentDescriptorBuilder
instance. - create() - Static method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Static helper that can be used to creates a new
AzkarraContext
instance using a defaultComponentRegistry
and a empty configuration. - create() - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Static helper that can be used to creates a new
StreamsExecutionEnvironment
instance using the empty configuration and a generated unique name. - create() - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Static helper that can be used to creates a new
AzkarraConf
instance that loads a default configuration. - create(ComponentDescriptor<T>) - Static method in class io.streamthoughts.azkarra.runtime.components.ComponentDescriptorBuilder
-
Static helper method for creating a new
ComponentDescriptorBuilder
instance. - create(ComponentFactory) - Static method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Static helper that can be used to creates a new
AzkarraContext
instance using the specifiedComponentRegistry
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 defaultComponentRegistry
and the specified configuration. - create(Conf) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Static helper that can be used to creates a new
StreamsExecutionEnvironment
instance from the specifiedConf
and using a generated env name. - create(HasId) - Static method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
-
An helper method to create a new
BasicContainerId
based on a givenHasId
. - create(QueryRequest, QueryOptions) - Static method in class io.streamthoughts.azkarra.http.query.V1QueryBuilder
- create(String) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentFactory
-
Creates a new StreamsExecutionEnvironment from the specified name and an empty configuration.
- create(String) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Static helper that can be used to creates a new
StreamsExecutionEnvironment
instance from the specified env name and using the configuration. - create(String) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Static helper that can be used to creates a new
AzkarraConf
instance using the specified resource base name. - create(String, Conf) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironmentFactory
-
Creates a new StreamsExecutionEnvironment from the specified name and configuration.
- create(String, Conf) - Static method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Static helper that can be used to creates a new
StreamsExecutionEnvironment
instance from the specifiedConf
and env name. - create(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory
-
Creates a new StreamsExecutionEnvironment from the specified name and configuration.
- create(String, Endpoint, Endpoint, QueryRequest) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCallFactory
- create(String, Endpoint, Endpoint, QueryRequest) - Method in interface io.streamthoughts.azkarra.runtime.query.RemoteQueryCallFactory
- create(String, String, Conf) - Method in class io.streamthoughts.azkarra.runtime.StreamsExecutionEnvironmentAbstractFactory
-
Creates a new
StreamsExecutionEnvironment
for the specified type using the given name and configuration. - create(Map<String, ? extends Object>) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Static helper that can be used to creates a new
AzkarraConf
instance from the specified map. - create(Properties) - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Static helper that can be used to creates a new
AzkarraConf
instance from the specified properties. - CREATED - io.streamthoughts.azkarra.api.State
- CREATED - io.streamthoughts.azkarra.api.streams.State.Standards
-
The
KafkaStreams
instance has been created successfully. - createGson() - Static method in class io.streamthoughts.azkarra.client.openapi.JSON
- createKeyManagers(String, char[], String, String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
- createKeyStore(String, char[], String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
-
Helper method to create a new
KeyStore
. - createNewProducer(Map<String, Object>) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Creates a new
Producer
instance using the same configs that the Kafka Streams instance. - createNewProducer(Map<String, Object>) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Creates a new
Producer
instance using the same configs that the Kafka Streams instance. - createTrustManagers(String, char[], String, String) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
- Credential(String, String) - Constructor for class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator.Credential
- credentials() - Method in class io.streamthoughts.azkarra.http.security.auth.UserDetails
- Credentials - Interface in io.streamthoughts.azkarra.http.security.auth
-
Interface to hold a user credentials.
- Credentials.UnsupportedCredentialException - Exception in io.streamthoughts.azkarra.http.security.auth
- currentOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
- customHeaders() - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- CustomHealthCheckExample - Class in io.streamthoughts.examples.azkarra.healthcheck
-
Example for registering custom health-check.
- CustomHealthCheckExample() - Constructor for class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample
- CustomHealthCheckExample.MyCustomerHealthCheck - Class in io.streamthoughts.examples.azkarra.healthcheck
D
- data() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
- dataContentType - Variable in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
-
Content type of data value.
- dataContentType() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
- DateTypeAdapter() - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.DateTypeAdapter
- DateTypeAdapter(DateFormat) - Constructor for class io.streamthoughts.azkarra.client.openapi.JSON.DateTypeAdapter
- DEAD_LETTER_HEADERS_PREFIX - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- DEAD_LETTER_PRODUCER_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- DEAD_LETTER_TOPIC_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- DEAD_LETTER_TOPIC_DOC - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- DeadLetterTopicExceptionHandler - Class in io.streamthoughts.azkarra.commons.error
-
A
DeserializationExceptionHandler
implementation that write rejected records to an dead-letter-topic. - DeadLetterTopicExceptionHandler() - Constructor for class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
- DeadLetterTopicExceptionHandlerConfig - Class in io.streamthoughts.azkarra.commons.error
-
Config class for
DeadLetterTopicExceptionHandler
. - DeadLetterTopicExceptionHandlerConfig(Map<String, ?>) - Constructor for class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
-
Creates a new
DeadLetterTopicExceptionHandlerConfig
instance. - debugging(boolean) - Method in class io.streamthoughts.azkarra.client.HttpClientBuilder
-
Enable/disable debugging for this API client.
- DecorateQuery<T extends Query> - Class in io.streamthoughts.azkarra.api.query
- DecorateQuery(T) - Constructor for class io.streamthoughts.azkarra.api.query.DecorateQuery
-
Creates a new
DecorateQuery
instance. - DEFAULT - Static variable in interface io.streamthoughts.azkarra.api.components.ComponentNameGenerator
-
The default
ComponentNameGenerator
implementation. - DEFAULT - Static variable in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsFactory
- DEFAULT_ENV_NAME - Static variable in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
- DEFAULT_STREAM_THREAD_EXCEPTION_HANDLER - Static variable in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
- DefaultApplicationIdBuilder - Class in io.streamthoughts.azkarra.runtime.streams
-
The default
ApplicationIdBuilder
implementation. - DefaultApplicationIdBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.streams.DefaultApplicationIdBuilder
- DefaultAuthenticationCallbackHandler - Class in io.streamthoughts.azkarra.http.security.jaas.spi
- DefaultAuthenticationCallbackHandler() - Constructor for class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler
-
Creates a new
DefaultAuthenticationCallbackHandler
instance. - DefaultAzkarraContext - Class in io.streamthoughts.azkarra.runtime.context
-
The AzkarraContext.
- DefaultBannerPrinter - Class in io.streamthoughts.azkarra.streams.banner
- DefaultComponentDescriptorFactory - Class in io.streamthoughts.azkarra.runtime.components
- DefaultComponentDescriptorFactory() - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultComponentDescriptorFactory
-
Creates a new
DefaultComponentDescriptorFactory
instance. - DefaultComponentFactory - Class in io.streamthoughts.azkarra.runtime.components
-
The default
ComponentRegistry
implementation. - DefaultComponentFactory(ComponentDescriptorFactory) - Constructor for class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Creates a new
DefaultComponentFactory
instance. - DefaultContainerIdBuilder - Class in io.streamthoughts.azkarra.runtime.env.internal
- DefaultContainerIdBuilder() - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.DefaultContainerIdBuilder
- DefaultInteractiveQueryService - Class in io.streamthoughts.azkarra.runtime.query
-
A
DefaultInteractiveQueryService
is used to execute a query request. - DefaultInteractiveQueryService(AzkarraStreamsService) - Constructor for class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService
-
Creates a new
DefaultInteractiveQueryService
instance. - DefaultInteractiveQueryService(AzkarraStreamsService, List<QueryExecutionDelegatee>) - Constructor for class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService
-
Creates a new
DefaultInteractiveQueryService
instance. - defaultKeySerde() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets the default
Serde
configured for key. - defaultKeySerde() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets the default
Serde
configured for key. - defaultObject() - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig
- DefaultStatusAggregator - Class in io.streamthoughts.azkarra.http.health.internal
- DefaultStatusAggregator() - Constructor for class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator
-
Creates a new
DefaultStatusAggregator
instance. - DefaultStatusAggregator(List<Status>) - Constructor for class io.streamthoughts.azkarra.http.health.internal.DefaultStatusAggregator
-
Creates a new
DefaultStatusAggregator
instance using the specified status order. - DefaultStreamThreadExceptionHandlerFactory - Class in io.streamthoughts.azkarra.runtime.context
- DefaultStreamThreadExceptionHandlerFactory() - Constructor for class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
- defaultValue - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
- DelegateBlockingRecordQueue<K,V> - Class in io.streamthoughts.azkarra.api.events
-
A delegating
BlockingRecordQueue
that can be used to easily override some methods. - DelegateBlockingRecordQueue(BlockingRecordQueue<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
- DelegatingComponentFactory - Class in io.streamthoughts.azkarra.api.components
-
A delegating
ComponentFactory
implementation. - DelegatingComponentFactory(ComponentFactory) - Constructor for class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- DelegatingConf - Class in io.streamthoughts.azkarra.api.config
-
Delegates to a
Conf
. - DelegatingConf(Conf) - Constructor for class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Creates a new
DelegatingConf
instance. - DelegatingExecutionEnvironmentAware<T> - Class in io.streamthoughts.azkarra.runtime.context.internal
-
A delegating
StreamsExecutionEnvironmentAware
implementation. - DelegatingUncaughtExceptionHandler - Class in io.streamthoughts.azkarra.api.streams.errors
-
This class can be used to delegate
Thread.UncaughtExceptionHandler
exception handling to an a givenStreamThreadExceptionHandler
implementation. - DelegatingUncaughtExceptionHandler(KafkaStreamsContainer, StreamThreadExceptionHandler) - Constructor for class io.streamthoughts.azkarra.api.streams.errors.DelegatingUncaughtExceptionHandler
- deleteUsersByName(String) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
- DENIED - io.streamthoughts.azkarra.http.security.authorizer.AuthorizationResult
- describe() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Describes the local
KafkaStreams
instance. - describe() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Gets a serializable view of this
StreamsExecutionEnvironment
instance. - describe() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Describes the local
KafkaStreams
instance. - describeAllEnvironments() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets all existing streams environments.
- describeAllEnvironments() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets all existing streams environments.
- describeEnvironmentByName(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets the
StreamsExecutionEnvironment
for the specified name. - describeEnvironmentByName(String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets the
StreamsExecutionEnvironment
for the specified name. - description - Variable in class io.streamthoughts.azkarra.api.Executed
- description - Variable in class io.streamthoughts.azkarra.client.openapi.ServerConfiguration
- description - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
- description() - Method in annotation type io.streamthoughts.azkarra.api.annotations.TopologyInfo
-
Gets the
Topology
description. - description() - Method in class io.streamthoughts.azkarra.api.model.Metric
- description() - Method in class io.streamthoughts.azkarra.api.providers.TopologyDescriptor
- description() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
- description() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
- description() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
- description() - Method in class io.streamthoughts.azkarra.streams.config.loader.internal.TopologyConfig
-
Gets the user-defined topology description.
- description(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
- description(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
- descriptionOrElseGet(String) - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
- descriptor() - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent
-
Gets the descriptor for the component.
- deserialize(byte[]) - Method in class io.streamthoughts.azkarra.http.serialization.json.SpecificJsonSerdes
-
Deserialize data from a byte array into a value or object.
- deserialize(byte[]) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given bytes array.
- deserialize(byte[]) - Method in interface io.streamthoughts.azkarra.serialization.Serdes
-
Deserialize data from a byte array into a value or object.
- deserialize(byte[], Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given bytes array.
- deserialize(JsonNode, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given bytes array.
- deserialize(InputStream) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given
InputStream
. - deserialize(InputStream, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given
InputStream
. - deserialize(String, byte[]) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer
-
{@inheritDoc
- deserialize(String, byte[]) - Static method in class io.streamthoughts.azkarra.http.serialization.json.JsonQuerySerde
- deserialize(String, Class<T>) - Method in class io.streamthoughts.azkarra.serialization.json.Json
-
An helper method that can be used to deserialize a given
InputStream
. - deserialize(String, Type) - Method in class io.streamthoughts.azkarra.client.openapi.JSON
-
Deserialize the given JSON string to Java object.
- deserialize(String, Headers, byte[]) - Method in class io.streamthoughts.azkarra.commons.error.SafeDeserializer
-
{@inheritDoc
- deserialize(Response, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Deserialize response body to Java object, according to the return type and the Content-Type response header.
- DigestPasswordCredentials - Class in io.streamthoughts.azkarra.http.security.auth
- DigestPasswordCredentials(String, String) - Constructor for class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
-
Creates a new
PasswordCredentials
instance. - disableHeadlessMode() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Disables the headless mode.
- disableRestExtensions() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Disables support for rest extensions.
- disableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Disables SSL.
- dispose() - Method in interface io.streamthoughts.azkarra.commons.rocksdb.internal.ResourceDisposer
-
Release the memory shared resource.
- DistributedQueryCall<K,V> - Class in io.streamthoughts.azkarra.runtime.query
- DistributedQueryCall(LocalExecutableQuery<K, V>, LocalKafkaStreamsContainer, RemoteQueryCallFactory) - Constructor for class io.streamthoughts.azkarra.runtime.query.DistributedQueryCall
-
Creates a new
DecorateQuery
instance. - DistributedQueryExecutionDelegatee - Class in io.streamthoughts.azkarra.runtime.query
- DistributedQueryExecutionDelegatee(RemoteQueryCallFactory) - Constructor for class io.streamthoughts.azkarra.runtime.query.DistributedQueryExecutionDelegatee
-
Creates a new
DistributedQueryExecutionDelegatee
instance. - Double() - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
- Double(Double) - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
- down() - Method in class io.streamthoughts.azkarra.http.health.Health.Builder
-
Sets the status for the
Health
indicator to be built toStatus.DOWN
. - DOWN - Static variable in class io.streamthoughts.azkarra.http.health.Status
- downloadFileFromResponse(Response) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Download file from the given response.
- drainTo(Collection<? super KV<K, V>>) - Method in class io.streamthoughts.azkarra.api.events.BasicBlockingRecordQueue
- drainTo(Collection<? super KV<K, V>>) - Method in interface io.streamthoughts.azkarra.api.events.BlockingRecordQueue
- drainTo(Collection<? super KV<K, V>>) - Method in class io.streamthoughts.azkarra.api.events.DelegateBlockingRecordQueue
- dropHeadOnLimitReached() - Static method in class io.streamthoughts.azkarra.api.events.LimitHandlers
- DTF - Static variable in interface io.streamthoughts.azkarra.api.time.Time
- duration(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
E
- Eager - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
Annotation that can be used on any class or method directly or indirectly annotated with
Component
. - Either<L,R> - Class in io.streamthoughts.azkarra.api.monad
-
Simple
Either
monad type. - Either.Left<L,R> - Class in io.streamthoughts.azkarra.api.monad
- Either.LeftProjection<L,R> - Class in io.streamthoughts.azkarra.api.monad
- Either.Right<L,R> - Class in io.streamthoughts.azkarra.api.monad
- Either.RightProjection<L,R> - Class in io.streamthoughts.azkarra.api.monad
- EmbeddedHttpServer - Interface in io.streamthoughts.azkarra.api.server
-
Default interface to provide an embedded http-server.
- EmbeddedHttpServerProvider - Interface in io.streamthoughts.azkarra.api.spi
-
Default Service Provider interface to provides an
EmbeddedHttpServer
implementation. - empty() - Static method in interface io.streamthoughts.azkarra.api.config.Conf
-
Static helper that can be used to creates a new empty
Conf
instance. - empty() - Static method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
- empty() - Static method in class io.streamthoughts.azkarra.client.authentication.BasicAuthAuthenticator.Credential
- empty() - Static method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Static helper that can be used to creates a new empty
AzkarraConf
instance. - EMPTY - Static variable in interface io.streamthoughts.azkarra.api.config.Conf
- EMPTY - Static variable in class io.streamthoughts.azkarra.api.streams.KafkaStreamsMetadata
- EmptyConf - Class in io.streamthoughts.azkarra.api.config
- EmptyConf() - Constructor for class io.streamthoughts.azkarra.api.config.EmptyConf
- EmptyQueryCall<K,V> - Class in io.streamthoughts.azkarra.runtime.query
- EmptyQueryCall(Query) - Constructor for class io.streamthoughts.azkarra.runtime.query.EmptyQueryCall
-
Creates a new
DecorateQuery
instance. - ENABLE_WAIT_FOR_TOPICS__CONFIG - Static variable in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig
-
wait.for.topics.enable
- EnableAutoConfig - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
- EnableAutoStart - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
- EnableEmbeddedHttpServer - Annotation Type in io.streamthoughts.azkarra.streams.autoconfigure.annotations
- enableHeadlessMode() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Enables the headless mode.
- enableRestExtensions() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Enables support for rest extensions.
- enableSsl() - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Enables the SSL.
- enableUI(boolean) - Method in class io.streamthoughts.azkarra.http.ServerConfigBuilder
-
Sets if the Web UI must be enable.
- endingOffset(Long) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
- endpoint() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets the endpoint configured for this
KafkaStreams
instance. - endpoint() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsInstance
- endpoint() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets the endpoint configured for this
KafkaStreams
instance. - Endpoint - Class in io.streamthoughts.azkarra.api.util
- Endpoint(String, int) - Constructor for class io.streamthoughts.azkarra.api.util.Endpoint
-
Creates a new
Endpoint
instance. - enumValues - Variable in class io.streamthoughts.azkarra.client.openapi.ServerVariable
- env(String) - Static method in class io.streamthoughts.azkarra.api.components.Restriction
- environment - Variable in class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
- environment() - Method in class io.streamthoughts.azkarra.api.streams.KafkaStreamsApplication
- environment() - Method in annotation type io.streamthoughts.azkarra.streams.autoconfigure.annotations.EnableAutoStart
- ENVIRONMENT_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
- ENVIRONMENT_DEFAULT_NAME - Static variable in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
- ENVIRONMENT_NAME_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
- ENVIRONMENT_STREAMS_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
- ENVIRONMENT_TYPE_CONFIG - Static variable in class io.streamthoughts.azkarra.streams.config.loader.internal.EnvironmentConfig
- EnvironmentAwareComponentSupplier<T> - Class in io.streamthoughts.azkarra.runtime.env.internal
- EnvironmentAwareComponentSupplier(Supplier<T>) - Constructor for class io.streamthoughts.azkarra.runtime.env.internal.EnvironmentAwareComponentSupplier
-
Creates a new
EnvironmentAwareComponentSupplier
instance. - EnvironmentConfig - Class in io.streamthoughts.azkarra.streams.config.loader.internal
-
Class which is used to configure a
StreamsExecutionEnvironment
instance. - EnvironmentConfig.Reader - Class in io.streamthoughts.azkarra.streams.config.loader.internal
- EnvironmentRequestBody - Class in io.streamthoughts.azkarra.http.data
- EnvironmentRequestBody(String, String, Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.http.data.EnvironmentRequestBody
- EnvironmentsConfigEntryLoader - Class in io.streamthoughts.azkarra.streams.config.loader
- EnvironmentsConfigEntryLoader() - Constructor for class io.streamthoughts.azkarra.streams.config.loader.EnvironmentsConfigEntryLoader
-
Creates a new
EnvironmentsConfigEntryLoader
instance. - equals(Object) - Method in class io.streamthoughts.azkarra.api.ApplicationId
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.Restriction
- equals(Object) - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
- equals(Object) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
- equals(Object) - Method in class io.streamthoughts.azkarra.api.errors.Error
- equals(Object) - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
- equals(Object) - Method in class io.streamthoughts.azkarra.api.model.KV
- equals(Object) - Method in class io.streamthoughts.azkarra.api.model.Metric
- equals(Object) - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
- equals(Object) - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
- equals(Object) - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
- equals(Object) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.QueryOptions
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- equals(Object) - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsetsState
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerThreadKey
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.consumer.OffsetAndTimestamp
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.StateChangeEvent
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
- equals(Object) - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
- equals(Object) - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
- equals(Object) - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
- equals(Object) - Method in class io.streamthoughts.azkarra.api.util.Endpoint
- equals(Object) - Method in class io.streamthoughts.azkarra.api.util.Version
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
- equals(Object) - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
- equals(Object) - Method in class io.streamthoughts.azkarra.http.health.Health
- equals(Object) - Method in class io.streamthoughts.azkarra.http.health.Status
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
- equals(Object) - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
- equals(Object) - Method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
- equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
- equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
- equals(Object) - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata
- equals(Object) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ExternalComponent
- error(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- Error - Class in io.streamthoughts.azkarra.api.errors
- Error(String) - Constructor for class io.streamthoughts.azkarra.api.errors.Error
- Error(Throwable) - Constructor for class io.streamthoughts.azkarra.api.errors.Error
- ERROR - io.streamthoughts.azkarra.api.query.result.QueryStatus
-
Unexpected error happens while querying store.
- ERROR - io.streamthoughts.azkarra.api.streams.State.Standards
- ERROR - io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
- ERROR_APPLICATION_ID - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_EXCEPTION_CLASS_NAME - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_EXCEPTION_MESSAGE - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_EXCEPTION_STACKTRACE - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_RECORD_OFFSET - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_RECORD_PARTITION - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_RECORD_TOPIC - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ERROR_TIMESTAMP - Static variable in class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- ErrorMessage - Class in io.streamthoughts.azkarra.http.data
-
The error message response object.
- ErrorMessage(int, String, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage
-
Creates a new
ErrorMessage
instance. - ErrorMessage(int, String, String, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage
-
Creates a new
ErrorMessage
instance. - ErrorMessage(int, String, Throwable, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage
-
Creates a new
ErrorMessage
instance. - ErrorMessage(int, Throwable, String) - Constructor for class io.streamthoughts.azkarra.http.data.ErrorMessage
-
Creates a new
ErrorMessage
instance. - ErrorResultSet - Class in io.streamthoughts.azkarra.api.query.result
- ErrorResultSet(String, boolean, QueryError) - Constructor for class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
- ErrorResultSet(String, boolean, List<QueryError>) - Constructor for class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
- errors(List<V1Error>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
- escapeString(String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Escape the given string to be used as URL query value.
- EventStream<K,V> - Class in io.streamthoughts.azkarra.api.events
-
A typed stream of events backed by a
BlockingRecordQueue
. - EventStream(String, BlockingRecordQueue<K, V>) - Constructor for class io.streamthoughts.azkarra.api.events.EventStream
-
Creates a new
EventStream
instance. - EventStream.Builder - Class in io.streamthoughts.azkarra.api.events
- EventStreamConnectionCallback - Class in io.streamthoughts.azkarra.http.sse
- EventStreamConnectionCallback(AzkarraStreamsService, Json) - Constructor for class io.streamthoughts.azkarra.http.sse.EventStreamConnectionCallback
-
Creates a new
EventStreamConnectionCallback
instance. - EventStreamPipe<K,V> - Interface in io.streamthoughts.azkarra.api.events
-
The EventStreamPipe is used to attached or detach an object that will be responsible to consume records send to an
EventStream
. - EventStreamProvider - Interface in io.streamthoughts.azkarra.api.events
-
EventStreamsProvider.
- EventStreamPublisher<K,V> - Interface in io.streamthoughts.azkarra.api.events.reactive
-
The main publisher interface to subscribe to a specific streams of key-value records.
- eventStreams() - Method in interface io.streamthoughts.azkarra.api.events.EventStreamProvider
-
Returns the list of
EventStream
- eventStreams() - Method in class io.streamthoughts.azkarra.api.events.EventStreamSupport
-
Returns the list of
EventStream
- eventStreams() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier.ClassLoaderAwareTopologyProvider
-
Returns the list of
EventStream
- EventStreamSupport - Class in io.streamthoughts.azkarra.api.events
-
Base class for
EventStreamProvider
. - EventStreamSupport() - Constructor for class io.streamthoughts.azkarra.api.events.EventStreamSupport
- ExactlyOnce - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
This annotation can be used to automatically set the streams property
processing.guarantee
toexactly_once
. - exception() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets the last observed exception thrown the
KafkaStreams
instance. - exception() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets the last observed exception thrown the
KafkaStreams
instance. - exception(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
- ExceptionDefaultHandler - Class in io.streamthoughts.azkarra.http.error
-
An
HttpHandler
which used for catching any exception thrown during request execution. - ExceptionDefaultHandler() - Constructor for class io.streamthoughts.azkarra.http.error.ExceptionDefaultHandler
- ExceptionDefaultResponseListener - Class in io.streamthoughts.azkarra.http.error
- ExceptionDefaultResponseListener() - Constructor for class io.streamthoughts.azkarra.http.error.ExceptionDefaultResponseListener
- ExceptionHeader - Class in io.streamthoughts.azkarra.commons.error
-
The default record-headers added to record write to the dead-letter-topic.
- ExceptionHeader() - Constructor for class io.streamthoughts.azkarra.commons.error.ExceptionHeader
- exceptionType() - Method in class io.streamthoughts.azkarra.api.monad.Retry
- ExchangeHelper - Class in io.streamthoughts.azkarra.http
-
Simple class to wrap
HttpServerExchange
instance. - ExchangeHelper() - Constructor for class io.streamthoughts.azkarra.http.ExchangeHelper
- excludeByName(String) - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- excludeSecondary() - Static method in class io.streamthoughts.azkarra.api.components.qualifier.Qualifiers
- execute() - Method in class io.streamthoughts.azkarra.api.streams.internal.InternalStreamsLifeCycleChain
-
Executes the operation on the current
KafkaStreams
instance. - execute() - Method in interface io.streamthoughts.azkarra.api.StreamsLifecycleChain
-
Executes the operation on the current
KafkaStreams
instance. - execute(LocalStoreAccessProvider) - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueCountQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueGetRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchKeyRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.SessionFetchQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueGetRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchKeyRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowFetchTimeRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowGetAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchKeyRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowFetchTimeRangeQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.internal.WindowGetAllQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQuery
-
Executes this query to the specified KafkaStreams application.
- execute(LocalStoreAccessProvider, long) - Method in class io.streamthoughts.azkarra.api.query.LoggingFailureLocalExecutableQuery
-
Executes this query to the specified KafkaStreams application.
- execute(QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall
-
Executes this
QueryCall
. - execute(QueryOptions) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall
-
Executes this
QueryCall
. - execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DistributedQueryCall
-
Executes this
QueryCall
. - execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.EmptyQueryCall
-
Executes this
QueryCall
. - execute(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.LocalQueryCall
-
Executes this
QueryCall
. - execute(KafkaStreamsContainer, QueryRequest, QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DistributedQueryExecutionDelegatee
- execute(KafkaStreamsContainer, QueryRequest, QueryOptions) - Method in interface io.streamthoughts.azkarra.runtime.query.QueryExecutionDelegatee
- execute(StreamsLifecycleInterceptor, StreamsLifecycleChain) - Method in interface io.streamthoughts.azkarra.api.streams.internal.InternalStreamsLifeCycleChain.Callback
- execute(String, QueryRequest, QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.InteractiveQueryService
-
Executes an interactive query for the specified streams application.
- execute(String, QueryRequest, QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.DefaultInteractiveQueryService
-
Executes an interactive query for the specified streams application.
- execute(Call) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
- execute(Call, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Execute HTTP call and deserialize the HTTP response body into the given return type.
- executeAsync(QueryOptions) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(QueryOptions) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(QueryOptions) - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in interface io.streamthoughts.azkarra.api.query.QueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in class io.streamthoughts.azkarra.http.query.RestApiQueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(QueryOptions, Consumer<QueryResult<K, V>>) - Method in class io.streamthoughts.azkarra.runtime.query.BaseAsyncQueryCall
-
Executes this
QueryCall
asynchronously. - executeAsync(Call, ApiCallback<T>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
- executeAsync(Call, Type, ApiCallback<T>) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Execute HTTP call asynchronously.
- executed - Variable in class io.streamthoughts.azkarra.runtime.AbstractTopologyStreamsExecution
- Executed - Class in io.streamthoughts.azkarra.api
-
Executed class is used to describe a
Topology
instance to be executed. - Executed() - Constructor for class io.streamthoughts.azkarra.api.Executed
-
Creates a new
Executed
instance. - Executed(Executed) - Constructor for class io.streamthoughts.azkarra.api.Executed
- ExecutionException - Exception in io.streamthoughts.azkarra.api.errors
- ExecutionException(Throwable) - Constructor for exception io.streamthoughts.azkarra.api.errors.ExecutionException
- exists() - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
- exists() - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
- extensions() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
- ExternalComponent - Class in io.streamthoughts.azkarra.streams.components.isolation
- ExternalComponentClassLoader - Interface in io.streamthoughts.azkarra.api.components
- extractAlias(Class<?>) - Method in interface io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.ClassAliasExtractor
- extractAlias(Class<?>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator.DropClassNameSuffixExtractor
F
- factory - Variable in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- factory - Variable in class io.streamthoughts.azkarra.api.Executed
- factory() - Method in class io.streamthoughts.azkarra.runtime.streams.topology.InternalExecuted
- Factory - Annotation Type in io.streamthoughts.azkarra.api.annotations
-
An annotation that can be used by any class having a no-arg constructor to provide one or many other component implementation.
- failable(CheckedSupplier<V, E>) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
- failure(Throwable) - Static method in interface io.streamthoughts.azkarra.api.monad.Try
- failure(List<V1QueryErrorResultSet>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- FATAL_ERRORS_CONFIG - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- FATAL_ERRORS_DOC - Static variable in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
- fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
- fetch() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
- fetch(V1QueryFetchParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
- fetch(V1QueryFetchParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- FETCH - io.streamthoughts.azkarra.api.query.StoreOperation
- FETCH_ALL - io.streamthoughts.azkarra.api.query.StoreOperation
- FETCH_KEY_RANGE - io.streamthoughts.azkarra.api.query.StoreOperation
- FETCH_TIME_RANGE - io.streamthoughts.azkarra.api.query.StoreOperation
- fetchAll() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
- fetchAll() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
- fetchAll(V1QueryFetchAllParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
- fetchAll(V1QueryFetchAllParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.SessionQueryBuilder
- fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
- fetchKeyRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
- fetchKeyRange(V1QueryFetchKeyRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
- fetchKeyRange(V1QueryFetchKeyRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- fetchLogEndOffsetsFor(Consumer<K, V>, Collection<TopicPartition>) - Static method in class io.streamthoughts.azkarra.api.streams.consumer.LogOffsetsFetcher
- fetchLogStartOffsetsFor(Consumer<K, V>, Collection<TopicPartition>) - Static method in class io.streamthoughts.azkarra.api.streams.consumer.LogOffsetsFetcher
- fetchTimeRange() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedWindowQueryBuilder
- fetchTimeRange() - Method in class io.streamthoughts.azkarra.api.query.internal.WindowQueryBuilder
- fetchTimeRange(V1QueryFetchTimeRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
- fetchTimeRange(V1QueryFetchTimeRangeParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.LatestVersionQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.PrimaryQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.SecondaryQualifier
- filter(Class<T>, Stream<ComponentDescriptor<T>>) - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
- filterByGroup(String) - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
- filterByGroupAndMetricName(String, String) - Static method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer.KafkaMetricFilter
- filterByName(Collection<T>, String) - Static method in interface io.streamthoughts.azkarra.api.model.HasName
-
An helper method to filter a
Collection
ofHasName
object based on its name. - findAllAnnotations(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
- findAllAnnotationsByType(Class<?>, Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
- findAllAnnotationsByType(Method, Class<T>) - Static method in class io.streamthoughts.azkarra.api.util.AnnotationResolver
- findAllDescriptorsByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified alias. - findAllDescriptorsByClass(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByClass(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findAllDescriptorsByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds all
ComponentDescriptor
registered for the specified type. - findAllEndpointsForStore(String) - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessProvider
- findAllEndpointsForStore(String) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
- findApplicationIdBuilder(Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory
- findComponentByRestriction(Class<T>, Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.components.RestrictedComponentFactory
-
Finds a component for the given type that is available for the given config and restriction.
- findDescriptorByAlias(String) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByAlias(String, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByAlias(String, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByAlias(String, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByAlias(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByAlias(String, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByClass(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByClass(Class<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByClass(Class<T>, ComponentConditionalContext) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type. - findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConditionalDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByClass(Class<T>, ComponentConditionalContext, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByClass(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentDescriptorRegistry
-
Finds a
ComponentDescriptor
for the specified type and options. - findDescriptorByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- findDescriptorByClass(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Finds a
ComponentDescriptor
for the specified type and options. - findFirst(Class<T>, Stream<ComponentDescriptor<T>>) - Method in interface io.streamthoughts.azkarra.api.components.Qualifier
- findMetadataForStoreAndKey(String, K, Serializer<K>) - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessProvider
- findMetadataForStoreAndKey(String, K, Serializer<K>) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
- findStreamThreadExceptionHandler(Conf, Restriction) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironmentFactory
- findUserByName(String) - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
- findUserByName(String) - Method in interface io.streamthoughts.azkarra.http.security.auth.UsersIdentityManager
- flatMap(Function<? super B, Reader<A, ? extends BB>>) - Method in class io.streamthoughts.azkarra.api.monad.Reader
- flatMap(Function<? super L, Either<LL, R>>) - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
- flatMap(Function<? super R, Either<L, RR>>) - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
- flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
- flatMap(Function<? super V, Try<B>>) - Method in interface io.streamthoughts.azkarra.api.monad.Try
- flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
- flatMap(Function<? super V, Try<B>>) - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
- flatMap(Function<Tuple<L, R>, Tuple<LL, RR>>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
- Float() - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
- Float(Float) - Static method in class io.streamthoughts.azkarra.commons.error.SafeSerdes
- fold(Function<L, LL>, Function<R, RR>) - Method in class io.streamthoughts.azkarra.api.monad.Tuple
- fold(Function<L, T>, Function<R, T>) - Method in class io.streamthoughts.azkarra.api.monad.Either
- forAlias(String) - Static method in exception io.streamthoughts.azkarra.api.errors.NoSuchComponentException
- forAliasAndQualifier(String, Qualifier) - Static method in exception io.streamthoughts.azkarra.api.errors.NoSuchComponentException
- formatStackTrace(Throwable) - Static method in class io.streamthoughts.azkarra.api.util.Utils
- from(TopologyDescriptor<TopologyProvider>) - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta.Builder
- fromValue(String) - Static method in enum io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum
- fromValue(String) - Static method in enum io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
- FutureCollectors - Class in io.streamthoughts.azkarra.api.util
G
- generate(ComponentDescriptor<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentNameGenerator
-
Generates a component name for the specified component descriptor.
- generateNext() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.SequentialSubscriptionIdGenerator
-
Generates the next
SubscriptionId
- generateNext() - Method in interface io.streamthoughts.azkarra.api.events.reactive.internal.SubscriptionIdGenerator
-
Generates the next
SubscriptionId
- GenericQueryParams - Class in io.streamthoughts.azkarra.api.query
- GenericQueryParams() - Constructor for class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Creates a new
GenericQueryParams
instance. - GenericQueryParams(Map<String, Object>) - Constructor for class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Creates a new
GenericQueryParams
instance. - GenericRecordSerializer - Class in io.streamthoughts.azkarra.http.serialization.json
- GenericRecordSerializer() - Constructor for class io.streamthoughts.azkarra.http.serialization.json.GenericRecordSerializer
- get() - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
- get() - Method in class io.streamthoughts.azkarra.api.config.Property
- get() - Method in class io.streamthoughts.azkarra.api.config.RocksDBConfig
- get() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
- get() - Method in interface io.streamthoughts.azkarra.api.events.reactive.internal.SubscriptionId
- get() - Method in interface io.streamthoughts.azkarra.api.monad.CheckedSupplier
- get() - Method in class io.streamthoughts.azkarra.api.monad.Either.LeftProjection
- get() - Method in class io.streamthoughts.azkarra.api.monad.Either.RightProjection
- get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
- get() - Method in interface io.streamthoughts.azkarra.api.monad.Try
- get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
- get() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
- get() - Method in class io.streamthoughts.azkarra.api.monad.Validator
- get() - Method in class io.streamthoughts.azkarra.api.query.internal.KeyValueQueryBuilder
- get() - Method in class io.streamthoughts.azkarra.api.query.internal.TimestampedKeyValueQueryBuilder
- get() - Method in class io.streamthoughts.azkarra.api.query.LocalStoreAccessor
- get() - Method in interface io.streamthoughts.azkarra.api.query.LocalStoreAccessor.StoreSupplier
- get() - Method in interface io.streamthoughts.azkarra.http.security.auth.GrantedAuthority
-
Gets the string representation of this
GrantedAuthority
. - get() - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
-
Gets the string representation of this
GrantedAuthority
. - get() - Method in class io.streamthoughts.azkarra.runtime.components.BasicComponentFactory
- get() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultStreamThreadExceptionHandlerFactory
- get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareApplicationIdBuilderSupplier
- get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareKafkaStreamsFactorySupplier
- get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareLifecycleInterceptorSupplier
- get() - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier
- get() - Method in class io.streamthoughts.azkarra.runtime.modules.InteractiveQueryServiceModule
- get() - Method in class io.streamthoughts.azkarra.streams.components.ReflectMethodComponentSupplier
- get() - Method in class io.streamthoughts.examples.azkarra.dependency.ComplexWordCountTopologyModule
- get(AzkarraContext) - Method in interface io.streamthoughts.azkarra.api.spi.EmbeddedHttpServerProvider
-
Creates an returns the embedded HTTP server.
- get(AzkarraContext) - Method in class io.streamthoughts.azkarra.http.UndertowEmbeddedServerProvider
-
Creates an returns the embedded HTTP server.
- get(Conf) - Method in interface io.streamthoughts.azkarra.api.components.GettableComponent
-
Gets the instance of type
GettableComponent
, which may be shared or independent. - get(Conf) - Method in class io.streamthoughts.azkarra.api.config.ConfigurableSupplier
- get(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareGettableComponentSupplier
- get(Conf) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareTopologySupplier
- get(StreamsExecutionEnvironment<?>, Conf) - Method in class io.streamthoughts.azkarra.runtime.env.internal.EnvironmentAwareComponentSupplier
- get(V1QueryGetParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
- get(V1QueryGetParams) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- get(String) - Static method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
- GET - io.streamthoughts.azkarra.api.query.StoreOperation
- getActiveTasks() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get activeTasks
- getAdminClient() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets a shared
AdminClient
instance for thisKafkaStreams
instance. - getAdminClient() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets a shared
AdminClient
instance for thisKafkaStreams
instance. - getAdminClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get adminClientId
- getAdvertisedServer() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
-
Get the server name that will be included in monitoring events.
- getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentAliasesGenerator
-
Gets unique aliases for the specified
SimpleComponentDescriptor
descriptor. - getAliasesFor(ComponentDescriptor, Collection<? extends ComponentDescriptor>) - Method in class io.streamthoughts.azkarra.runtime.components.ClassComponentAliasesGenerator
-
Gets unique aliases for the specified
SimpleComponentDescriptor
descriptor. - getAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
-
Get all
- getAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get all
- getAllClassLoaders() - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
- getAllClassLoaders() - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllClassLoaders() - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
- getAllComponentProviders(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponentProviders(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllComponentProviders(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllComponents(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllComponents(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllComponents(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getAllComponents(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets all instances, which may be shared or independent, for the specified type.
- getAllEnvironments() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets all
StreamsExecutionEnvironment
registered to this context. - getAllEnvironments() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets all
StreamsExecutionEnvironment
registered to this context. - getAllPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.commons.streams.StateRestoreInfo
-
Gets the state of the TopicPartition being restored.
- getAllStatus(Collection<Health>) - Static method in interface io.streamthoughts.azkarra.http.health.StatusAggregator
-
Static helper that can be used for retrieving only status from a list of
Health
instances. - getAllStreamsContainersById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Returns all the
KafkaStreamsContainer
for the specifiedapplication.id
. - getAllStreamsContainersById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
-
Returns all the
KafkaStreamsContainer
for the specifiedapplication.id
. - getAllSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
- getAllTopologies() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets the list of all topologies.
- getAllTopologies() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
- getApiClient() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
- getApiClient() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
- getApiKey() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- getApiKeyPrefix() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- getApplicationById(ApplicationId) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Gets the
KafkaStreamsApplication
for the specifiedapplication.id
- getApplicationById(ApplicationId) - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Gets the
KafkaStreamsApplication
for the specifiedapplication.id
- getApplicationIdBuilder() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Gets the
ApplicationIdBuilder
. - getApplicationIdBuilder() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Gets the
ApplicationIdBuilder
. - getApplicationIds() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Returns all {
ApplicationId
for active Kafka Streams applications. - getApplicationIds() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Returns all {
ApplicationId
for active Kafka Streams applications. - getAsMap() - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Gets all query params as
Map
. - getAsMap() - Method in interface io.streamthoughts.azkarra.api.query.QueryParams
-
Gets all query params as
Map
. - getAssignments() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
-
Get assignments
- getAuthentication() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext
-
Gets the currently authenticated principal.
- getAuthentication() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext
-
Gets the currently authenticated principal.
- getAuthentication() - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.AuthenticationCallback
- getAuthentication(String) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get authentication for the given name.
- getAuthenticationContext() - Static method in class io.streamthoughts.azkarra.http.security.auth.AuthenticationContextHolder
-
Gets the
AuthenticationContext
attached to the current thread of execution. - getAuthenticationMechanism() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthenticationPrincipalBuilder() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthenticationRealm() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthenticationRestricted() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthenticationRoles() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthentications() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get authentications (key: authentication name, value: authentication).
- getAuthenticationUsers() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAuthorizationManager() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getAutoCreateTopicsConfigs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
Get additional properties that should be should be set for creating topics.
- getAutoCreateTopicsNumPartition() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
Get the default number of partitions that should be set for creating topics.
- getAutoCreateTopicsReplicationFactor() - Method in class io.streamthoughts.azkarra.runtime.interceptors.AutoCreateTopicsInterceptorConfig
-
Get the default replication factor that should be should be set for creating topics.
- getAzkarraVersion() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
-
Version of Azkarra Framework
- getBasePath() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get base path
- getBearerToken() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBearerAuth
-
Gets the token, which together with the scheme, will be sent as the value of the Authorization header.
- getBool(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getBoolean(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as an boolean.
- getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as an boolean.
- getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as an boolean.
- getBoolean(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as an boolean.
- getBoolean(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as an boolean.
- getBranch() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
-
Branch of Azkarra Framework
- getBytes(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getCertificate() - Method in class io.streamthoughts.azkarra.http.security.auth.SSLClientAuthentication
- getClass(Class<T>) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as an instances of type
ConfEntry
. - getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.AbstractConf
-
Gets a required parameter as an instances of type
Conf
. - getClass(String, Class<T>) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as an instances of type
Conf
. - getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as an instances of type
Conf
. - getClass(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as an instances of type
Conf
. - getClasses(Class<T>) - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
-
Gets value as a list of instances of type
ConfEntry
. - getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.AbstractConf
-
Gets a required parameter as a list of instances of type
Conf
. - getClasses(String, Class<T>) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a list of instances of type
Conf
. - getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a list of instances of type
Conf
. - getClasses(String, Class<T>) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a list of instances of type
Conf
. - getClassLoader() - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
- getCleanup() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
-
Get cleanup
- getClientAddress() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext
-
Gets the client address.
- getClientAddress() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext
-
Gets the client address.
- getClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
-
Get clientId
- getCode() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException
-
Get the HTTP status code.
- getCode() - Method in class io.streamthoughts.azkarra.http.health.Status
- getCommitId() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
-
Commit id of Azkarra Framework
- getCommittedOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get committedOffset
- getCommittedTimestamp() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get committedTimestamp
- getComponent() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext
- getComponent(Class<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getComponent(Class<T>, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getComponent(Class<T>, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getComponent(String, Conf) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.ContextAwareComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getComponent(String, Conf, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets the internal
ComponentFactory
. - getComponentFactory() - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule
-
Gets the internal
ComponentFactory
. - getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext
-
Get the
ComponentFactory
that holds the component descriptor should the condition match. - getComponentFactory() - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets the internal
ComponentFactory
. - getComponentFactory() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets the internal
ComponentFactory
. - getComponentProvider(Class<T>, Qualifier<T>) - Method in interface io.streamthoughts.azkarra.api.components.ComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getComponentProvider(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.api.components.DelegatingComponentFactory
- getComponentProvider(Class<T>, Qualifier<T>) - Method in class io.streamthoughts.azkarra.runtime.components.DefaultComponentFactory
-
Gets an instance, which may be shared or independent, for the specified type.
- getConfAsMap() - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Converts this
Conf
into a path-value map. - getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Converts this
Conf
into a path-value map. - getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Converts this
Conf
into a path-value map. - getConfAsMap() - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Converts this
Conf
into a path-value map. - getConfAsMap() - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Converts this
Conf
into a path-value map. - getConfAsProperties() - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Converts this
Conf
into a properties. - getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Converts this
Conf
into a properties. - getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Converts this
Conf
into a properties. - getConfAsProperties() - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Converts this
Conf
into a properties. - getConfAsProperties() - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Converts this
Conf
into a properties. - getConfig() - Method in interface io.streamthoughts.azkarra.api.components.condition.ConditionContext
-
Get the configuration that was passed to get the component instance.
- getConfig() - Method in class io.streamthoughts.azkarra.http.data.GetContextResponse
- getConfig() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getConfiguration() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Returns the global context streamsConfig of this
AzkarraContext
instance. - getConfiguration() - Method in class io.streamthoughts.azkarra.api.components.BaseComponentModule
-
Gets the configuration used by this component factory.
- getConfiguration() - Method in interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory
-
Gets the configuration used by this component factory.
- getConfiguration() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Gets this environment configuration.
- getConfiguration() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Returns the global context streamsConfig of this
AzkarraContext
instance. - getConfiguration() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Gets this environment configuration.
- getConfiguration() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Gets the configuration for this
AzkarraApplication
. - getConnectTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get connection timeout (in milliseconds).
- getConsumedOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get consumedOffset
- getConsumedTimestamp() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get consumedTimestamp
- getConsumers() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
-
Get consumers
- getContainerById(ContainerId) - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Gets a
KafkaStreamsContainer
for the specified id. - getContainerIds() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Returns all
ContainerId
for active Kafka Streams applications. - getContainerIds() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Returns all
ContainerId
for active Kafka Streams applications. - getContainers() - Method in interface io.streamthoughts.azkarra.api.StreamsExecutionEnvironment
-
Returns all containers for active Kafka Streams applications.
- getContainers() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Returns all containers for active Kafka Streams applications.
- getContext() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Gets the
AzkarraContext
. - getContextConfig() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets the configuration of
AzkarraContext
. - getContextConfig() - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
-
Gets the configuration of
AzkarraContext
. - GetContextResponse - Class in io.streamthoughts.azkarra.http.data
- GetContextResponse(Conf) - Constructor for class io.streamthoughts.azkarra.http.data.GetContextResponse
-
Creates a new
GetContextResponse
instance. - getCount() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
-
Get count
- getCount() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get count
- getCredentials() - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication
-
The
Credentials
of the user to authenticate. - getCredentials() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication
-
The
Credentials
of the user to authenticate. - getCredentials() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
- getCurrentOffset() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- getCurrentOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
-
Get currentOffset
- getCurrentVersion() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
-
get the API current version
- getCurrentVersionAsync(ApiCallback<Version>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
-
(asynchronously) get the API current version
- getCurrentVersionCall(ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
-
Build call for getCurrentVersion
- getCurrentVersionWithHttpInfo() - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraVersionApi
-
get the API current version
- getData() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
- getDate(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getDateFormat() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
- getDefault() - Static method in class io.streamthoughts.azkarra.serialization.json.Json
- getDefaultApiClient() - Static method in class io.streamthoughts.azkarra.client.openapi.Configuration
-
Get the default API client, which would be used when creating API instances without providing an API client.
- getDefaultEnvironment() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets the default
StreamsExecutionEnvironment
. - getDefaultEnvironment() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets the default
StreamsExecutionEnvironment
. - getDescription() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
- getDescription() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
-
Get description
- getDescription() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get description
- getDescription() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getDescription() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getDetails() - Method in class io.streamthoughts.azkarra.http.health.Health
-
Gets the health indicator details.
- getDouble(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getDouble(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a double.
- getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a double.
- getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a double.
- getDouble(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a double.
- getDouble(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a double.
- getDuration() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get duration
- getDuration() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the duration of the restoration process.
- getEndingOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get endingOffset
- getEndingOffset() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the exclusive ending offset of the entire restoration process for this TopicPartition
- getEndpoint() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getEnv() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getEnvironmentForName(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets the
StreamsExecutionEnvironment
for the specified name. - getEnvironmentForName(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets the
StreamsExecutionEnvironment
for the specified name. - getError() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getError() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get error
- getErrorCode() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
- getErrors() - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
- getErrors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
-
Get errors
- getEventStreamPublisherForType(String) - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Gets a new
EventStreamPublisher
for the given event-tye. - getEventStreamPublisherForType(String) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Gets a new
EventStreamPublisher
for the given event-tye. - getEventStreams() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
- getException() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get exception
- getException() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
- getException() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getExcludePatterns() - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig
- getExtensions() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
-
Get the list of extension attributes that should be included in monitoring events.
- getFailure() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getFailure() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get failure
- getFatalExceptions() - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig
- getFetch() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
-
Get fetch
- getFetch() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get fetch
- getFetchAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
-
Get fetchAll
- getFetchAll() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get fetchAll
- getFetchKeyRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
-
Get fetchKeyRange
- getFetchKeyRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get fetchKeyRange
- getFetchTimeRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
-
Get fetchTimeRange
- getFetchTimeRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get fetchTimeRange
- getFloat(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getGet() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
-
Get get
- getGet() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get get
- getGitBranch() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
- getGitCommitId() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
- getGlobalStores() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
- getGlobalStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
-
Get globalStores
- getGroup() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
-
Get group
- getGson() - Method in class io.streamthoughts.azkarra.client.openapi.JSON
-
Get Gson.
- getHeaders() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
- getHealth() - Method in interface io.streamthoughts.azkarra.http.health.HealthIndicator
-
Gets the health for a service or sub-system.
- getHealth() - Method in class io.streamthoughts.azkarra.http.health.internal.StreamsHealthIndicator
-
Gets the health for a service or sub-system.
- getHealth() - Method in class io.streamthoughts.examples.azkarra.healthcheck.CustomHealthCheckExample.MyCustomerHealthCheck
- getHost() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
- getHttpClient() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get HTTP client
- getId() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
- getId() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
- getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get id
- getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
-
Get id
- getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
-
Get id
- getId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
-
Get id
- getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsApplicationResponse
- getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getId() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
- getIds(Collection<? extends HasId>) - Static method in interface io.streamthoughts.azkarra.api.model.HasId
-
Helper method to get string ids from a collection of
HasId
objects. - getIds(Collection<? extends HasName>) - Static method in interface io.streamthoughts.azkarra.api.model.HasName
-
An helper method to get string names from a collection of
HasName
objects. - getInstance() - Static method in class io.streamthoughts.azkarra.api.streams.consumer.GlobalConsumerOffsetsRegistry
- getInt(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getInt(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as an integer.
- getInt(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as an integer.
- getInt(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as an integer.
- getInt(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as an integer.
- getInt(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as an integer.
- getIntervalMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
-
Get the period the interceptor should use to send a streams state event (Default is 10 seconds).
- getJSON() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get JSON
- getKafkaStreams() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Returns the wrapped
KafkaStreams
instance. - getKafkaStreams() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Returns the wrapped
KafkaStreams
instance. - getKey() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
- getKey() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
- getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
-
Get key
- getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
-
Get key
- getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams
-
Get key
- getKey() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
-
Get key
- getKeyFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
-
Get keyFrom
- getKeyFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
-
Get keyFrom
- getKeyManagers() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
- getKeyPassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getKeySerializer() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
- getKeySerializer() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
- getKeystoreLocation() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getKeystorePassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getKeystoreType() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getKeyTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
-
Get keyTo
- getKeyTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
-
Get keyTo
- getLag() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get lag
- getLatest(Version...) - Static method in class io.streamthoughts.azkarra.api.util.Version
-
Static helper for returning the latest version from a list of
Version
. - getLimit() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
-
Only return the first n records
- getList(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getListener() - Method in class io.streamthoughts.azkarra.http.ServerConfig
- getLocalEndpoint() - Method in class io.streamthoughts.azkarra.runtime.query.LocalQueryCall
- getLocalInstance(KafkaStreamsMetadata) - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
- getLocation() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- getLogEndOffset() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- getLogEndOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
-
Get logEndOffset
- getLoginContext() - Method in class io.streamthoughts.azkarra.http.security.auth.JAASAuthentication
-
Gets the
LoginModule
used to authenticate the user. - getLong(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getLong(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a long.
- getLong(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a long.
- getLong(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a long.
- getLong(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a long.
- getLong(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Gets the parameter as long for the given key.
- getLong(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams
-
Gets the parameter as long for the given key.
- getLong(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a long.
- getLongEndOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get longEndOffset
- getLongStartColonOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get longStartColonOffset
- getMainApplicationClass() - Method in class io.streamthoughts.azkarra.streams.AzkarraApplication
-
Gets the
Class
containing the main method. - getMainConsumerClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get mainConsumerClientId
- getMessage() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error
-
Get message
- getMessage() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
- getMetrics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
-
Get metrics
- getMinAvailableBrokers() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
- getName() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
- getName() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
- getName() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
-
Get name
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
-
Get name
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
-
Get name
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get name
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
-
Get name
- getName() - Method in class io.streamthoughts.azkarra.client.openapi.Pair
- getName() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getName() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getName() - Method in class io.streamthoughts.azkarra.http.health.Health
-
Gets the health indicator name.
- getName() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
- getName() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
- getNodes() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SubTopologyGraph
- getNodes() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
-
Get nodes
- getOffsetLag() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- getOffsetLag() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
-
Get offsetLag
- getOptionalBoolean(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets an optional parameter as an boolean.
- getOptionalDouble(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets an optional parameter as an double.
- getOptionalInt(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets an optional parameter as an integer.
- getOptionalLong(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets an optional parameter as a long.
- getOptionalQueryParam(HttpServerExchange, String) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper
-
Static helper that can be used to get an optional param from query for the specified name.
- getOptionalString(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets an optional parameter as a string.
- getOrThrow(Function<List<Error>, Throwable>) - Method in class io.streamthoughts.azkarra.api.monad.Validator
- getParamName() - Method in class io.streamthoughts.azkarra.client.openapi.auth.ApiKeyAuth
- getParams() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- getParams() - Method in interface io.streamthoughts.azkarra.api.query.Query
- getParams() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- getPartition() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
-
Get partition
- getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get partition
- getPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
-
The partition of the topic
- getPartition() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the Partition being restored.
- getPartitionLagInfos() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
- getPartitionLagInfos() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
-
Get partitionLagInfos
- getPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
- getPartitionRestoreInfos() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
-
Get partitionRestoreInfos
- getPassword() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
- getPath() - Method in class io.streamthoughts.azkarra.http.data.ErrorMessage
- getPort() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
- getPort() - Method in class io.streamthoughts.azkarra.http.ServerConfig
- getPositions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
-
Get positions
- getPredecessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
- getPredecessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
- getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
-
Get predecessors
- getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
-
Get predecessors
- getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
-
Get predecessors
- getPredecessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
-
Get predecessors
- getPrincipal() - Method in class io.streamthoughts.azkarra.http.security.auth.AbstractAuthentication
-
The
Principal
of the user to authenticate. - getPrincipal() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication
-
The
Principal
of the user to authenticate. - getPrincipal() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
- getProcessor() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
- getProcessor() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
-
Get processor
- getProducerClientIds() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get producerClientIds
- getProducerConfigs(String) - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
-
Get the configs for the
producer
. - getQuery() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
-
Get query
- getQueryBuilder(String) - Method in enum io.streamthoughts.azkarra.api.query.StoreType
- getQueryParam(HttpServerExchange, String) - Static method in class io.streamthoughts.azkarra.http.ExchangeHelper
-
Static helper that can be used to get an mandatory param from query for the specified name.
- getQueryTimeout() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
- getQueryTimeoutMs() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
-
This limit the total time of state store execute.
- getRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
-
Get range
- getRange() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange
-
Get range
- getReadTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get read timeout (in milliseconds).
- getRecord() - Method in class io.streamthoughts.azkarra.http.sse.ServerSentEventSubscriber.StreamedEvent
- getRecords() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
- getRecords() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
-
Get records
- getRemote() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
-
Get remote
- getRemote() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
-
Get remote
- getRemoteAccessAllowed() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
-
Is remote access is allowed for this execute
- getReporters() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
- getResource() - Method in class io.streamthoughts.azkarra.commons.rocksdb.internal.OpaqueMemoryResource
-
Gets the handle resource.
- getResource(String) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
- getResources(String) - Method in class io.streamthoughts.azkarra.streams.components.isolation.ComponentClassLoader
- getResponseBody() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException
-
Get the HTTP response body.
- getResponseHeaders() - Method in exception io.streamthoughts.azkarra.client.openapi.ApiException
-
Get the HTTP response headers.
- getRestoreConsumerClientId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get restoreConsumerClientId
- getResult() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- getResult() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
-
Get result
- getRetries() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
-
The maximum number of attempts to run after failed access to a given local state store
- getRetries() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
- getRetryBackoff() - Method in class io.streamthoughts.azkarra.http.data.QueryOptionsRequest
- getRetryBackoffMs() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
-
The time to wait before attempting to retry a failed access to a given local state store
- getRetryBackoffMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
- getRoles() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
- getSecurityMechanism() - Method in interface io.streamthoughts.azkarra.http.security.auth.AuthenticationContext
-
Gets the security mechanism used to authenticate the current user.
- getSecurityMechanism() - Method in class io.streamthoughts.azkarra.http.security.auth.UndertowAuthenticationContext
-
Gets the security mechanism used to authenticate the current user.
- getSecurityMechanism() - Method in class io.streamthoughts.azkarra.http.security.handler.SecurityHandler
- getServer() - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
- getServer() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
-
Get server
- getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
-
Get server
- getServer() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
-
Get server
- getServers() - Method in class io.streamthoughts.azkarra.http.data.StreamsApplicationResponse
- getSetOptions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
-
Get setOptions
- getShort(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getSince() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get since
- getSince() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
-
Get since
- getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getSince() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.State
- getSinkTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
- getSource() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.GlobalStore
- getSource() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
-
Get source
- getSourceTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
- getSslCaCert() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get SSL CA cert.
- getSSLContext(KeyManager[], TrustManager[]) - Method in class io.streamthoughts.azkarra.client.security.SSLContextFactory
-
Gets the
SSLContext
instance using the specified configuration. - getSSLSession() - Method in class io.streamthoughts.azkarra.http.security.auth.SSLAuthenticationContext
-
Gets the current ssl session information.
- getStandbyAssignments() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
-
Get standbyAssignments
- getStandbyStateStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
-
Get standbyStateStores
- getStandbyTasks() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get standbyTasks
- getStartingOffset() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get startingOffset
- getStartingOffset() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the starting offset of the entire restoration process for this TopicPartition.
- getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get state
- getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
-
Get state
- getState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
-
Get state
- getState() - Method in class io.streamthoughts.azkarra.commons.streams.StateRestoreInfo
-
Gets the name of the state being restored.
- getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo.State
- getState() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
- getStateRestoreInfo(String) - Method in class io.streamthoughts.azkarra.commons.streams.LoggingStateRestoreListener
-
Gets the state state of a the restoration process for given state store.
- getStateRestoreInfo(String) - Method in interface io.streamthoughts.azkarra.commons.streams.StateRestoreService
-
Gets the state state of a the restoration process for given state store.
- getStateStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
-
Get stateStores
- getStatus() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- getStatus() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
-
Get status
- getStatus() - Method in class io.streamthoughts.azkarra.http.health.Health
-
Gets the health indicator status.
- getStatusCode() - Method in class io.streamthoughts.azkarra.client.openapi.ApiResponse
- getStore() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getStore() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get store
- getStoreName() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- getStoreName() - Method in interface io.streamthoughts.azkarra.api.query.Query
- getStoreName() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- getStoreOperation() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- getStoreOperation() - Method in interface io.streamthoughts.azkarra.api.query.Query
- getStoreOperation() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- getStores() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.ProcessorNode
- getStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
-
Get stores
- getStores() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
-
Get stores
- getStoreType() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- getStoreType() - Method in interface io.streamthoughts.azkarra.api.query.Query
- getStoreType() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- getStreamBuilder() - Method in class io.streamthoughts.azkarra.api.streams.OptimizedTopologyProvider
-
Returns the
StreamsBuilder
which is used to build theTopology
instance. - getStreamsApplicationById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets all local and remote streams instances for the specified streams application.
- getStreamsApplicationById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
-
Gets all local and remote streams instances for the specified streams application.
- getStreamsContainerById(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Returns the
KafkaStreamsContainer
for the specified id. - getStreamsContainerById(String) - Method in class io.streamthoughts.azkarra.runtime.service.LocalAzkarraStreamsService
-
Returns the
KafkaStreamsContainer
for the specified id. - getStreamsInstanceConfig(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the configuration of the KafkaStreams instance
- getStreamsInstanceConfigAsync(String, ApiCallback<Map<String, Object>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the configuration of the KafkaStreams instance
- getStreamsInstanceConfigCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceConfig
- getStreamsInstanceConfigWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the configuration of the KafkaStreams instance
- getStreamsInstanceConsumerOffsets(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the offset posititions for the consumers of the Kafka Streams instance
- getStreamsInstanceConsumerOffsetsAsync(String, ApiCallback<V1StreamsConsumerGroupOffsets>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the offset posititions for the consumers of the Kafka Streams instance
- getStreamsInstanceConsumerOffsetsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceConsumerOffsets
- getStreamsInstanceConsumerOffsetsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the offset posititions for the consumers of the Kafka Streams instance
- getStreamsInstanceDetails(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get details about a Kafka Streams instance
- getStreamsInstanceDetailsAsync(String, ApiCallback<V1StreamsDetails>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get details about a Kafka Streams instance
- getStreamsInstanceDetailsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceDetails
- getStreamsInstanceDetailsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get details about a Kafka Streams instance
- getStreamsInstanceMetadata(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
list the KafkaStreams instances currently active on the local Azkarra application
- getStreamsInstanceMetadataAsync(String, ApiCallback<V1StreamsMetadata>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) list the KafkaStreams instances currently active on the local Azkarra application
- getStreamsInstanceMetadataCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceMetadata
- getStreamsInstanceMetadataWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
list the KafkaStreams instances currently active on the local Azkarra application
- getStreamsInstanceMetricByGroupAndName(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the current metric for the streams instance, metric group and name
- getStreamsInstanceMetricByGroupAndNameAsync(String, String, String, ApiCallback<V1MetricGroup>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the current metric for the streams instance, metric group and name
- getStreamsInstanceMetricByGroupAndNameCall(String, String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceMetricByGroupAndName
- getStreamsInstanceMetricByGroupAndNameWithHttpInfo(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the current metric for the streams instance, metric group and name
- getStreamsInstanceMetrics(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricsAsync(String, ApiCallback<List<V1MetricGroup>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricsByGroup(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricsByGroupAsync(String, String, ApiCallback<List<V1MetricGroup>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricsByGroupCall(String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceMetricsByGroup
- getStreamsInstanceMetricsByGroupWithHttpInfo(String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceMetrics
- getStreamsInstanceMetricsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the metrics for the Kafka Streams instance
- getStreamsInstanceMetricValue(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the current metric value for the streams application, metric group and name
- getStreamsInstanceMetricValueAsync(String, String, String, ApiCallback<String>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the current metric value for the streams application, metric group and name
- getStreamsInstanceMetricValueCall(String, String, String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceMetricValue
- getStreamsInstanceMetricValueWithHttpInfo(String, String, String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the current metric value for the streams application, metric group and name
- getStreamsInstanceStatus(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the status about the running tasks of the KafkaStreams instance
- getStreamsInstanceStatusAsync(String, ApiCallback<V1StreamsStatus>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the status about the running tasks of the KafkaStreams instance
- getStreamsInstanceStatusCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceStatus
- getStreamsInstanceStatusWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the status about the running tasks of the KafkaStreams instance
- getStreamsInstanceStoreOffsets(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
gets the partition lag and restoration info for all local state store
- getStreamsInstanceStoreOffsetsAsync(String, ApiCallback<List<V1LocalStatePartitionsInfo>>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) gets the partition lag and restoration info for all local state store
- getStreamsInstanceStoreOffsetsCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceStoreOffsets
- getStreamsInstanceStoreOffsetsWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
gets the partition lag and restoration info for all local state store
- getStreamsInstanceTopology(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the topology graph of the Kafka Streams instance
- getStreamsInstanceTopologyAsync(String, ApiCallback<V1StreamsTopology>) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
(asynchronously) get the topology graph of the Kafka Streams instance
- getStreamsInstanceTopologyCall(String, ApiCallback) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
Build call for getStreamsInstanceTopology
- getStreamsInstanceTopologyWithHttpInfo(String) - Method in class io.streamthoughts.azkarra.client.openapi.apis.AzkarraV1Api
-
get the topology graph of the Kafka Streams instance
- getStreamThread() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
-
Get streamThread
- getStreamThreadExceptionHandler() - Method in class io.streamthoughts.azkarra.runtime.env.LocalStreamsExecutionEnvironment
-
Gets the
StreamThreadExceptionHandler
. - getString(Object) - Static method in class io.streamthoughts.azkarra.api.util.TypeConverter
- getString(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a string.
- getString(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a string.
- getString(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a string.
- getString(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a string.
- getString(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Gets the parameter as string for the given key.
- getString(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams
-
Gets the parameter as string for the given key.
- getString(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a string.
- getStringList(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a list.
- getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
- getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a list.
- getStringList(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a list.
- getStringList(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a list.
- getSubConf(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a
Conf
. - getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a
Conf
. - getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a
Conf
. - getSubConf(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a
Conf
. - getSubConf(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a
Conf
. - getSubConfList(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter as a list of
Conf
. - getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter as a list of
Conf
. - getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter as a list of
Conf
. - getSubConfList(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter as a list of
Conf
. - getSubConfList(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter as a list of
Conf
. - getSubTopologies() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph
- getSubTopologies() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
-
Get subTopologies
- getSuccess() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getSuccess() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get success
- getSuccessors() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
- getSuccessors() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
- getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
-
Get successors
- getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
-
Get successors
- getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
-
Get successors
- getSuccessors() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
-
Get successors
- getSuperTypes(Class<?>) - Static method in class io.streamthoughts.azkarra.api.util.ClassUtils
- getSupportedEnvironmentTypes() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets all supported environment types.
- getSupportedEnvironmentTypes() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets all supported environment types.
- GettableComponent<T> - Interface in io.streamthoughts.azkarra.api.components
-
Class for getting a configurable component.
- getTags() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
-
Get tags
- getTaskId() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
-
The single task-id running within the KafkaStreams application
- getTempFolderPath() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
The path of temporary folder used to store downloaded files from endpoints with file response.
- getThreadName() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get threadName
- getThreads() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
-
Get threads
- getThreads() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceStatus
- getThreadState() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
-
Get threadState
- getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Failure
- getThrowable() - Method in interface io.streamthoughts.azkarra.api.monad.Try
- getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Retriable
- getThrowable() - Method in class io.streamthoughts.azkarra.api.monad.Try.Success
- getTime() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
-
Get time
- getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
-
Get timeFrom
- getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
-
Get timeFrom
- getTimeFrom() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
-
Get timeFrom
- getTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
-
Get timeout
- getTimeout() - Method in class io.streamthoughts.azkarra.runtime.interceptors.WaitForSourceTopicsInterceptorConfig
- getTimeoutMs() - Method in class io.streamthoughts.azkarra.runtime.interceptors.KafkaBrokerReadyInterceptorConfig
- getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
-
Get timeTo
- getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
-
Get timeTo
- getTimeTo() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
-
Get timeTo
- getTook() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- getTook() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
-
Get took
- getTopic() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SinkNode
- getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get topic
- getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
-
Get topic
- getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
-
Get topic
- getTopic() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
-
The name of the topic
- getTopic() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the Topic of the partition being restored.
- getTopic() - Method in class io.streamthoughts.azkarra.runtime.interceptors.MonitoringStreamsInterceptorConfig
-
Get the topic on which monitoring event will be sent (Default is _azkarra-streams-monitoring).
- getTopicPartition() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
-
Get topicPartition
- getTopicPartitions() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
-
The assigned Topic/Partition
- getTopics() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.SourceNode
- getTopics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
-
Get topics
- getTopics() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
-
Get topics
- getTopology() - Method in interface io.streamthoughts.azkarra.api.streams.KafkaStreamsContainer
-
Returns the wrapped
Topology
instance. - getTopology() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
- getTopology() - Method in class io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainer
-
Returns the wrapped
Topology
instance. - getTopologyByAliasAndQualifiers(String, Qualifier<? extends TopologyProvider>) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets the
TopologyDescriptor
for the specified alias and qualifier. - getTopologyByAliasAndQualifiers(String, Qualifier<? extends TopologyProvider>) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets the
TopologyDescriptor
for the specified alias and qualifier. - getTopologyByAliasAndVersion(String, String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets the
TopologyDescriptor
for the specified alias and version. - getTopologyByAliasAndVersion(String, String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets the
TopologyDescriptor
for the specified alias and version. - getTopologyDescriptors() - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets all topologies registered into this
AzkarraContext
even those ones which are not enable. - getTopologyDescriptors() - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets all topologies registered into this
AzkarraContext
even those ones which are not enable. - getTopologyDescriptors(StreamsExecutionEnvironment<?>) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets all topologies registered into this
AzkarraContext
which are available for the given environment. - getTopologyDescriptors(StreamsExecutionEnvironment<?>) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets all topologies registered into this
AzkarraContext
which are available for the given environment. - getTopologyDescriptors(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraContext
-
Gets all topologies registered into this
AzkarraContext
which are available for the given environment. - getTopologyDescriptors(String) - Method in class io.streamthoughts.azkarra.runtime.context.DefaultAzkarraContext
-
Gets all topologies registered into this
AzkarraContext
which are available for the given environment. - getTopologyProviders() - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets all topologies available locally.
- getTopologyProviders() - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets all topologies available locally.
- getTopologyVersionsByAlias(String) - Method in interface io.streamthoughts.azkarra.api.AzkarraStreamsService
-
Gets all versions of
TopologyDescriptor
for the specified alias. - getTopologyVersionsByAlias(String) - Method in class io.streamthoughts.azkarra.runtime.service.AbstractAzkarraStreamsService
-
Gets all versions of
TopologyDescriptor
for the specified alias. - getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getTotal() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
- getTotal() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get total
- getTotal() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
-
Get total
- getTotalRestored() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
-
Get totalRestored
- getTotalRestored() - Method in class io.streamthoughts.azkarra.commons.streams.StatePartitionRestoreInfo
-
Gets the total number of records restored.
- getTrustStoreLocation() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getTruststorePassword() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getTruststoreType() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getType() - Method in class io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.AbstractNode
- getType() - Method in interface io.streamthoughts.azkarra.api.model.StreamsTopologyGraph.Node
- getType() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
-
Get type
- getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
-
Get type
- getType() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
-
Get type
- getType() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getUserDeclaredTopics(TopologyDescription) - Static method in class io.streamthoughts.azkarra.runtime.streams.topology.TopologyUtils
- getUserDetails() - Method in interface io.streamthoughts.azkarra.http.security.auth.Authentication
-
Gets details about the authenticated user.
- getUserDetails() - Method in class io.streamthoughts.azkarra.http.security.auth.UsernamePasswordAuthentication
-
Gets details about the authenticated user.
- getUserIdentityManager() - Method in class io.streamthoughts.azkarra.http.security.SecurityConfig
- getUsername() - Method in class io.streamthoughts.azkarra.client.openapi.auth.HttpBasicAuth
- getUsers() - Method in class io.streamthoughts.azkarra.http.security.auth.InMemoryUserIdentityManager
- getValue() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
-
Get value
- getValue() - Method in enum io.streamthoughts.azkarra.client.openapi.models.V1Query.TypeEnum
- getValue() - Method in enum io.streamthoughts.azkarra.client.openapi.models.V1QueryResult.StatusEnum
- getValue() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
-
Get value
- getValue() - Method in class io.streamthoughts.azkarra.client.openapi.Pair
- getValue(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Gets a required parameter value.
- getValue(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Gets a required parameter value.
- getValue(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Gets a required parameter value.
- getValue(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Gets a required parameter value.
- getValue(String) - Method in class io.streamthoughts.azkarra.api.query.GenericQueryParams
-
Gets the parameter for the given key.
- getValue(String) - Method in interface io.streamthoughts.azkarra.api.query.QueryParams
-
Gets the parameter for the given key.
- getValue(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Gets a required parameter value.
- getVersion() - Static method in class io.streamthoughts.azkarra.api.AzkarraVersion
- getVersion() - Method in interface io.streamthoughts.azkarra.api.streams.topology.TopologyDefinition
- getVersion() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
-
Get version
- getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsInstanceInfo
- getVersion() - Method in class io.streamthoughts.azkarra.http.data.StreamsTopologyRequest
- getVersion() - Static method in class io.streamthoughts.examples.azkarra.Version
- getWriteTimeout() - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Get write timeout (in milliseconds).
- getX509Certificate() - Method in class io.streamthoughts.azkarra.http.security.auth.X509CertificateCredentials
- getX509TrustManager(TrustManager[]) - Static method in class io.streamthoughts.azkarra.client.security.SSLUtils
-
Helpers method to get the first
X509TrustManager
in the givenTrustManager
. - GlobalConsumerOffsetsRegistry - Class in io.streamthoughts.azkarra.api.streams.consumer
- GlobalResultSet<K,V> - Class in io.streamthoughts.azkarra.api.query.result
- GlobalResultSet(String, String, String, List<ErrorResultSet>, List<SuccessResultSet<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
-
Creates a new
GlobalResultSet
instance. - GlobalResultSet(String, String, List<ErrorResultSet>, List<SuccessResultSet<K, V>>) - Constructor for class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
-
Creates a new
GlobalResultSet
instance. - globalStores(List<V1StreamsGlobalStore>) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
- GrantedAuthority - Interface in io.streamthoughts.azkarra.http.security.auth
- group() - Method in class io.streamthoughts.azkarra.api.model.Metric
- group() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
- group(String) - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
- GroupMetricFilter - Class in io.streamthoughts.azkarra.api.model.predicate
- GroupMetricFilter(String) - Constructor for class io.streamthoughts.azkarra.api.model.predicate.GroupMetricFilter
-
Creates a new
GroupMetricFilter
instance. - guessContentTypeFromFile(File) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Guess Content-Type header from the given file (defaults to "application/octet-stream").
H
- handle(KafkaStreamsContainer, Thread, Throwable) - Method in interface io.streamthoughts.azkarra.api.streams.errors.StreamThreadExceptionHandler
-
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
- handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.context.internal.ContextAwareThreadExceptionHandlerSupplier.DelegateStreamThreadExceptionHandler
-
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
- handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.CloseKafkaStreamsOnThreadException
-
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
- handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.LogAndSkipOnThreadException
-
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
- handle(KafkaStreamsContainer, Thread, Throwable) - Method in class io.streamthoughts.azkarra.runtime.streams.errors.RestartKafkaStreamsOnThreadException
-
Method invoked when a StreamThread abruptly terminates due to an uncaught exception.
- handle(Callback[]) - Method in class io.streamthoughts.azkarra.http.security.jaas.spi.DefaultAuthenticationCallbackHandler
- handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception) - Method in class io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandler
- handleDefaultResponse(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.error.ExceptionDefaultResponseListener
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiApplicationsRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiContextRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiDefaultRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiDocHttpRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiEnvironmentRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiStreamsRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiTopologyRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
- handler(AzkarraStreamsService) - Method in class io.streamthoughts.azkarra.http.routes.WebUIHttpRoutes
- handler(AzkarraStreamsService) - Method in interface io.streamthoughts.azkarra.http.spi.RoutingHandlerProvider
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.error.ExceptionDefaultHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.ApplicationQueryStoreHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.HeadlessHttpHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsGetMetricsHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsPostHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.handler.StreamsStopHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiHealthRoutes
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiInfoRoutes
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.routes.ApiVersionRoutes
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.authorizer.AuthorizationHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.AuthenticationContextHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.SecurityHandler
- handleRequest(HttpServerExchange) - Method in class io.streamthoughts.azkarra.http.security.handler.XMLHttpRequestAwareAuthCallHandler
-
Only allow the request through if successfully authenticated or if authentication is not required.
- handleResponse(Response, Type) - Method in class io.streamthoughts.azkarra.client.openapi.ApiClient
-
Handle the given response, return the deserialized object when the response is successful.
- hashCode() - Method in class io.streamthoughts.azkarra.api.ApplicationId
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.ComponentAttribute
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.AnyQualifier
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.CompositeQualifier
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.NamedQualifier
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.RestrictionQualifier
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.qualifier.VersionQualifier
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.Restriction
- hashCode() - Method in class io.streamthoughts.azkarra.api.components.SimpleComponentDescriptor
- hashCode() - Method in class io.streamthoughts.azkarra.api.config.ConfEntry
- hashCode() - Method in class io.streamthoughts.azkarra.api.errors.Error
- hashCode() - Method in class io.streamthoughts.azkarra.api.events.reactive.internal.LongSubscriptionId
- hashCode() - Method in class io.streamthoughts.azkarra.api.model.KV
- hashCode() - Method in class io.streamthoughts.azkarra.api.model.Metric
- hashCode() - Method in class io.streamthoughts.azkarra.api.model.MetricGroup
- hashCode() - Method in class io.streamthoughts.azkarra.api.model.TimestampedValue
- hashCode() - Method in class io.streamthoughts.azkarra.api.model.TopologyAndAliases
- hashCode() - Method in class io.streamthoughts.azkarra.api.monad.Tuple
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.DecorateQuery
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.internal.BaseKeyedLocalStoreQuery
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.QueryOptions
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.QueryRequest
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.AbstractResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.ErrorResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.GlobalResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.QueryResult
- hashCode() - Method in class io.streamthoughts.azkarra.api.query.result.SuccessResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.api.server.ServerInfo
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerClientOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerGroupOffsetsState
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerLogOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.ConsumerThreadKey
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.consumer.OffsetAndTimestamp
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.StateChangeEvent
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.store.LocalStatePartitionsInfo
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.store.StatePartitionLagInfo
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.TopicPartitions
- hashCode() - Method in class io.streamthoughts.azkarra.api.streams.topology.TopologyMetadata
- hashCode() - Method in class io.streamthoughts.azkarra.api.StreamsExecutionEnvironment.View
- hashCode() - Method in class io.streamthoughts.azkarra.api.StreamsTopologyMeta
- hashCode() - Method in class io.streamthoughts.azkarra.api.util.Endpoint
- hashCode() - Method in class io.streamthoughts.azkarra.api.util.Version
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Error
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1LocalStatePartitionsInfo
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Metric
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1MetricGroup
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Options
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Query
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryAll
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryCount
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryErrorResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetch
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAll
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchAllParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRange
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchKeyRangeParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRange
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryFetchTimeRangeParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGet
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGetParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryGlobalResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOperation
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryOptions
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRange
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryRangeParams
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QueryResult
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1QuerySuccessResultSet
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1Record
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionLagInfo
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StatePartitionRestoreInfo
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerClientOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerGroupOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsConsumerLogOffsets
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsDetails
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsGlobalStore
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsMetadata
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsState
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsStatus
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsSubTopology
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopology
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyNode
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNode
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologyProcessorNodeAllOf
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNode
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySinkNodeAllOf
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNode
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1StreamsTopologySourceNodeAllOf
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TaskMetadata
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1ThreadMetadata
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.V1TopicPartition
- hashCode() - Method in class io.streamthoughts.azkarra.client.openapi.models.Version
- hashCode() - Method in class io.streamthoughts.azkarra.http.health.Health
- hashCode() - Method in class io.streamthoughts.azkarra.http.health.Status
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicRolePrincipal
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.BasicUserPrincipal
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.DigestPasswordCredentials
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.PasswordCredentials
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.auth.RoleGrantedAuthority
- hashCode() - Method in class io.streamthoughts.azkarra.http.security.AzkarraAccount
- hashCode() - Method in class io.streamthoughts.azkarra.runtime.env.internal.BasicContainerId
- hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsAttributes
- hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsContext
- hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.ce.CloudEventsEntity
- hashCode() - Method in class io.streamthoughts.azkarra.runtime.interceptors.monitoring.KafkaStreamsMetadata
- hashCode() - Method in class io.streamthoughts.azkarra.streams.components.isolation.ExternalComponent
- HasId - Interface in io.streamthoughts.azkarra.api.model
-
An interface representing a model that has an identifier.
- hasKey() - Method in interface io.streamthoughts.azkarra.api.query.LocalExecutableQueryWithKey
- HasName - Interface in io.streamthoughts.azkarra.api.model
-
An interface representing a model that has a name.
- hasPath(String) - Method in interface io.streamthoughts.azkarra.api.config.Conf
-
Checks whether the specified path exists into this
Conf
. - hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.DelegatingConf
-
Checks whether the specified path exists into this
Conf
. - hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.EmptyConf
-
Checks whether the specified path exists into this
Conf
. - hasPath(String) - Method in class io.streamthoughts.azkarra.api.config.MapConf
-
Checks whether the specified path exists into this
Conf
. - hasPath(String) - Method in class io.streamthoughts.azkarra.streams.config.AzkarraConf
-
Checks whether the specified path exists into this
Conf
. - havingValue() - Method in annotation type io.streamthoughts.azkarra.api.annotations.ConditionalOn
-
Specify the expected value for the
ConditionalOn.property()
. - HeadlessHttpHandler - Class in io.streamthoughts.azkarra.http.handler
- HeadlessHttpHandler(HttpHandler) - Constructor for class io.streamthoughts.azkarra.http.handler.HeadlessHttpHandler
-
Creates a new
HeadlessHttpHandler
instance. - Health - Class in io.streamthoughts.azkarra.http.health
-
The
Health
wraps information about a service or sub-system. - Health.Builder - Class in io.streamthoughts.azkarra.http.health
-
Builder for creating new
Health
instances. - HealthAggregator - Class in io.streamthoughts.azkarra.http.health
-
The
HealthAggregator
aggregates multipleHealth
instances into a single one. - HealthAggregator() - Constructor for class io.streamthoughts.azkarra.http.health.HealthAggregator
- HealthAggregator(StatusAggregator) - Constructor for class io.streamthoughts.azkarra.http.health.HealthAggregator
- HealthIndicator - Interface in io.streamthoughts.azkarra.http.health
- HIGHEST_ORDER - Static variable in interface io.streamthoughts.azkarra.api.components.Ordered
- HOSTNAME - Static variable in class io.streamthoughts.azkarra.api.util.Network
- HTTP_AUTH_PRINCIPAL_BUILDER_CLASS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
- HTTP_AUTH_USER_IDENTITY_MANAGER_CLASS_CONFIG - Static variable in class io.streamthoughts.azkarra.http.security.SecurityConfig
- HTTP_AUTHORIZATION_MANAGER_CLASS_CONFIG - Static variable in class io.strea