org.springframework.xd.dirt.stream.dsl

Class StreamConfigParser

java.lang.Object

org.springframework.xd.dirt.stream.dsl.StreamConfigParser

All Implemented Interfaces:

StreamLookupEnvironment

public class StreamConfigParser
extends java.lang.Object
implements StreamLookupEnvironment

Author:

Andy Clement

Constructor Summary

Constructors

Constructor and Description
StreamConfigParser(org.springframework.data.repository.CrudRepository<? extends BaseDefinition,java.lang.String> repository)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	lookupChannelForLabelOrModule(java.lang.String streamName, java.lang.String streamOrLabelOrModuleName) Look up an existing label or module name.
StreamNode	lookupStream(java.lang.String name) Look up a previously defined stream by name, returns the parsed AST for it.
StreamNode	parse(java.lang.String stream) Parse a stream definition without supplying the stream name up front.
StreamNode	parse(java.lang.String name, java.lang.String stream) Parse a stream definition.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamConfigParser

public StreamConfigParser(org.springframework.data.repository.CrudRepository<? extends BaseDefinition,java.lang.String> repository)

Method Detail

parse

public StreamNode parse(java.lang.String stream)

Parse a stream definition without supplying the stream name up front. The stream name may be embedded in the definition. For example: mystream = http | file

Returns:

the AST for the parsed stream

parse

public StreamNode parse(java.lang.String name,
               java.lang.String stream)

Parse a stream definition.

Returns:

the AST for the parsed stream

Throws:

StreamDefinitionException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

lookupStream

public StreamNode lookupStream(java.lang.String name)

Description copied from interface: StreamLookupEnvironment

Look up a previously defined stream by name, returns the parsed AST for it.

Specified by:

lookupStream in interface StreamLookupEnvironment

Parameters:

name - name of the stream

Returns:

AST for the stream

lookupChannelForLabelOrModule

public java.lang.String lookupChannelForLabelOrModule(java.lang.String streamName,
                                             java.lang.String streamOrLabelOrModuleName)

Description copied from interface: StreamLookupEnvironment

Look up an existing label or module name. The stream name is optionally supplied to restrict the search to a particular stream. The returned value is the computed output channel for that label/module if it is found. For example:

 
 mystream = http | foo | file
 tap mystream.foo > count
 
 

will cause a lookup for stream 'mystream' module 'foo' when the tap is being resolved. The return value would be 'mystream.1' (The output channel for a module is based on the index of the module within the stream, starting at 0).

Specified by:

lookupChannelForLabelOrModule in interface StreamLookupEnvironment

Parameters:

streamName - the name of the stream

streamOrLabelOrModuleName - a label or name of a module

Returns:

the label or module name