embedded

Type Members

1. trait Assertions extends AnyRef

   

   Simple helper assertions.

   Simple helper assertions. Some stolen from Akka akka.testkit.TestKit.scala for now.

2. trait CassandraPorts extends AnyRef

   

3. case class DynamicCassandraPorts(basePort: Int) extends CassandraPorts with Product with Serializable

   

4. trait EmbeddedCassandra extends AnyRef

   

   A utility trait for integration testing.

   A utility trait for integration testing. Manages *one* single Cassandra server at a time and enables switching its configuration. This is not thread safe, and test suites must not be run in parallel, because they will "steal" the server.

5. final class EmbeddedKafka extends Embedded

   

6. class EmbeddedZookeeper extends Embedded

   

   Implements a simple standalone ZooKeeperServer.

   Implements a simple standalone ZooKeeperServer. To create a ZooKeeper client object, the application needs to pass a connection string containing a comma separated list of host:port pairs, each corresponding to a ZooKeeper server.

   Session establishment is asynchronous. This constructor will initiate connection to the server and return immediately - potentially (usually) before the session is fully established. The watcher argument specifies the watcher that will be notified of any changes in state. This notification can come at any point before or after the constructor call has returned.

   The instantiated ZooKeeper client object will pick an arbitrary server from the connectString and attempt to connect to it. If establishment of the connection fails, another server in the connect string will be tried (the order is non-deterministic, as we random shuffle the list), until a connection is established. The client will continue attempts until the session is explicitly closed.

7. class KafkaConsumer extends AnyRef

   

   The KafkaConsumer is a very simple consumer of a single Kafka topic.

   The KafkaConsumer is a very simple consumer of a single Kafka topic. This is a helpful utility for IT tests to insure data is getting published to Kafka for streaming ingestion upstream.

8. class KafkaProducer[K, V] extends AnyRef

   

   Simple producer using string encoder and default partitioner.

9. abstract class KafkaProducerActor[K, V] extends Actor with ActorLogging

   

   Simple producer for an Akka Actor using string encoder and default partitioner.

10. class KafkaTopicLogger extends Actor with ActorLogging

    

    Simple actor with a Kafka consumer to report the latest message count in a Kafka Topic.

11. trait SparkRepl extends AnyRef

    

12. trait SparkTemplate extends AnyRef

    

13. implicit final class SparkTestDuration extends AnyVal