See: Description
| Interface | Description |
|---|---|
| Disposable |
To be implemented by fixtures that need special cleanup when a test is done.
|
| HasDisplayValue<T> |
Marker interface for entities whose 'display' command returns a simple representation.
|
| Class | Description |
|---|---|
| AbstractMailSource<T extends AbstractMailSource<T>> |
Base class support for both "mail" and "imap".
|
| AbstractMetricSink |
Base class for Metrics related sinks, makes sure named metric is deleted at end of test.
|
| AbstractModuleFixture<F extends AbstractModuleFixture<F>> |
Base class for objects that can be incorporated in a stream definition by calling their
AbstractModuleFixture.toString() method. |
| AggregateCounterSink |
Fixture class for an aggregate counter.
|
| AvailableSocketPorts |
Utility class to find available server ports.
|
| CounterSink |
Fixture class for an "simple" counter.
|
| DisposableFileSupport<F extends DisposableFileSupport<F>> |
Base class for stream elements that deal with file locations.
|
| DisposableMailSupport<T extends DisposableMailSupport<T>> |
Base class for fixtures that interact with a mail server.
|
| EventuallyMatcher<U> |
A matcher that will evaluate another matcher repeatedly until it matches, or fail after some number of attempts.
|
| FileJdbcJob |
A test fixture that represents the FileJdbc Job
|
| FilePollHdfsJob |
Test fixture that creates a File Poll Hdfs Job.
|
| FileSink |
Support class to capture output of a sink in a File.
|
| FileSink.FileSinkContentsMatcher |
A matcher on the String contents of the sink, that delegates to another (String) matcher.
|
| FileSource |
Support class that represents the file source module.
|
| FtpHdfsJob |
Test fixture that creates a Ftp Hdfs Job.
|
| GemFireCQSource |
Create a gemfire CQ (continuous query) source.
|
| GemFireServerSink |
Create a gemfire-server or gemfire-json-server sink.
|
| GemFireSource |
Create a gemfire source
|
| HdfsJdbcJob |
A test fixture that represents the HdfsJdbc Job
|
| HdfsMongoDbJob |
A test fixture that represents the HdfsMongoDb Job
|
| HdfsSink |
A test fixture that allows testing of the 'hdfs' sink module.
|
| JdbcHdfsJob |
A test fixture that represents the JdbcHdfs Job
|
| JdbcSink |
Represents the
jdbc sink module. |
| JdbcSource |
Represents the
jdbc source module. |
| JmsSource |
A test fixture that allows testing of the 'jms' source module.
|
| KafkaSink |
A test fixture that represents the kafka sink
|
| KafkaSource |
A test fixture that represents the kafka source
|
| LogSink |
A test fixture that represents the log sink
|
| MailSink |
A fixture to help test the
mail sink module. |
| MetricHasSimpleValueMatcher<U,T extends AbstractMetricSink & HasDisplayValue<U>> |
A matcher that will assert that the
<metric type> display xxx shell command displays the expected value. |
| MqttSink |
Test fixture that creates a mqtt sink.
|
| MqttSource |
A test fixture that allows testing of the mqtt source module.
|
| NonPollingImapSource |
Represents the imap source module, that does not use polling.
|
| PartitionedJdbcHdfsJob |
A test fixture that represents a partitioned JdbcHdfs Job
|
| PollingMailSource |
Fixture that represents the mail source module, which uses polling (here forced to 1s).
|
| RabbitSink |
A test fixture that allows testing of the rabbit sink module.
|
| RabbitSource |
A test fixture that allows testing of the rabbit source module.
|
| SimpleCounterSink |
Used to generate the counter sink portion of a stream.
|
| SimpleFileSink |
Used to generate the file sink portion of a stream.
|
| SimpleFileSource |
A FileSource for integraiton tests.
|
| SimpleHttpSource |
An HTTP source that default to using localhost:9000
|
| SimpleTailSource |
A tail source for integration tests.
|
| SparkAppJob |
A test fixture that represents the Spark App Job
|
| SyslogTcpSource |
A test fixture that allows testing of the syslog tcp source module.
|
| SyslogUdpSource |
A test fixture that allows testing of the syslog udp source module.
|
| TailSource |
Support class that represents a tail source.
|
| Tap |
Test fixture that creates a tap.
|
| TcpClientSource |
A test fixture that allows testing of the 'tcp-client' source module.
|
| TcpSink |
Test fixture that creates a simple socket server, ready to accept connections from a 'tcp' sink module.
|
| TcpSource |
A test fixture that allows testing of the 'tcp' source module.
|
| Transform |
Test fixture that creates a Transform.
|
| TwitterSearchSource |
A test fixture that allows testing of the 'TwitterSearch' source module.
|
| TwitterStreamSource |
A test fixture that allows testing of the 'TwitterStream' source module.
|