Abstract class representing a ZK formatter

A wrapper for an alpine data container

CLI Tests

Holds CLI validators

Used for mocking time related code.

Test Cluster controller.

HTTP response entity class

HTTP response entity class

HTTP response entity class

Model of cluster state. User is able to add, remove and monitor task status.

`Tests

Holder object for framework configuration.

SystemTest configuration object

Tests

Simple class to monitor lifecycle of scheduler container.

Factory to read credentials and return credential builder.

Test that custom settings work

Tests data volumes

Tests that we can run different versions of ES

Discovery mappings.

Given the wrong ES settings, the cluster will not discover each other. This test ensures it can.

Versioned docker scheduler

Docker helper utilities

Represents ES ports.

Status of task. This is necessary because the raw TaskInfo packet doesn't contain the frameworkID or a link to the respective TaskStatus packet.

Tests

Get Array of tasks from the API

Test Auth. This currently tests authentication and roles. It does not test ACL's yet.

Common elasticsearch parameters

Response for Elasticsearch nodes. No need for discovery test.

Scheduler for Elasticsearch.

Container for the Elasticsearch scheduler

Tests Scheduler API.

Delegates system environment to enable testing of Main.

Environmental variables for the executor

Tests

Test that Executor state can be set/get

Factory for creating {@link org.apache.mesos.Protos.FrameworkInfo}s

Tests

Tests configuration of framework roles

Model of framework state

Tests

Provides the ZooKeeper address(es) in a format required by Mesos. The format consists of a list of ZK servers Example: zk://host1:port1,host2:port2

Tests for Mesos state zookeeper address parsing

Adds ip table rules to forward all ES traffic to the docker host.

Versioned Jar Scheduler

Callback for logging of docker commands that require textual output

Application which starts the Elasticsearch scheduler

Main app to run Mesos Elasticsearch with Mini Mesos.

Main test

A tagged version of MesosMaster

A tagged version of MesosSlave

Adds a volume to the sandbox location

Provides the ZooKeeper address(es) in a format required by Mesos. The format consists of a list of ZK servers and a path Example: zk://host1:port1,h

Tests for Mesos ZK formatting. Basically the same as MesosStateZKFormatter, but with /mesos

Utilities to help with networking

Ensures that the string is not empty. Will strip spaces.

Ensures that the string is not empty. Will strip spaces.

Adds a warning message if an even number is encountered

Matcher for {@link org.apache.mesos.Protos.OfferID}s.

Offer result

Rule and reason container object

Offer strategy

Offer strategy when external storage is involved. Notice when compared to the OfferStrategyNormal, the OfferRule for checking if enough storage space

Offer strategy

Test offer strategy

Utility class for building offers

Validates a positive number. For type Double

Validates a positive number. For type Integer

Validates a positive number. For type Long

Abstract class to validate a number. @param <T> A numeric type

Proto file helpers for tests.

Tests CLUSTER state monitoring and reconciliation.

Matcher for {@link org.apache.mesos.Protos.Request}s

Checks a list of resources to ensure that it contains more than the required value

Test for ResourceCheck

Helper class for building Mesos resources.

Interface for checking offers

A system test to ensure that the framework can run as a JAR, not using docker. <p> <b>Test method</b> <p> The goal is to start the framework in ja

Tests the main method.

A TestBase that starts a scheduler