Package io.quarkus.kafka.streams.runtime.dev.ui

Class TopologyParserContext

java.lang.Object

io.quarkus.kafka.streams.runtime.dev.ui.TopologyParserContext

final class TopologyParserContext
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	TopologyParserContext.Graphviz
(package private) static final class	TopologyParserContext.Mermaid

Field Summary

Fields

Modifier and Type	Field	Description
(package private) String	currentNode
(package private) final TopologyParserContext.Graphviz	graphviz
(package private) final TopologyParserContext.Mermaid	mermaid
(package private) final Set<String>	sinks
(package private) final Set<String>	sources
(package private) final Set<String>	stores
(package private) final Set<String>	subTopologies

Constructor Summary

Constructors

Constructor	Description
TopologyParserContext()

Method Summary

Modifier and Type	Method	Description
(package private) void	addRegexSource(String source, String regex)
(package private) void	addSink(String sink, String topic)
(package private) void	addSources(String source, String[] topics)
(package private) void	addStores(String[] stores, String processor, boolean join)
(package private) void	addSubTopology(String subTopology)
(package private) void	addTargets(String[] targets)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

currentNode

String currentNode

subTopologies

final Set<String> subTopologies

sources

final Set<String> sources

sinks

final Set<String> sinks

stores

final Set<String> stores

graphviz

final TopologyParserContext.Graphviz graphviz

mermaid

final TopologyParserContext.Mermaid mermaid

Constructor Details

TopologyParserContext

TopologyParserContext()

Method Details

addSubTopology

void addSubTopology(String subTopology)

addSink

void addSink(String sink,
 String topic)

addSources

void addSources(String source,
 String[] topics)

addRegexSource

void addRegexSource(String source,
 String regex)

addStores

void addStores(String[] stores,
 String processor,
 boolean join)

addTargets

void addTargets(String[] targets)