Open Kilda Java Documentation
Public Member Functions | Static Public Member Functions | List of all members
org.openkilda.wfm.topology.stats.StatsTopology Class Reference
Inheritance diagram for org.openkilda.wfm.topology.stats.StatsTopology:
org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig > org.openkilda.wfm.topology.Topology

Public Member Functions

 StatsTopology (LaunchEnvironment env)
 
StormTopology createTopology ()
 
- Public Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
final String getTopologyName ()
 
final T getConfig ()
 

Static Public Member Functions

static void main (String[] args) throws Exception
 

Additional Inherited Members

- Public Attributes inherited from org.openkilda.wfm.topology.Topology
String TOPOLOGY_PROPERTIES = "/topology.properties"
 
String TOPOLOGY_PROPERTIES_DEFAULTS_PREFIX = "defaults."
 
- Static Public Attributes inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
static final String SPOUT_ID_CTRL = "ctrl.in"
 
static final String BOLT_ID_CTRL_ROUTE = "ctrl.route"
 
static final String BOLT_ID_CTRL_OUTPUT = "ctrl.out"
 
static final String MESSAGE_FIELD = "message"
 
static final Fields fieldMessage = new Fields(MESSAGE_FIELD)
 
- Protected Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
 AbstractTopology (LaunchEnvironment env, Class< T > topologyConfigClass)
 
String getDefaultTopologyName ()
 
void setup () throws TException, NameCollisionException
 
Config makeStormConfig ()
 
void localExecutionMainLoop ()
 
void checkAndCreateTopic (final String topic)
 
KafkaSpout< String, String > createKafkaSpout (String topic, String spoutId)
 
KafkaBolt createKafkaBolt (final String topic)
 
void createCtrlBranch (TopologyBuilder builder, List< CtrlBoltRef > targets) throws StreamNameCollisionException
 
void createHealthCheckHandler (TopologyBuilder builder, String prefix)
 
KafkaSpoutConfig.Builder< String, String > makeKafkaSpoutConfigBuilder (String spoutId, String topic)
 
- Static Protected Member Functions inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
static int handleLaunchException (Exception error)
 
- Protected Attributes inherited from org.openkilda.wfm.topology.AbstractTopology< T extends AbstractTopologyConfig >
final String topologyName
 
final KafkaNamingStrategy kafkaNamingStrategy
 
final TopologyNamingStrategy topoNamingStrategy
 
final ConfigurationProvider configurationProvider
 
final T topologyConfig
 

Detailed Description

Definition at line 46 of file StatsTopology.java.

Constructor & Destructor Documentation

◆ StatsTopology()

org.openkilda.wfm.topology.stats.StatsTopology.StatsTopology ( LaunchEnvironment  env)

Definition at line 50 of file StatsTopology.java.

Member Function Documentation

◆ createTopology()

StormTopology org.openkilda.wfm.topology.stats.StatsTopology.createTopology ( )

Topology creator. Should be implemented.

Returns
StormTopology

Implements org.openkilda.wfm.topology.Topology.

Definition at line 64 of file StatsTopology.java.

◆ main()

static void org.openkilda.wfm.topology.stats.StatsTopology.main ( String []  args) throws Exception
static

Definition at line 54 of file StatsTopology.java.

The documentation for this class was generated from the following file: