| Constructor and Description |
|---|
MaestroAgent(String maestroURL,
PeerInfo peerInfo,
MaestroDataServer dataServer)
Constructor
|
| Modifier and Type | Class and Description |
|---|---|
class |
AgentPeer
Agent-specific peer class
|
| Constructor and Description |
|---|
MaestroReceiverClient(String url,
PeerInfo peerInfo,
String id) |
| Modifier and Type | Method and Description |
|---|---|
protected PeerInfo |
AbstractMaestroPeer.getPeerInfo() |
| Modifier and Type | Method and Description |
|---|---|
static String[] |
MaestroTopics.agentTopics(String id,
PeerInfo peerInfo) |
static String[] |
MaestroTopics.inspectorTopics(String id,
PeerInfo peerInfo) |
static String |
MaestroTopics.peerTopic(PeerInfo peerInfo)
Get the peer specific topic by id
|
static String[] |
MaestroTopics.peerTopics(String[] publicTopics,
PeerInfo peerInfo,
String id)
Returns the full list of topics for a peer including the public and private topics (those that are specific
to that peer)
|
| Constructor and Description |
|---|
AbstractMaestroPeer(org.eclipse.paho.client.mqttv3.MqttClient inboundEndPoint,
PeerInfo peerInfo,
MaestroNoteDeserializer<? extends T> deserializer) |
AbstractMaestroPeer(String url,
PeerInfo peerInfo,
MaestroNoteDeserializer<? extends T> deserializer) |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectorPeer |
class |
WorkerPeer |
| Modifier and Type | Method and Description |
|---|---|
Map<String,PeerInfo> |
PeerSet.getPeers()
Get the peers in this set
|
| Constructor and Description |
|---|
PeerSet(Map<String,PeerInfo> peers)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
PeerInfo |
MaestroNotification.getPeerInfo() |
PeerInfo |
MaestroResponse.getPeerInfo() |
| Modifier and Type | Method and Description |
|---|---|
void |
MaestroNotification.setPeerInfo(PeerInfo peerInfo) |
void |
MaestroResponse.setPeerInfo(PeerInfo peerInfo) |
| Constructor and Description |
|---|
InspectorManager(String maestroURL,
PeerInfo peerInfo,
MaestroDataServer dataServer,
File logDir) |
| Modifier and Type | Class and Description |
|---|---|
class |
InspectorPeer |
| Modifier and Type | Method and Description |
|---|---|
void |
PooledDownloaderDecorator.downloadAny(PeerInfo peerInfo,
String testNumber) |
void |
ReportsDownloader.downloadAny(PeerInfo peerInfo,
String testNumber)
Download any report
|
void |
BrokerDownloader.downloadAny(PeerInfo peerInfo,
String testNumber) |
void |
DefaultDownloader.downloadAny(PeerInfo peerInfo,
String testNumber) |
void |
PooledDownloaderDecorator.downloadLastFailed(String id,
PeerInfo peerInfo) |
void |
ReportsDownloader.downloadLastFailed(String id,
PeerInfo peerInfo)
Download the last failed reports
|
void |
BrokerDownloader.downloadLastFailed(String id,
PeerInfo peerInfo) |
void |
DefaultDownloader.downloadLastFailed(String id,
PeerInfo peerInfo)
Download files from the peers when a test failed
|
void |
PooledDownloaderDecorator.downloadLastSuccessful(String id,
PeerInfo peerInfo) |
void |
ReportsDownloader.downloadLastSuccessful(String id,
PeerInfo peerInfo)
Download the last successful reports
|
void |
BrokerDownloader.downloadLastSuccessful(String id,
PeerInfo peerInfo) |
void |
DefaultDownloader.downloadLastSuccessful(String id,
PeerInfo peerInfo)
Download files from the peers when a test is successful
|
| Modifier and Type | Method and Description |
|---|---|
protected String |
DefaultOrganizer.combine(PeerInfo peerInfo) |
String |
Organizer.organize(PeerInfo peerInfo)
Organize the report directory
|
String |
DefaultOrganizer.organize(PeerInfo peerInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected PeerEndpoint |
ExclusiveBalancedStrategy.assign(String id,
PeerInfo peerInfo) |
protected PeerEndpoint |
BalancedStrategy.assign(String id,
PeerInfo peerInfo) |
protected PeerEndpoint |
LegacyStrategy.assign(String id,
PeerInfo peerInfo) |
protected abstract PeerEndpoint |
AbstractStrategy.assign(String id,
PeerInfo peerInfo)
Assign a role to the node identified by the id and peer information
|
protected PeerEndpoint |
NonAssigningStrategy.assign(String id,
PeerInfo peerInfo) |
| Constructor and Description |
|---|
ConcurrentWorkerManager(String maestroURL,
PeerInfo peerInfo,
File logDir,
MaestroDataServer dataServer)
Constructor
|
MaestroWorkerManager(String maestroURL,
PeerInfo peerInfo,
MaestroDataServer dataServer)
Constructor
|
| Constructor and Description |
|---|
MaestroWorkerExecutor(String url,
PeerInfo peerInfo,
File logDir,
MaestroDataServer dataServer) |
This documentation was released into the public domain.