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 default void
AzkarraContextListener. onContextStart(AzkarraContext context)
default 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
ApiApplicationsRoutes. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in.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.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)
ContextAwareKafkaStreamsFactorySupplier(AzkarraContext context, GettableComponent<KafkaStreamsFactory> gettable)
ContextAwareLifecycleInterceptorSupplier(AzkarraContext context, GettableComponent<StreamsLifecycleInterceptor> gettable)
ContextAwareThreadExceptionHandlerSupplier(AzkarraContext context, GettableComponent<StreamThreadExceptionHandler> gettable)
ContextAwareTopologySupplier(AzkarraContext context, StreamsTopologyMeta meta)
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
LocalStreamsExecutionEnvironment. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in.void
LocalStreamsExecutionEnvironmentFactory. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
Uses of AzkarraContext in io.streamthoughts.azkarra.runtime.service
Fields in io.streamthoughts.azkarra.runtime.service declared as AzkarraContext Modifier and Type Field Description protected AzkarraContext
AbstractAzkarraStreamsService. context
Methods in io.streamthoughts.azkarra.runtime.service with parameters of type AzkarraContext Modifier and Type Method Description void
AbstractAzkarraStreamsService. setAzkarraContext(AzkarraContext context)
Set theAzkarraContext
that this object runs in. -
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
.
-