Uses of Interface
io.streamthoughts.azkarra.api.ContainerId
-
Packages that use ContainerId Package Description io.streamthoughts.azkarra.api io.streamthoughts.azkarra.runtime.env io.streamthoughts.azkarra.runtime.env.internal -
-
Uses of ContainerId in io.streamthoughts.azkarra.api
Methods in io.streamthoughts.azkarra.api that return types with arguments of type ContainerId Modifier and Type Method Description Set<ContainerId>
StreamsExecutionEnvironment. getContainerIds()
Returns allContainerId
for active Kafka Streams applications.Methods in io.streamthoughts.azkarra.api with parameters of type ContainerId Modifier and Type Method Description default KafkaStreamsContainer
StreamsExecutionEnvironment. getContainerById(ContainerId id)
Gets aKafkaStreamsContainer
for the specified id.default void
StreamsExecutionEnvironment. stop(ContainerId id, boolean cleanUp)
Stops the streams container for the specifiedapplication.id
.void
StreamsExecutionEnvironment. stop(ContainerId id, boolean cleanUp, Duration timeout)
Stops the streams container for the specifiedapplication.id
.default void
StreamsExecutionEnvironment. terminate(ContainerId id)
Terminates all streams container for the specifiedapplication.id
and remove the associated topology from this environment.void
StreamsExecutionEnvironment. terminate(ContainerId id, Duration timeout)
Terminates theKafkaStreams
instance for the specifiedcontainer.id
and remove the associated topology from this environment. -
Uses of ContainerId in io.streamthoughts.azkarra.runtime.env
Methods in io.streamthoughts.azkarra.runtime.env that return ContainerId Modifier and Type Method Description ContainerId
ContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.Methods in io.streamthoughts.azkarra.runtime.env that return types with arguments of type ContainerId Modifier and Type Method Description Set<ContainerId>
LocalStreamsExecutionEnvironment. getContainerIds()
Returns allContainerId
for active Kafka Streams applications.Methods in io.streamthoughts.azkarra.runtime.env with parameters of type ContainerId Modifier and Type Method Description void
LocalStreamsExecutionEnvironment. stop(ContainerId id, boolean cleanUp, Duration timeout)
Stops the streams container for the specifiedapplication.id
.void
LocalStreamsExecutionEnvironment. terminate(ContainerId id, Duration timeout)
Terminates theKafkaStreams
instance for the specifiedcontainer.id
and remove the associated topology from this environment. -
Uses of ContainerId in io.streamthoughts.azkarra.runtime.env.internal
Classes in io.streamthoughts.azkarra.runtime.env.internal that implement ContainerId Modifier and Type Class Description class
BasicContainerId
Methods in io.streamthoughts.azkarra.runtime.env.internal that return ContainerId Modifier and Type Method Description ContainerId
DefaultContainerIdBuilder. buildContainerId(ApplicationId applicationId, TopologyMetadata metadata, Conf config)
Builds the identifier that will be used for identifying theKafkaStreamsContainer
running the topology.
-