Uses of Interface
io.streamthoughts.azkarra.api.AzkarraContext
-
-
Uses of AzkarraContext in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return AzkarraContext Modifier and Type Method Description AzkarraContext
AzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.AzkarraContext
AzkarraContext. addExecutionEnvironment(StreamsExecutionEnvironment environment)
Adds theStreamsExecutionEnvironment
to this context.AzkarraContext
AzkarraContext. addListener(AzkarraContextListener listener)
Registers a new listener instance to this context.AzkarraContext
AzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
.AzkarraContext
AzkarraContext. setRegisterShutdownHook(boolean registerShutdownHook)
Sets if the createdAzkarraContext
should have a shutdown hook registered.Methods in io.streamthoughts.azkarra.api with parameters of type AzkarraContext Modifier and Type Method Description void
AzkarraContextListener. onContextStart(AzkarraContext context)
void
AzkarraContextListener. onContextStop(AzkarraContext context)
void
AzkarraContextAware. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
Uses of AzkarraContext in io.streamthoughts.azkarra.api.components
Constructors in io.streamthoughts.azkarra.api.components with parameters of type AzkarraContext Constructor Description ContextAwareComponentFactory(AzkarraContext context, ComponentFactory factory)
Creates a newContextAwareComponentFactory
instance. -
Uses of AzkarraContext in io.streamthoughts.azkarra.api.server
Methods in io.streamthoughts.azkarra.api.server that return AzkarraContext Modifier and Type Method Description AzkarraContext
AzkarraRestExtensionContext. context()
Provides theAzkarraContext
instance that can be used to retrieve registered components. -
Uses of AzkarraContext in io.streamthoughts.azkarra.api.spi
Methods in io.streamthoughts.azkarra.api.spi with parameters of type AzkarraContext Modifier and Type Method Description EmbeddedHttpServer
EmbeddedHttpServerProvider. get(AzkarraContext context)
Creates an returns the embedded HTTP server. -
Uses of AzkarraContext in io.streamthoughts.azkarra.http
Methods in io.streamthoughts.azkarra.http that return AzkarraContext Modifier and Type Method Description AzkarraContext
UndertowEmbeddedServer.InternalRestExtensionContext. context()
Methods in io.streamthoughts.azkarra.http with parameters of type AzkarraContext Modifier and Type Method Description EmbeddedHttpServer
UndertowEmbeddedServerProvider. get(AzkarraContext context)
Creates an returns the embedded HTTP server. -
Uses of AzkarraContext in io.streamthoughts.azkarra.http.health.internal
Methods in io.streamthoughts.azkarra.http.health.internal with parameters of type AzkarraContext Modifier and Type Method Description void
StreamsHealthIndicator. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
Uses of AzkarraContext in io.streamthoughts.azkarra.http.routes
Methods in io.streamthoughts.azkarra.http.routes with parameters of type AzkarraContext Modifier and Type Method Description void
ApiHealthRoutes. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
Uses of AzkarraContext in io.streamthoughts.azkarra.http.security.handler
Constructors in io.streamthoughts.azkarra.http.security.handler with parameters of type AzkarraContext Constructor Description SecurityHandlerFactory(AzkarraContext context)
Creates a newAzkarraContext
instance. -
Uses of AzkarraContext in io.streamthoughts.azkarra.runtime.context
Classes in io.streamthoughts.azkarra.runtime.context that implement AzkarraContext Modifier and Type Class Description class
DefaultAzkarraContext
The AzkarraContext.Methods in io.streamthoughts.azkarra.runtime.context that return AzkarraContext Modifier and Type Method Description AzkarraContext
DefaultAzkarraContext. addConfiguration(Conf configuration)
Adds the specifiedConf
to the configuration of thisAzkarraContext
.AzkarraContext
DefaultAzkarraContext. addExecutionEnvironment(StreamsExecutionEnvironment env)
Adds theStreamsExecutionEnvironment
to this context.AzkarraContext
DefaultAzkarraContext. addListener(AzkarraContextListener listener)
Registers a new listener instance to this context.static AzkarraContext
DefaultAzkarraContext. create()
Static helper that can be used to creates a newAzkarraContext
instance using a defaultComponentRegistry
and a empty configuration.static AzkarraContext
DefaultAzkarraContext. create(ComponentFactory factory)
Static helper that can be used to creates a newAzkarraContext
instance using the specifiedComponentRegistry
and a empty configuration.static AzkarraContext
DefaultAzkarraContext. create(Conf configuration)
Static helper that can be used to creates a newAzkarraContext
instance using a defaultComponentRegistry
and the specified configuration.AzkarraContext
DefaultAzkarraContext. setConfiguration(Conf configuration)
Sets the default configuration to be used for thisAzkarraContext
.AzkarraContext
DefaultAzkarraContext. setRegisterShutdownHook(boolean registerShutdownHook)
Sets if the createdAzkarraContext
should have a shutdown hook registered. -
Uses of AzkarraContext in io.streamthoughts.azkarra.runtime.context.internal
Fields in io.streamthoughts.azkarra.runtime.context.internal declared as AzkarraContext Modifier and Type Field Description protected AzkarraContext
ContextAwareComponentSupplier. context
Constructors in io.streamthoughts.azkarra.runtime.context.internal with parameters of type AzkarraContext Constructor Description ContextAwareApplicationIdBuilderSupplier(AzkarraContext context, GettableComponent<ApplicationIdBuilder> gettable)
ContextAwareComponentSupplier(AzkarraContext context)
ContextAwareGettableComponentSupplier(AzkarraContext context, GettableComponent<T> gettable)
Creates a newContextAwareGettableComponentSupplier
instance.ContextAwareKafkaStreamsFactorySupplier(AzkarraContext context, GettableComponent<KafkaStreamsFactory> gettable)
ContextAwareLifecycleInterceptorSupplier(AzkarraContext context, GettableComponent<StreamsLifecycleInterceptor> gettable)
ContextAwareThreadExceptionHandlerSupplier(AzkarraContext context, GettableComponent<StreamThreadExceptionHandler> gettable)
ContextAwareTopologySupplier(AzkarraContext context, ComponentDescriptor<TopologyProvider> descriptor)
Creates a newContextAwareTopologySupplier
instance. -
Uses of AzkarraContext in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env with parameters of type AzkarraContext Modifier and Type Method Description void
DefaultStreamsExecutionEnvironment. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
Uses of AzkarraContext in io.streamthoughts.azkarra.runtime.service
Constructors in io.streamthoughts.azkarra.runtime.service with parameters of type AzkarraContext Constructor Description LocalAzkarraStreamsService(AzkarraContext context, RemoteQueryClient remoteQueryClient)
Creates a newLocalAzkarraStreamsService
instance. -
Uses of AzkarraContext in io.streamthoughts.azkarra.streams
Methods in io.streamthoughts.azkarra.streams that return AzkarraContext Modifier and Type Method Description AzkarraContext
AzkarraApplication. getContext()
Gets theAzkarraContext
.static AzkarraContext
AzkarraApplication. run()
static AzkarraContext
AzkarraApplication. run(Class<?>[] sources, String[] args)
static AzkarraContext
AzkarraApplication. run(Class<?> sources, String[] args)
AzkarraContext
AzkarraApplication. run(String[] args)
Runs thisAzkarraApplication
.Methods in io.streamthoughts.azkarra.streams with parameters of type AzkarraContext Modifier and Type Method Description AzkarraApplication
AzkarraApplication. setContext(AzkarraContext context)
Sets theAzkarraContext
that must be used for thisAzkarraApplication
. -
Uses of AzkarraContext in io.streamthoughts.azkarra.streams.context
Methods in io.streamthoughts.azkarra.streams.context that return AzkarraContext Modifier and Type Method Description static AzkarraContext
AzkarraContextLoader. load(AzkarraContext context, Conf configuration)
Initialize the specifiedAzkarraContext
using the specifiedConf
.static AzkarraContext
AzkarraContextLoader. load(AzkarraContext context, ApplicationConfig configuration)
Initialize the specifiedAzkarraContext
using the specifiedApplicationConfig
.Methods in io.streamthoughts.azkarra.streams.context with parameters of type AzkarraContext Modifier and Type Method Description static AzkarraContext
AzkarraContextLoader. load(AzkarraContext context, Conf configuration)
Initialize the specifiedAzkarraContext
using the specifiedConf
.static AzkarraContext
AzkarraContextLoader. load(AzkarraContext context, ApplicationConfig configuration)
Initialize the specifiedAzkarraContext
using the specifiedApplicationConfig
.
-