Uses of Interface
org.maestro.common.client.notes.MaestroNote

Packages that use MaestroNote

Package	Description
org.maestro.agent.base
org.maestro.client
org.maestro.client.callback
org.maestro.client.exchange
org.maestro.client.notes
org.maestro.common.agent
org.maestro.common.client
org.maestro.common.client.notes
org.maestro.tests
org.maestro.tests.callbacks

Uses of MaestroNote in org.maestro.agent.base

Methods in org.maestro.agent.base that return MaestroNote

Modifier and Type	Method and Description
MaestroNote	GroovyHandler.getMaestroNote()
MaestroNote	AbstractHandler.getNote() Get maestro note

Methods in org.maestro.agent.base with parameters of type MaestroNote

Modifier and Type	Method and Description
void	AbstractHandler.setMaestroNote(MaestroNote note) Sets the content of the note associated with the external endpoint
void	GroovyHandler.setMaestroNote(MaestroNote maestroNote)

Uses of MaestroNote in org.maestro.client

Methods in org.maestro.client that return types with arguments of type MaestroNote

Modifier and Type	Method and Description
CompletableFuture<List<? extends MaestroNote>>	Maestro.drainRequest(String topic, String duration, String url, int parallelCount) Issues a drain request
CompletableFuture<List<? extends MaestroNote>>	Maestro.flushRequest() Sends a flush request
CompletableFuture<List<? extends MaestroNote>>	Maestro.flushRequest(String topic) Sends a flush request
CompletableFuture<List<? extends MaestroNote>>	Maestro.getDataServer() Sends a get request
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt() Sends a halt request
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest() Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest(String topic) Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setDuration(Object value) Sends a set duration request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setDuration(String topic, Object value) Sends a set duration request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setFCL(int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setLogLevel(String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setLogLevel(String topic, String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setManagementInterface(String value) Sets the management interface URL
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String value) Sends a set message size request (this one can be used for fixed or variable message sizes)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setThrottle(int value) Sends a set throttle request
CompletableFuture<List<? extends MaestroNote>>	Maestro.setThrottle(String topic, int value) Sends a set throttle request
CompletableFuture<List<? extends MaestroNote>>	Maestro.sourceRequest(String sourceUrl, String branch) Sends a source request to the agent (which causes it to download the given source)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAgent() Sends a start agent request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAll(String inspectorName) Starts all of the receivers, senders and inspectors peers on the test cluster
CompletableFuture<List<? extends MaestroNote>>	Maestro.startInspector(String value) Sends a start inspector request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startReceiver() Sends a start receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.startSender() Sends a start sender request
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest() Sends a stats request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAgent() Sends a stop agent request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAll() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector() Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopReceiver() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopSender() Sends a stop sender request
CompletableFuture<List<? extends MaestroNote>>	Maestro.userCommand(long option, String payload) Sends a user command request
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForDrain() Waits for the drain notifications
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForDrain(int expect) Waits for the drain notifications
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForNotifications(int expect) Waits for notifications

Methods in org.maestro.client with parameters of type MaestroNote

Modifier and Type	Method and Description
void	MaestroReceiverClient.pingResponse(MaestroNote note, long sec, long uSec)
void	MaestroReceiverClient.replyInternalError(MaestroNote note, String message, String... args)
void	MaestroReceiverClient.replyOk(MaestroNote note)

Method parameters in org.maestro.client with type arguments of type MaestroNote

Modifier and Type	Method and Description
static <T> void	Maestro.exec(Function<T,CompletableFuture<List<? extends MaestroNote>>> function, T value)
static <T> void	Maestro.exec(Supplier<CompletableFuture<List<? extends MaestroNote>>> function)
static <T,U> void	Maestro.set(BiFunction<T,U,CompletableFuture<List<? extends MaestroNote>>> function, T value1, U value2)
static <T> void	Maestro.set(Function<T,CompletableFuture<List<? extends MaestroNote>>> function, T value)

Uses of MaestroNote in org.maestro.client.callback

Methods in org.maestro.client.callback with parameters of type MaestroNote

Modifier and Type	Method and Description
boolean	MaestroNoteCallback.call(MaestroNote note) Executes the call back

Uses of MaestroNote in org.maestro.client.exchange

Classes in org.maestro.client.exchange with type parameters of type MaestroNote

Modifier and Type	Class and Description
class	AbstractMaestroPeer<T extends MaestroNote> Is a base class that implements the basic operations of any peer connect to Maestro (not just senders and receivers).
interface	MaestroNoteDeserializer<T extends MaestroNote>

Methods in org.maestro.client.exchange that return MaestroNote

Modifier and Type	Method and Description
static MaestroNote	MaestroDeserializer.deserialize(byte[] bytes)

Methods in org.maestro.client.exchange that return types with arguments of type MaestroNote

Modifier and Type	Method and Description
List<MaestroNote>	MaestroCollector.collect(Predicate<? super MaestroNote> predicate) Collect notes matching a given predicate

Methods in org.maestro.client.exchange with parameters of type MaestroNote

Modifier and Type	Method and Description
protected void	MaestroCollector.noteArrived(MaestroNote note)
void	MaestroMqttClient.publish(String topic, MaestroNote note) Publishes a message in the broker
protected void	MaestroMqttClient.publish(String topic, MaestroNote note, int qos, boolean retained) Publishes a message in the broker.
protected void	MaestroMqttClient.publish(String topic, MaestroNote note, int qos, boolean retained, MaestroNoteCallback postProcessCallback) Publishes a message in the broker.

Method parameters in org.maestro.client.exchange with type arguments of type MaestroNote

Modifier and Type	Method and Description
List<MaestroNote>	MaestroCollector.collect(Predicate<? super MaestroNote> predicate) Collect notes matching a given predicate

Uses of MaestroNote in org.maestro.client.notes

Classes in org.maestro.client.notes that implement MaestroNote

Modifier and Type	Class and Description
class	AbnormalDisconnect
class	AgentSourceRequest
class	DrainCompleteNotification
class	DrainRequest
class	FlushRequest
class	GetRequest A GET request queries the peers for information
class	GetResponse A GET response provide peers w/ a response for their GET requests
class	Halt
class	InternalError
class	LogRequest
class	LogResponse
class	MaestroEvent<T>
class	MaestroNotification
class	MaestroRequest<T>
class	MaestroResponse
class	OkResponse
class	PingRequest
class	PingResponse
class	ProtocolError
class	SetRequest
class	StartAgent
class	StartInspector
class	StartReceiver
class	StartSender
class	StatsRequest
class	StatsResponse
class	StopAgent
class	StopInspector
class	StopReceiver
class	StopSender
class	TestFailedNotification
class	TestSuccessfulNotification
class	UserCommand1Request
class	UserCommand1Response

Uses of MaestroNote in org.maestro.common.agent

Methods in org.maestro.common.agent that return MaestroNote

Modifier and Type	Method and Description
MaestroNote	AgentEndpoint.getNote() Get the content of the note associated with the external endpoint.

Methods in org.maestro.common.agent with parameters of type MaestroNote

Modifier and Type	Method and Description
void	AgentEndpoint.setMaestroNote(MaestroNote note) Sets the content of the note associated with the external endpoint.

Uses of MaestroNote in org.maestro.common.client

Methods in org.maestro.common.client that return types with arguments of type MaestroNote

Modifier and Type	Method and Description
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.flushRequest() Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.flushRequest(String topic) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.getDataServer() Sends a get request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.halt() Sends a halt request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.pingRequest() Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.pingRequest(String topic) Sends a ping request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setDuration(Object value) Sends a set duration request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setDuration(String topic, Object value) Sends a set duration request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setFCL(int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setLogLevel(String value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setLogLevel(String topic, String value) Sends a set log level request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String value) Sends a set message size request (This one can be used for variable and fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setParallelCount(int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setParallelCount(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setThrottle(int value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setThrottle(String topic, int value) Deprecated.
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startAgent() Sends a start agent request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startInspector(String value) Sends a start inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startReceiver() Sends a start receiver request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.startSender() Sends a start sender request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest() Sends a stats request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopAgent() Sends a stop agent request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopInspector() Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopReceiver() Sends a stop receiver request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopSender() Sends a stop sender request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.userCommand(long option, String payload) Sends a agent general execution request

Methods in org.maestro.common.client with parameters of type MaestroNote

Modifier and Type	Method and Description
void	MaestroReceiver.pingResponse(MaestroNote note, long sec, long uSec) Publishes a ping response that takes into account a giver number of elapsed seconds/microseconds
void	MaestroClient.publish(String topic, MaestroNote note) Publishes a message in the broker
void	MaestroReceiver.replyInternalError(MaestroNote note, String message, String... args) Publishes an internal error reply in the Maestro broker
void	MaestroReceiver.replyOk(MaestroNote note) Publishes a OK reply in the maestro broker

Uses of MaestroNote in org.maestro.common.client.notes

Methods in org.maestro.common.client.notes with parameters of type MaestroNote

Modifier and Type	Method and Description
void	MaestroNote.correlate(MaestroNote note)
boolean	MaestroNote.correlatesTo(MaestroNote note)

Uses of MaestroNote in org.maestro.tests

Methods in org.maestro.tests with parameters of type MaestroNote

Modifier and Type	Method and Description
protected boolean	AbstractTestExecutor.isFailed(MaestroNote note)
protected boolean	AbstractTestExecutor.isTestFailed(MaestroNote note)

Uses of MaestroNote in org.maestro.tests.callbacks

Methods in org.maestro.tests.callbacks with parameters of type MaestroNote

Modifier and Type	Method and Description
boolean	LogRequesterCallback.call(MaestroNote note)
boolean	StatsCallBack.call(MaestroNote note)