Uses of Package
io.streamthoughts.azkarra.api
-
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.AzkarraContext The AzkarraContext.AzkarraContextListener ContainerId An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.Executed Executed class is used to describe aTopology
instance to be executed.State The states.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironment.View AEnvironment
is used to describe the current state of aStreamsExecutionEnvironment
instance.StreamsLifecycleChain StreamsLifecycleContext Context about the currentKafkaStreams
instance.StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped.StreamsTopologyExecution TopologyExecution provide a way for topology to be executed in an specific environment.StreamsTopologyMeta StreamsTopologyMeta.Builder -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api.components Class Description AzkarraContext The AzkarraContext. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api.server Class Description AzkarraContext The AzkarraContext. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api.spi Class Description AzkarraContext The AzkarraContext. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api.streams Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.api.streams.internal Class Description StreamsLifecycleChain StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http Class Description AzkarraContext The AzkarraContext. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.handler Class Description AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.health.internal Class Description AzkarraContext The AzkarraContext.AzkarraContextAware Interface to be implemented by any object that wishes to be notified of theAzkarraContext
that it runs in. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.prometheus Class Description AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.routes Class Description AzkarraContext The AzkarraContext.AzkarraContextAware Interface to be implemented by any object that wishes to be notified of theAzkarraContext
that it runs in.AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.security.handler Class Description AzkarraContext The AzkarraContext. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.spi Class Description AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.http.sse Class Description AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.metrics.interceptor Class Description StreamsLifecycleChain StreamsLifecycleContext Context about the currentKafkaStreams
instance.StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime Class Description Executed Executed class is used to describe aTopology
instance to be executed.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentFactory StreamsTopologyExecution TopologyExecution provide a way for topology to be executed in an specific environment.StreamsTopologyMeta -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.context Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.AzkarraContext The AzkarraContext.AzkarraContextListener Executed Executed class is used to describe aTopology
instance to be executed.State The states.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.context.internal Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.AzkarraContext The AzkarraContext.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentAware StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped.StreamsTopologyMeta -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.env Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.AzkarraContext The AzkarraContext.AzkarraContextAware Interface to be implemented by any object that wishes to be notified of theAzkarraContext
that it runs in.ContainerId An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.Executed Executed class is used to describe aTopology
instance to be executed.State The states.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentFactory StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped.StreamsTopologyExecution TopologyExecution provide a way for topology to be executed in an specific environment.StreamsTopologyMeta -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.env.internal Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.ContainerId An interface representing an ID to uniquely identify a KafkaStreams instance running either locally or remotely.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.interceptors Class Description StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentAware StreamsLifecycleChain StreamsLifecycleContext Context about the currentKafkaStreams
instance.StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.query Class Description AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.service Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.AzkarraContext The AzkarraContext.AzkarraContextAware Interface to be implemented by any object that wishes to be notified of theAzkarraContext
that it runs in.AzkarraStreamsService TheAzkarraStreamsService
serves as the main front-facing interface for manipulating streams applications.Executed Executed class is used to describe aTopology
instance to be executed.StreamsExecutionEnvironment.View AEnvironment
is used to describe the current state of aStreamsExecutionEnvironment
instance. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.streams Class Description ApplicationId An interface representing an ID to uniquely identify a KafkaStreams application running either locally or remotely.StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentAware StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.streams.errors Class Description StreamsExecutionEnvironment AStreamsExecutionEnvironment
manages the execution and the lifecycle of one or manyKafkaStreams
instances that run either locally or remotely.StreamsExecutionEnvironmentAware -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.runtime.streams.topology Class Description Executed Executed class is used to describe aTopology
instance to be executed.StreamsLifecycleInterceptor An interface that allows to intercept aKafkaStreams
instance before being started or stopped. -
Classes in io.streamthoughts.azkarra.api used by io.streamthoughts.azkarra.streams Class Description AzkarraContext The AzkarraContext.