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	GroovyHandler.setMaestroNote(MaestroNote maestroNote)
void	AbstractHandler.setMaestroNote(MaestroNote note) Sets the content of the note associated with the external endpoint

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, DrainOptions drainOptions)
CompletableFuture<List<? extends MaestroNote>>	Maestro.getDataServer()
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt()
CompletableFuture<List<? extends MaestroNote>>	Maestro.halt(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest()
CompletableFuture<List<? extends MaestroNote>>	Maestro.pingRequest(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.roleAssign(String topic, Role role)
CompletableFuture<List<? extends MaestroNote>>	Maestro.roleUnassign(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setBroker(String topic, String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setDuration(String topic, Object value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setFCL(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setManagementInterface(String topic, String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String topic, long value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setMessageSize(String topic, String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setParallelCount(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.setRate(String topic, int value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.sourceRequest(String topic, Source source)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startAgent()
CompletableFuture<List<? extends MaestroNote>>	Maestro.startInspector(String value)
CompletableFuture<List<? extends MaestroNote>>	Maestro.startWorker(String topic, WorkerStartOptions options)
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest()
CompletableFuture<List<? extends MaestroNote>>	Maestro.statsRequest(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAgent()
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopAll()
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector() Deprecated.
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopInspector(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.stopWorker(String topic)
CompletableFuture<List<? extends MaestroNote>>	Maestro.userCommand(String topic, UserCommandData userCommandData)
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForDrain()
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForDrain(int expect) Waits for the drain notifications
CompletableFuture<List<? extends MaestroNote>>	Maestro.waitForNotifications(int expect)

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,U> void	Maestro.exec(BiFunction<T,U,CompletableFuture<List<? extends MaestroNote>>> function, T value1, U value2)
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
protected AbstractMaestroPeer<? extends MaestroNote>	AbstractMaestroExecutor.getMaestroPeer() Get the Maestro peer

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.
boolean	MaestroMonitor.shouldAwake(MaestroNote subject) Tests if a subject matches the predicate

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

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

Constructor and Description
AbstractMaestroExecutor(AbstractMaestroPeer<? extends MaestroNote> maestroPeer) Constructor
MaestroMonitor(Predicate<? super MaestroNote> object) Constructs a Monitor using the given predicate (ie.: note instanceof TestSuccessfulNotification)

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	GetRequest A GET request queries the peers for information
class	GetResponse A GET response provide peers w/ a response for their GET requests
class	GroupJoinRequest
class	GroupLeaveRequest
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	RoleAssign
class	RoleUnassign
class	SetRequest
class	StartAgent
class	StartInspector
class	StartWorker
class	StatsRequest
class	StatsResponse
class	StopAgent
class	StopInspector
class	StopWorker
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.drainRequest(String topic, DrainOptions drainOptions) Issues a drain request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.getDataServer() Sends a get data server request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.halt() Sends a halt request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.halt(String topic) 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.roleAssign(String topic, Role role) Assign a role to one or more peers
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.roleUnassign(String topic) Unassign a role to one or more peers
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setBroker(String topic, String value) Sends a set broker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setDuration(String topic, Object value) Sends a set duration request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setFCL(String topic, int value) Sends a set fail-condition-latency (FCL) request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setManagementInterface(String topic, String value) Sets the management interface URL
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String topic, long value) Sends a set message size request (this one can be used for fixed message sizes)
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setMessageSize(String topic, 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(String topic, int value) Sends a set parallel count request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.setRate(String topic, int value) Sends a set rate request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.sourceRequest(String topic, Source source) Sends a source request to the agent (which causes it to download the given source)
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.startWorker(String topic, WorkerStartOptions options) Sends a start worker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest() Sends a stats request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.statsRequest(String topic) Sends a stats request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopAgent() Sends a stop agent request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopAll() Stops everything running on the test cluster
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopInspector() Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopInspector(String topic) Sends a stop inspector request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.stopWorker(String topic) Sends a stop worker request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.userCommand(String topic, UserCommandData userCommandData) Sends a user command request
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.waitForDrain() Waits for the drain notifications
CompletableFuture<List<? extends MaestroNote>>	MaestroRequester.waitForNotifications(int expect) Waits for notifications

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)