Index (AceMQ AMQP workloads 0.1.0-SNAPSHOT API)

A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

above(double) - Method in class org.acemq.workloads.rules.Threshold
above(Duration) - Method in class org.acemq.workloads.rules.Threshold
achievedPublishRate() - Method in class org.acemq.workloads.WorkloadReport
achievedRate(Duration) - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult
achievedRateAtLeast() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the achievedRateAtLeast record component.
achievedRateAtLeast(long) - Method in class org.acemq.workloads.scenario.Expect
achievedRateAtLeastValue() - Method in class org.acemq.workloads.scenario.Expect
activeExchanges() - Method in class org.acemq.workloads.scenario.Scenario
activeProducers() - Method in class org.acemq.workloads.scenario.Scenario
activeQueues() - Method in class org.acemq.workloads.scenario.Scenario
all() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the all record component.
allowances - Variable in class org.acemq.workloads.endurance.EnduranceConfig
Allowances() - Constructor for class org.acemq.workloads.endurance.EnduranceConfig.Allowances
allowDevelopmentCertificates() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns the value of the allowDevelopmentCertificates record component.
An objective is only judged on a valid run - Search tag in class org.acemq.workloads.rules.Objective: Section
argument(String, Object) - Method in class org.acemq.workloads.scenario.ExchangeNode
argument(String, Object) - Method in class org.acemq.workloads.scenario.QueueNode
argument(String, Object) - Method in class org.acemq.workloads.TopologySpec
arguments() - Method in class org.acemq.workloads.scenario.ExchangeNode
arguments() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns the value of the arguments record component.
arguments() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the arguments record component.
at() - Method in record class org.acemq.workloads.Sample: Returns the value of the at record component.
at() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the at record component.

B

because(String) - Method in class org.acemq.workloads.rules.Threshold
below(double) - Method in class org.acemq.workloads.rules.Threshold
below(Duration) - Method in class org.acemq.workloads.rules.Threshold
Binding - Record Class in org.acemq.workloads.scenario: One route from an exchange into a queue.
Binding(String, String) - Constructor for record class org.acemq.workloads.scenario.Binding: Creates an instance of a Binding record class.
BindingJson(String, String) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Creates an instance of a BindingJson record class.
bindings() - Method in class org.acemq.workloads.scenario.QueueNode
bindings() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the bindings record component.
blocked() - Method in record class org.acemq.workloads.Sample: Returns the value of the blocked record component.
blocked() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the blocked record component.
blockedFor() - Method in class org.acemq.workloads.scenario.ScenarioReport
blockedNanos() - Method in class org.acemq.workloads.WorkloadReport
blockedReason() - Method in class org.acemq.workloads.scenario.ScenarioReport
blockedReason() - Method in class org.acemq.workloads.WorkloadReport
boundTo(String, String) - Method in class org.acemq.workloads.scenario.QueueNode
boundTo(String, String) - Method in class org.acemq.workloads.TopologySpec
broker - Variable in class org.acemq.workloads.endurance.EnduranceConfig: The AMQP endpoint every standing load publishes to.
broker() - Method in class org.acemq.workloads.scenario.QueueNode
broker() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the broker record component.
broker() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the broker record component.
broker(String) - Method in class org.acemq.workloads.scenario.QueueNode: The broker this queue actually lives on, when that is not the one the scenario runs against.
BrokerCapabilities - Class in org.acemq.workloads.scenario: What a particular broker will actually give you.
brokerUrl(int) - Method in class org.acemq.workloads.cli.WorkloadFile
brokerWasNotBlocked() - Static method in class org.acemq.workloads.rules.Rules: Was the broker refusing publishes during the run?
build - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Launch: Run to completion before the load starts; empty for none.
build() - Method in class org.acemq.workloads.Workload.Builder
build(long, long) - Method in class org.acemq.workloads.Payload: Builds one message body.

C

ceilingAtLeast() - Method in class org.acemq.workloads.Ramp
ceilingAtLeast(long) - Method in class org.acemq.workloads.Ramp
check() - Method in class org.acemq.workloads.Ramp: Checks the settings hang together, without running anything.
check(WorkloadReport) - Method in interface org.acemq.workloads.rules.Rule
classic() - Method in class org.acemq.workloads.scenario.QueueNode
classic() - Method in class org.acemq.workloads.TopologySpec
CLASSIC - Enum constant in enum class org.acemq.workloads.scenario.QueueType: The default.
CLASSIC_MIRRORED - Enum constant in enum class org.acemq.workloads.scenario.QueueType: A classic queue with a mirroring policy over it.
Cli - Class in org.acemq.workloads.cli: java -jar acemq-workload.jar -f workload.yaml
client - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream
Client(String, long, boolean, Path) - Constructor for record class org.acemq.workloads.endurance.ClientLauncher.Client: Creates an instance of a Client record class.
ClientLauncher - Class in org.acemq.workloads.endurance: Starts the standing loads, or adopts ones already running, reports on them, and stops them.
ClientLauncher(EnduranceConfig, Consumer<String>) - Constructor for class org.acemq.workloads.endurance.ClientLauncher
ClientLauncher.Client - Record Class in org.acemq.workloads.endurance: A load being watched: its pid, and whether this call started it.
ClientLauncher.LaunchException - Exception Class in org.acemq.workloads.endurance: A load could not be started or stopped.
ClientLauncher.Status - Record Class in org.acemq.workloads.endurance: What a load is doing right now.
clients - Variable in class org.acemq.workloads.endurance.EnduranceConfig
close() - Method in interface org.acemq.workloads.endurance.Endurance.Fault
closeAll(String) - Method in interface org.acemq.workloads.endurance.Endurance.Fault: Closes every client connection on the cluster.
command - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Launch
concurrency() - Method in class org.acemq.workloads.ConsumerSpec
concurrency() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
concurrency() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns the value of the concurrency record component.
concurrency(int) - Method in class org.acemq.workloads.ConsumerSpec
concurrency(int) - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
ConfigException - Exception Class in org.acemq.workloads.cli: The workload file is wrong.
ConfigException(String) - Constructor for exception class org.acemq.workloads.cli.ConfigException
confirmed() - Method in record class org.acemq.workloads.Sample: Returns the value of the confirmed record component.
confirmed() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the confirmed record component.
confirmed() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the confirmed record component.
confirmed() - Method in class org.acemq.workloads.WorkloadReport
confirms() - Method in class org.acemq.workloads.PublisherSpec
confirms() - Method in class org.acemq.workloads.scenario.ProducerNode
confirms() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the confirms record component.
confirms(boolean) - Method in class org.acemq.workloads.PublisherSpec: Publisher confirms.
confirms(boolean) - Method in class org.acemq.workloads.scenario.ProducerNode
confirmsWereOn() - Static method in class org.acemq.workloads.rules.Rules
connections() - Method in interface org.acemq.workloads.endurance.Endurance.Fault
connections() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the connections record component.
console() - Method in class org.acemq.workloads.endurance.Verdict
consumed() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the consumed record component.
consumed() - Method in record class org.acemq.workloads.Sample: Returns the value of the consumed record component.
consumed() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the consumed record component.
consumed() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the consumed record component.
consumed() - Method in class org.acemq.workloads.WorkloadReport
consumeRate() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the consumeRate record component.
consumeRate() - Method in record class org.acemq.workloads.Sample: Returns the value of the consumeRate record component.
consumeRate() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the consumeRate record component.
consumeRate() - Method in class org.acemq.workloads.WorkloadReport
consumeRate(Duration) - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult
consumeRateAtLeast() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the consumeRateAtLeast record component.
consumeRateAtLeast(long) - Method in class org.acemq.workloads.scenario.Expect
consumeRateAtLeastValue() - Method in class org.acemq.workloads.scenario.Expect
ConsumerGroupNode - Class in org.acemq.workloads.scenario: The consumers on one queue.
consumers() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the consumers record component.
consumers() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the consumers record component.
consumers() - Method in class org.acemq.workloads.Workload
consumers(String, Consumer<ConsumerGroupNode>) - Method in class org.acemq.workloads.scenario.Scenario: Attaches consumers to a queue that is already in the scenario.
consumers(Consumer<ConsumerSpec>) - Method in class org.acemq.workloads.Workload.Builder
consumers(Consumer<ConsumerGroupNode>) - Method in class org.acemq.workloads.scenario.QueueNode
consumersEnabled() - Method in class org.acemq.workloads.WorkloadReport
ConsumersJson(Integer, Integer, String, Double, Boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Creates an instance of a ConsumersJson record class.
consumersKeptUp() - Static method in class org.acemq.workloads.rules.Rules: Did the consumers keep up with the publishers?
consumersNode() - Method in class org.acemq.workloads.scenario.QueueNode
ConsumerSpec - Class in org.acemq.workloads: How the load is consumed.
consuming() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the consuming record component.
cooldownSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig: After the last cycle: a client still mid-recovery holds two of some things.
COULD_NOT - Static variable in class org.acemq.workloads.endurance.LoadsCli
COULD_NOT_RUN - Static variable in class org.acemq.workloads.endurance.EnduranceCli
count() - Method in class org.acemq.workloads.metrics.LatencyRecorder
count() - Method in class org.acemq.workloads.metrics.LatencySummary
cycle(int, int) - Method in interface org.acemq.workloads.endurance.Endurance.Listener
cycles - Variable in class org.acemq.workloads.endurance.EnduranceConfig
cycleSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig

D

deadLetterExchange() - Method in class org.acemq.workloads.scenario.QueueNode
deadLetterExchange() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the deadLetterExchange record component.
deadLetterTo(String) - Method in class org.acemq.workloads.scenario.QueueNode
declare() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the declare record component.
declaredArguments() - Method in class org.acemq.workloads.scenario.QueueNode: The arguments this queue is declared with, the type and dead-letter settings included.
defaults() - Static method in class org.acemq.workloads.rules.Rules
depth() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the depth record component.
depthAtEnd() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the depthAtEnd record component.
depthAtStart() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the depthAtStart record component.
describe() - Method in class org.acemq.workloads.cli.WorkloadFile
describe(ScenarioFile) - Static method in class org.acemq.workloads.scenario.ScenarioReader
describedAs(String) - Method in class org.acemq.workloads.scenario.Scenario
description() - Method in enum class org.acemq.workloads.scenario.QueueType
description() - Method in class org.acemq.workloads.scenario.Scenario
description() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the description record component.
descriptors - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Allowances
detail() - Method in class org.acemq.workloads.rules.Finding
Diagnosis, not prescription - Search tag in class org.acemq.workloads.rules.Rules: Section
dir - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Launch: Working directory for both; the workspace when not given.
DRAINING - Enum constant in enum class org.acemq.workloads.Sample.Phase: Time is up; waiting for what is in flight to land.
durable() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns the value of the durable record component.
durable() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the durable record component.
duration() - Method in class org.acemq.workloads.scenario.Scenario
duration() - Method in class org.acemq.workloads.scenario.ScenarioReport
duration() - Method in class org.acemq.workloads.Workload
duration() - Method in class org.acemq.workloads.WorkloadReport

E

elapsed() - Method in record class org.acemq.workloads.Sample: Returns the value of the elapsed record component.
elapsed() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the elapsed record component.
empty(String) - Static method in class org.acemq.workloads.metrics.LatencySummary
enabled() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns the value of the enabled record component.
enabled() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns the value of the enabled record component.
enabled() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the enabled record component.
enabled() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the enabled record component.
enabled(boolean) - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
enabled(boolean) - Method in class org.acemq.workloads.scenario.ExchangeNode
enabled(boolean) - Method in class org.acemq.workloads.scenario.ProducerNode
enabled(boolean) - Method in class org.acemq.workloads.scenario.QueueNode
endToEnd() - Method in record class org.acemq.workloads.Sample: Returns the value of the endToEnd record component.
endToEnd() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the endToEnd record component.
endToEnd() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the endToEnd record component.
endToEnd() - Method in class org.acemq.workloads.WorkloadReport
Endurance - Class in org.acemq.workloads.endurance: The leak drill: standing loads in every language, and every connection torn out from under all of them, over and over, while the run watches what each process is holding rather than what it is publishing.
Endurance(EnduranceConfig, ProcessSampler, Endurance.Fault, Endurance.Listener) - Constructor for class org.acemq.workloads.endurance.Endurance
Endurance.Fault - Interface in org.acemq.workloads.endurance: The repeated recovery fault, and the connection count that proves it did something.
Endurance.Listener - Interface in org.acemq.workloads.endurance: What the run is doing, for a console or a terminal.
Endurance.Result - Record Class in org.acemq.workloads.endurance: What the run found and where it wrote it.
EnduranceCli - Class in org.acemq.workloads.endurance: java -jar acemq-workload.jar endurance [options]: the soak.
EnduranceConfig - Class in org.acemq.workloads.endurance: What an endurance run is asked to do: the soak's numbers, the clients to watch and how each one is started, the allowances a leak has to cross, and the upstream defects allowed within a measured ceiling.
EnduranceConfig() - Constructor for class org.acemq.workloads.endurance.EnduranceConfig
EnduranceConfig.Allowances - Class in org.acemq.workloads.endurance: Growth a client is allowed before it is a leak.
EnduranceConfig.KnownUpstream - Class in org.acemq.workloads.endurance: A breach a library is known to have for a reason nothing in the workspace can fix, with a ceiling of its own: base * factor + perRecovery * recoveries + plus.
EnduranceConfig.Launch - Class in org.acemq.workloads.endurance: How one standing load is started.
env - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Launch
epoch() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the epoch record component.
equals(Object) - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.endurance.Endurance.Result: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.endurance.Reading: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.endurance.Verdict.Row: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.RampReport.Step: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.Sample: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.Binding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioSample: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Indicates whether some other object is "equal to" this one.
Every step is an ordinary run - Search tag in class org.acemq.workloads.Ramp: Section
Evidence, not advice - Search tag in class org.acemq.workloads.rules.Finding: Section
exchange() - Method in record class org.acemq.workloads.scenario.Binding: Returns the value of the exchange record component.
exchange() - Method in class org.acemq.workloads.scenario.ProducerNode
exchange() - Method in record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Returns the value of the exchange record component.
exchange() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the exchange record component.
exchange() - Method in class org.acemq.workloads.TopologySpec
exchange(String, String) - Method in class org.acemq.workloads.scenario.Scenario
exchange(String, String) - Method in class org.acemq.workloads.TopologySpec
ExchangeJson(String, String, Boolean, Boolean, Map<String, Object>) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Creates an instance of a ExchangeJson record class.
ExchangeNode - Class in org.acemq.workloads.scenario: An exchange in a scenario.
exchanges() - Method in class org.acemq.workloads.scenario.Scenario
exchanges() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the exchanges record component.
exchangeType() - Method in class org.acemq.workloads.TopologySpec
Exit codes are the interface - Search tag in class org.acemq.workloads.cli.Cli: Section
expect() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the expect record component.
expect() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the expect record component.
expect(Consumer<Expect>) - Method in class org.acemq.workloads.scenario.ProducerNode: What this producer is asked to prove.
expect(Consumer<Expect>) - Method in class org.acemq.workloads.scenario.QueueNode: What this queue is asked to prove.
expect(Rule) - Method in class org.acemq.workloads.Workload.Builder
Expect - Class in org.acemq.workloads.scenario: What a scenario is asked to prove.
Expect() - Constructor for class org.acemq.workloads.scenario.Expect
expectations() - Method in class org.acemq.workloads.scenario.ProducerNode
expectations() - Method in class org.acemq.workloads.scenario.QueueNode
expectations() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the expectations record component.
expectations() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the expectations record component.
ExpectJson(String, String, String, Long, Long, Integer, Boolean, Boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Creates an instance of a ExpectJson record class.

F

factor - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream
failed() - Method in record class org.acemq.workloads.Sample: Returns the value of the failed record component.
failed() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the failed record component.
failed() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the failed record component.
failed() - Method in class org.acemq.workloads.WorkloadReport
FAILED - Enum constant in enum class org.acemq.workloads.rules.Severity: An objective was not met, and the measurement is sound.
FAILED - Static variable in class org.acemq.workloads.endurance.EnduranceCli
failureRate() - Method in class org.acemq.workloads.ConsumerSpec
failureRate() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
failureRate() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns the value of the failureRate record component.
failureRate(double) - Method in class org.acemq.workloads.ConsumerSpec: A fraction of messages the handler rejects.
failureRate(double) - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
failures() - Method in class org.acemq.workloads.endurance.Verdict
fds() - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Returns the value of the fds record component.
fds() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the fds record component.
fdsAfter() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the fdsAfter record component.
fdsBefore() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the fdsBefore record component.
fileName(String, LocalDate) - Static method in record class org.acemq.workloads.scenario.ScenarioFile: The file name a saved scenario gets.
Finding - Class in org.acemq.workloads.rules: One thing a rule noticed, with the measurement that made it say so.
findings() - Method in class org.acemq.workloads.scenario.ScenarioReport
findings() - Method in class org.acemq.workloads.WorkloadReport
findQueue(String) - Method in class org.acemq.workloads.scenario.Scenario
format() - Method in class org.acemq.workloads.metrics.LatencySummary
format() - Method in class org.acemq.workloads.RampReport
format() - Method in class org.acemq.workloads.rules.Finding
format() - Method in class org.acemq.workloads.scenario.ScenarioReport
format() - Method in class org.acemq.workloads.WorkloadReport
forThisOs() - Static method in interface org.acemq.workloads.endurance.ProcessSampler
forVersion(String) - Static method in class org.acemq.workloads.scenario.BrokerCapabilities

G

generatorKeptUp() - Static method in class org.acemq.workloads.rules.Rules: Did the generator actually offer the rate it was asked for?
grew() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult

H

handlerTime() - Method in class org.acemq.workloads.ConsumerSpec
handlerTime() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
handlerTime() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns the value of the handlerTime record component.
handlerTime(Duration) - Method in class org.acemq.workloads.ConsumerSpec: Simulated work per message.
handlerTime(Duration) - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
hashCode() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.endurance.Reading: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.RampReport.Step: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.Sample: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.Binding: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns a hash code value for this object.
hashCode() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns a hash code value for this object.
HEADER - Static variable in record class org.acemq.workloads.endurance.Reading: The TSV header, unchanged from the script that first wrote it.
HEADER_BYTES - Static variable in class org.acemq.workloads.Payload: Two longs: the intended send time and the sequence number.
highestSustainedRate() - Method in class org.acemq.workloads.RampReport

I

implication() - Method in class org.acemq.workloads.rules.Finding
INFO - Enum constant in enum class org.acemq.workloads.rules.Severity: Worth knowing, and not a problem.
intendedSendNanos(byte[]) - Static method in class org.acemq.workloads.Payload
INVALID - Enum constant in enum class org.acemq.workloads.rules.Severity: The run did not measure what it set out to measure.
invalidatesRun() - Method in class org.acemq.workloads.rules.Finding
isDurable() - Method in class org.acemq.workloads.scenario.ExchangeNode
isDurable() - Method in class org.acemq.workloads.scenario.QueueNode
isEmpty() - Method in class org.acemq.workloads.metrics.LatencySummary
isEmpty() - Method in class org.acemq.workloads.scenario.Expect
isEnabled() - Method in class org.acemq.workloads.ConsumerSpec
isEnabled() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
isEnabled() - Method in class org.acemq.workloads.scenario.ExchangeNode
isEnabled() - Method in interface org.acemq.workloads.scenario.Node
isEnabled() - Method in class org.acemq.workloads.scenario.ProducerNode
isEnabled() - Method in class org.acemq.workloads.scenario.QueueNode
isKnown() - Method in class org.acemq.workloads.scenario.BrokerCapabilities
isLatency(String) - Static method in class org.acemq.workloads.rules.Threshold
isRandom() - Method in class org.acemq.workloads.Payload
isRemote() - Method in class org.acemq.workloads.scenario.QueueNode
isRunning() - Method in class org.acemq.workloads.RunHandle
isRunning() - Method in class org.acemq.workloads.scenario.ScenarioHandle
isScenario(Path) - Static method in class org.acemq.workloads.scenario.ScenarioReader: Whether a file is a scenario rather than a single-path workload.
isStopping() - Method in class org.acemq.workloads.RunHandle
isStopping() - Method in class org.acemq.workloads.scenario.ScenarioHandle
isUnthrottled() - Method in class org.acemq.workloads.PublisherSpec
isUnthrottled() - Method in class org.acemq.workloads.scenario.ProducerNode
isValid() - Method in class org.acemq.workloads.RampReport
isValid() - Method in class org.acemq.workloads.scenario.ScenarioReport
isValid() - Method in class org.acemq.workloads.WorkloadReport
isWorkloadMessage(byte[]) - Static method in class org.acemq.workloads.Payload

J

json() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the json record component.
json(String, int, EnduranceConfig, String, String, List<Reading>) - Method in class org.acemq.workloads.endurance.Verdict: The JSON report the console reads: the same facts as the markdown, as data.

K

keep - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Leave the loads this run started running when it ends.
kind - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream: threads, memory or descriptors.
known() - Method in class org.acemq.workloads.endurance.Verdict
knownUpstream - Variable in class org.acemq.workloads.endurance.EnduranceConfig
KnownUpstream() - Constructor for class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream

L

label() - Method in enum class org.acemq.workloads.scenario.QueueType
lang() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the lang record component.
lang() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the lang record component.
LANGUAGES - Static variable in class org.acemq.workloads.endurance.EnduranceConfig: The five standing loads the workspace has, in the order the soak always listed them.
lastSampleAge() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the lastSampleAge record component.
LatencyRecorder - Class in org.acemq.workloads.metrics: Records latencies, from many threads, without distorting them.
LatencyRecorder(String) - Constructor for class org.acemq.workloads.metrics.LatencyRecorder
LatencySummary - Class in org.acemq.workloads.metrics: Latency percentiles from one run.
launch - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Per-client launch settings, laid over the defaults field by field.
Launch() - Constructor for class org.acemq.workloads.endurance.EnduranceConfig.Launch
launched() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns the value of the launched record component.
launchFor(String) - Method in class org.acemq.workloads.endurance.EnduranceConfig
LoadsCli - Class in org.acemq.workloads.endurance: java -jar acemq-workload.jar loads up|down|status: the standing loads a chaos drill watches, started, stopped and reported on through the same ClientLauncher the soak uses.

M

main(String[]) - Static method in class org.acemq.workloads.cli.Cli
management - Variable in class org.acemq.workloads.endurance.EnduranceConfig: The management API the fault and the connection counts go through.
management() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the management record component.
management(String, String, String) - Method in class org.acemq.workloads.Workload.Builder: The management API, for queue depth and topology facts the AMQP connection cannot see.
managementFault(EnduranceConfig) - Static method in class org.acemq.workloads.endurance.Endurance
managementPassword - Variable in class org.acemq.workloads.endurance.EnduranceConfig
managementUser - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Management credentials; taken from the broker URL when not given.
markdown(String, int, int, int, EnduranceConfig.Allowances, String) - Method in class org.acemq.workloads.endurance.Verdict: The report, byte for byte in the format scripts/soak.sh wrote and release-preflight.sh reads: a **PASSED** or **FAILED** line, the reasons as - bullets under "## What failed", and allowed breaches under "## Known upstream".
mask(String) - Static method in class org.acemq.workloads.scenario.YamlComments
max() - Method in class org.acemq.workloads.metrics.LatencySummary
maxErrorRate(double) - Method in class org.acemq.workloads.Ramp
maxInFlight() - Method in class org.acemq.workloads.PublisherSpec
maxInFlight() - Method in class org.acemq.workloads.scenario.ProducerNode
maxInFlight() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the maxInFlight record component.
maxInFlight(int) - Method in class org.acemq.workloads.PublisherSpec: How many publishes a thread may have outstanding before it waits.
maxInFlight(int) - Method in class org.acemq.workloads.scenario.ProducerNode
maxMessages() - Method in class org.acemq.workloads.PublisherSpec
maxMessages() - Method in class org.acemq.workloads.scenario.ProducerNode
maxMessages() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the maxMessages record component.
maxMessages(long) - Method in class org.acemq.workloads.PublisherSpec
maxMessages(long) - Method in class org.acemq.workloads.scenario.ProducerNode
maxRate(long) - Method in class org.acemq.workloads.Ramp
mean() - Method in class org.acemq.workloads.metrics.LatencySummary
MEASURING - Enum constant in enum class org.acemq.workloads.Sample.Phase: Running, and counting.
memoryFactor - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Allowances
messageSize() - Method in class org.acemq.workloads.scenario.ProducerNode
messageSize() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the messageSize record component.
messageSize(int) - Method in class org.acemq.workloads.PublisherSpec
messageSize(int) - Method in class org.acemq.workloads.scenario.ProducerNode
metricNames() - Static method in class org.acemq.workloads.rules.Threshold
min() - Method in class org.acemq.workloads.metrics.LatencySummary
mirrored() - Method in class org.acemq.workloads.scenario.QueueNode: A classic queue mirrored by an HA policy.
mode() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns the value of the mode record component.

N

name() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the name record component.
name() - Method in class org.acemq.workloads.metrics.LatencySummary
name() - Method in class org.acemq.workloads.RampReport
name() - Method in interface org.acemq.workloads.rules.Rule
name() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
name() - Method in class org.acemq.workloads.scenario.ExchangeNode
name() - Method in interface org.acemq.workloads.scenario.Node
name() - Method in class org.acemq.workloads.scenario.ProducerNode
name() - Method in class org.acemq.workloads.scenario.QueueNode
name() - Method in class org.acemq.workloads.scenario.Scenario
name() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the name record component.
name() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns the value of the name record component.
name() - Method in class org.acemq.workloads.Workload
name() - Method in class org.acemq.workloads.WorkloadReport
named(String) - Static method in class org.acemq.workloads.rules.Threshold
named(String) - Static method in class org.acemq.workloads.scenario.Scenario
named(String) - Static method in class org.acemq.workloads.Workload
needsPolicy() - Method in enum class org.acemq.workloads.scenario.QueueType
noBacklog() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the noBacklog record component.
noBacklog(boolean) - Method in class org.acemq.workloads.scenario.Expect: The queue must not be deeper at the end than it was at the start.
Node - Interface in org.acemq.workloads.scenario: Something in a scenario that can be switched off without being removed.
noFailures() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the noFailures record component.
noFailures(boolean) - Method in class org.acemq.workloads.scenario.Expect
noMessagesLost() - Static method in class org.acemq.workloads.rules.Objective: Every published message must arrive.
none() - Method in class org.acemq.workloads.ConsumerSpec: Runs with no consumers at all.
none() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
NONE - Static variable in interface org.acemq.workloads.RunListener: Does nothing, for a run nobody is watching.
NONE - Static variable in interface org.acemq.workloads.scenario.ScenarioListener: Does nothing, for a run nobody is watching.
notes() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the notes record component.

O

Objective - Class in org.acemq.workloads.rules: What the run has to achieve to count as a pass.
observation() - Method in class org.acemq.workloads.rules.Finding
of(String, String, String) - Static method in class org.acemq.workloads.scenario.BrokerCapabilities: Asks the broker what it is.
of(String, Severity, String, String) - Static method in class org.acemq.workloads.rules.Finding
of(String, Severity, String, String, String) - Static method in class org.acemq.workloads.rules.Finding
of(List<Reading>, List<Long>, int, EnduranceConfig.Allowances, List<EnduranceConfig.KnownUpstream>) - Static method in class org.acemq.workloads.endurance.Verdict
of(Scenario, String, String, Map<String, Object>) - Static method in record class org.acemq.workloads.scenario.ScenarioFile
of(Scenario, String, String, Map<String, Object>, ScenarioFile.SecurityJson) - Static method in record class org.acemq.workloads.scenario.ScenarioFile: The same, keeping a security block the caller already has.
of(Workload) - Static method in class org.acemq.workloads.Ramp
ofBytes(int) - Static method in class org.acemq.workloads.Payload
offeredRate() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the offeredRate record component.
offeredRate() - Method in class org.acemq.workloads.WorkloadReport
ofRandomBytes(int) - Static method in class org.acemq.workloads.Payload: Random bytes after the header.
OK - Static variable in class org.acemq.workloads.endurance.LoadsCli
on(String) - Method in class org.acemq.workloads.rules.Threshold
onFailed(Throwable) - Method in interface org.acemq.workloads.RunListener: The run ended without producing a report.
onFailed(Throwable) - Method in interface org.acemq.workloads.scenario.ScenarioListener
onFinished(ScenarioReport) - Method in interface org.acemq.workloads.scenario.ScenarioListener
onFinished(WorkloadReport) - Method in interface org.acemq.workloads.RunListener: The run finished, whether it passed, failed or was stopped early.
onPhase(Sample.Phase) - Method in interface org.acemq.workloads.RunListener: The run moved from one phase to another.
onPhase(Sample.Phase) - Method in interface org.acemq.workloads.scenario.ScenarioListener
onSample(Sample) - Method in interface org.acemq.workloads.RunListener: A reading, taken about once a second.
onSample(ScenarioSample) - Method in interface org.acemq.workloads.scenario.ScenarioListener: A reading, taken about once a second, node by node.
org.acemq.workloads - package org.acemq.workloads
org.acemq.workloads.cli - package org.acemq.workloads.cli
org.acemq.workloads.endurance - package org.acemq.workloads.endurance
org.acemq.workloads.metrics - package org.acemq.workloads.metrics
org.acemq.workloads.report - package org.acemq.workloads.report
org.acemq.workloads.rules - package org.acemq.workloads.rules
org.acemq.workloads.scenario - package org.acemq.workloads.scenario

P

p50() - Method in class org.acemq.workloads.metrics.LatencySummary
p50Below() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the p50Below record component.
p50Below(Duration) - Method in class org.acemq.workloads.scenario.Expect
p50BelowValue() - Method in class org.acemq.workloads.scenario.Expect
p90() - Method in class org.acemq.workloads.metrics.LatencySummary
p99() - Method in class org.acemq.workloads.metrics.LatencySummary
p999() - Method in class org.acemq.workloads.metrics.LatencySummary
p9999() - Method in class org.acemq.workloads.metrics.LatencySummary
p999Below() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the p999Below record component.
p999Below(Duration) - Method in class org.acemq.workloads.scenario.Expect: The tail, which is where a queue's real behaviour shows.
p999BelowValue() - Method in class org.acemq.workloads.scenario.Expect
p99Below() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the p99Below record component.
p99Below(Duration) - Static method in class org.acemq.workloads.rules.Objective
p99Below(Duration) - Method in class org.acemq.workloads.scenario.Expect
p99BelowValue() - Method in class org.acemq.workloads.scenario.Expect
parse(String) - Static method in record class org.acemq.workloads.endurance.Reading
parse(String) - Static method in enum class org.acemq.workloads.scenario.QueueType
parse(String, String) - Static method in class org.acemq.workloads.scenario.ScenarioReader: A scenario somebody handed over, rather than one read from disk.
parseYaml(String, Function<String, String>) - Static method in class org.acemq.workloads.cli.WorkloadFile: Reads workload YAML that is already in memory, exactly as WorkloadFile.read(Path) reads a file.
passed() - Method in class org.acemq.workloads.endurance.Verdict
passed() - Method in class org.acemq.workloads.RampReport
passed() - Method in class org.acemq.workloads.scenario.ScenarioReport
passed() - Method in class org.acemq.workloads.WorkloadReport
PASSED - Static variable in class org.acemq.workloads.endurance.EnduranceCli
payload() - Method in class org.acemq.workloads.PublisherSpec
payload() - Method in class org.acemq.workloads.scenario.ProducerNode
payload(Payload) - Method in class org.acemq.workloads.PublisherSpec
payload(Payload) - Method in class org.acemq.workloads.scenario.ProducerNode: What the messages are made of.
Payload - Class in org.acemq.workloads: The bytes a workload publishes, and the header this library needs inside them.
percentile(double) - Method in class org.acemq.workloads.metrics.LatencySummary
percentileBelow(double, Duration) - Static method in class org.acemq.workloads.rules.Objective
perRecovery - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream
phase() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the phase record component.
phase() - Method in record class org.acemq.workloads.Sample: Returns the value of the phase record component.
phase() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the phase record component.
phase(String) - Method in interface org.acemq.workloads.endurance.Endurance.Listener
pid() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns the value of the pid record component.
pid() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the pid record component.
plus - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream
prefetch() - Method in class org.acemq.workloads.ConsumerSpec
prefetch() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
prefetch() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns the value of the prefetch record component.
prefetch(int) - Method in class org.acemq.workloads.ConsumerSpec: How many unacknowledged messages a consumer will hold.
prefetch(int) - Method in class org.acemq.workloads.scenario.ConsumerGroupNode: How many unacknowledged messages each consumer may hold.
problems() - Method in class org.acemq.workloads.scenario.Scenario: What is wrong with this scenario, before a broker sees any of it.
problems() - Method in class org.acemq.workloads.WorkloadReport
ProcessSampler - Interface in org.acemq.workloads.endurance: What a process is holding, read from outside it.
ProcessSampler.Proc - Class in org.acemq.workloads.endurance: Linux: /proc/<pid>/status for VmRSS and Threads, and the entries of /proc/<pid>/fd for descriptors.
ProcessSampler.PsLsof - Class in org.acemq.workloads.endurance: macOS and other Unixes: ps -o rss=, lsof -p and ps -M, counted exactly as scripts/soak.sh counted them so a report from either compares with the other: every line lsof prints, header included, and every thread line ps prints after its header.
ProcessSampler.Usage - Record Class in org.acemq.workloads.endurance
producer(String, Consumer<ProducerNode>) - Method in class org.acemq.workloads.scenario.Scenario
ProducerJson(String, String, List<String>, Long, Integer, Integer, Boolean, Integer, Long, Boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: A producer that is asked to prove nothing in particular.
ProducerJson(String, String, List<String>, Long, Integer, Integer, Boolean, Integer, Long, Boolean, ScenarioFile.ExpectJson) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Creates an instance of a ProducerJson record class.
ProducerNode - Class in org.acemq.workloads.scenario: One source of load, aimed at one exchange.
ProducerResult(String, long, long, long, long, LatencySummary, LatencySummary, Expect) - Constructor for record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Creates an instance of a ProducerResult record class.
producers() - Method in class org.acemq.workloads.scenario.Scenario
producers() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the producers record component.
producers() - Method in class org.acemq.workloads.scenario.ScenarioReport
producers() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the producers record component.
ProducerSample(String, long, long, long, long, double, LatencySummary) - Constructor for record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Creates an instance of a ProducerSample record class.
PsLsof() - Constructor for class org.acemq.workloads.endurance.ProcessSampler.PsLsof
published() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the published record component.
published() - Method in record class org.acemq.workloads.Sample: Returns the value of the published record component.
published() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the published record component.
published() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the published record component.
published() - Method in class org.acemq.workloads.WorkloadReport
publishers() - Method in class org.acemq.workloads.Workload
publishers(Consumer<PublisherSpec>) - Method in class org.acemq.workloads.Workload.Builder
PublisherSpec - Class in org.acemq.workloads: How the load is offered.
publishesSucceeded() - Static method in class org.acemq.workloads.rules.Rules
publishLatency() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the publishLatency record component.
publishLatency() - Method in class org.acemq.workloads.WorkloadReport
publishRate() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the publishRate record component.
publishRate() - Method in record class org.acemq.workloads.Sample: Returns the value of the publishRate record component.
publishRate() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the publishRate record component.

Q

queue() - Method in class org.acemq.workloads.TopologySpec
queue(String) - Method in class org.acemq.workloads.scenario.Scenario
queue(String) - Method in class org.acemq.workloads.TopologySpec
queue(String, Consumer<QueueNode>) - Method in class org.acemq.workloads.scenario.Scenario
queueArguments() - Method in class org.acemq.workloads.TopologySpec
queueDepth() - Method in record class org.acemq.workloads.Sample: Returns the value of the queueDepth record component.
queueDepthAtEnd() - Method in class org.acemq.workloads.WorkloadReport
QueueJson(String, String, Boolean, Boolean, String, List<ScenarioFile.BindingJson>, ScenarioFile.ConsumersJson, Map<String, Object>) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: A queue that is asked to prove nothing in particular.
QueueJson(String, String, Boolean, Boolean, String, List<ScenarioFile.BindingJson>, ScenarioFile.ConsumersJson, Map<String, Object>, ScenarioFile.ExpectJson) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: A queue on the broker the scenario runs against.
QueueJson(String, String, Boolean, Boolean, String, List<ScenarioFile.BindingJson>, ScenarioFile.ConsumersJson, Map<String, Object>, ScenarioFile.ExpectJson, String) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Creates an instance of a QueueJson record class.
queueName() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
QueueNode - Class in org.acemq.workloads.scenario: A queue in a scenario, its bindings, and the consumers on it.
QueueResult(String, QueueType, int, long, LatencySummary, Long, Long, Expect) - Constructor for record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Creates an instance of a QueueResult record class.
queues() - Method in class org.acemq.workloads.scenario.Scenario
queues() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the queues record component.
queues() - Method in class org.acemq.workloads.scenario.ScenarioReport
queues() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns the value of the queues record component.
QueueSample(String, long, double, Long, LatencySummary, boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Creates an instance of a QueueSample record class.
queueType() - Method in class org.acemq.workloads.TopologySpec
QueueType - Enum Class in org.acemq.workloads.scenario: The kinds of queue a scenario can ask for.
queueTypes() - Method in class org.acemq.workloads.scenario.BrokerCapabilities
quorum() - Method in class org.acemq.workloads.scenario.QueueNode
quorum() - Method in class org.acemq.workloads.TopologySpec: A quorum queue: replicated, durable, and slower than classic by design.
QUORUM - Enum constant in enum class org.acemq.workloads.scenario.QueueType: Replicated by Raft, durable, and slower than classic by design.

R

ramp() - Method in class org.acemq.workloads.RampReport
ramp(int) - Method in class org.acemq.workloads.cli.WorkloadFile
Ramp - Class in org.acemq.workloads: Steps the offered rate up until something gives, to find the highest rate a broker sustains.
RampReport - Class in org.acemq.workloads: What a Ramp found: every step, the highest rate that met every rule and objective, and what stopped it.
RampReport.Step - Record Class in org.acemq.workloads: One step.
rate() - Method in class org.acemq.workloads.PublisherSpec
rate() - Method in record class org.acemq.workloads.RampReport.Step: Returns the value of the rate record component.
rate() - Method in class org.acemq.workloads.scenario.ProducerNode
rate() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the rate record component.
rate(long) - Method in class org.acemq.workloads.PublisherSpec: The offered rate, in messages per second, across all publisher threads.
rate(long) - Method in class org.acemq.workloads.scenario.ProducerNode
reachedMaxRate() - Method in class org.acemq.workloads.RampReport
read(Path) - Static method in class org.acemq.workloads.cli.WorkloadFile
read(Path) - Static method in class org.acemq.workloads.endurance.EnduranceConfig
read(Path) - Static method in class org.acemq.workloads.scenario.ScenarioReader
reading(Reading) - Method in interface org.acemq.workloads.endurance.Endurance.Listener
Reading - Record Class in org.acemq.workloads.endurance: One client, read once from outside: one line of the readings TSV.
Reading(long, String, String, long, long, long, long, long, long) - Constructor for record class org.acemq.workloads.endurance.Reading: Creates an instance of a Reading record class.
readingGapSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig
readings - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Readings taken for the baseline and again at the end; the verdict takes the median.
readings() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the readings record component.
record(long) - Method in class org.acemq.workloads.metrics.LatencyRecorder
recovery() - Method in class org.acemq.workloads.endurance.Verdict
redact(String) - Static method in class org.acemq.workloads.scenario.ScenarioReader
refine(int) - Method in class org.acemq.workloads.Ramp
refinement() - Method in record class org.acemq.workloads.RampReport.Step: Returns the value of the refinement record component.
Refinement - Search tag in class org.acemq.workloads.Ramp: Section
refused() - Method in record class org.acemq.workloads.Sample: Returns the value of the refused record component.
refused() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the refused record component.
report() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the report record component.
report() - Method in record class org.acemq.workloads.RampReport.Step: Returns the value of the report record component.
report() - Method in class org.acemq.workloads.RunHandle: The report, when there is one.
report() - Method in class org.acemq.workloads.scenario.ScenarioHandle
reportDir - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Relative to the workspace unless absolute.
Reports - Class in org.acemq.workloads.report: Renders runs as JSON, Markdown or HTML.
requiresNoBacklog() - Method in class org.acemq.workloads.scenario.Expect
requiresNoFailures() - Method in class org.acemq.workloads.scenario.Expect
reset() - Method in class org.acemq.workloads.metrics.LatencyRecorder: Discards everything recorded so far, which is how warm-up is excluded.
Result(String, Verdict, Path, Path, Path, List<Reading>) - Constructor for record class org.acemq.workloads.endurance.Endurance.Result: Creates an instance of a Result record class.
retainsMessages() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Whether this kind of queue keeps messages after they have been read.
routingKey() - Method in record class org.acemq.workloads.scenario.Binding: Returns the value of the routingKey record component.
routingKey() - Method in class org.acemq.workloads.scenario.ProducerNode
routingKey() - Method in record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Returns the value of the routingKey record component.
routingKey() - Method in class org.acemq.workloads.TopologySpec: The key publishes go out with.
routingKey(String) - Method in class org.acemq.workloads.TopologySpec
routingKeys() - Method in class org.acemq.workloads.scenario.ProducerNode
routingKeys() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the routingKeys record component.
routingKeys(String...) - Method in class org.acemq.workloads.scenario.ProducerNode: Publishes across several keys, one after another.
Row(String, long, long, long, long, long, long, List<String>) - Constructor for record class org.acemq.workloads.endurance.Verdict.Row: Creates an instance of a Row record class.
rows() - Method in class org.acemq.workloads.endurance.Verdict
rssAfter() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the rssAfter record component.
rssBefore() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the rssBefore record component.
rssKb() - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Returns the value of the rssKb record component.
rssKb() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the rssKb record component.
rule() - Method in class org.acemq.workloads.rules.Finding
rule(Rule) - Method in class org.acemq.workloads.Workload.Builder
Rule - Interface in org.acemq.workloads.rules: Something checked against a finished run.
rules() - Method in class org.acemq.workloads.Workload
Rules - Class in org.acemq.workloads.rules: The rules that run on every workload, whether or not anybody asked for them.
run() - Method in class org.acemq.workloads.endurance.Endurance: Runs the soak.
run(String) - Method in class org.acemq.workloads.Ramp
run(String) - Method in class org.acemq.workloads.Workload.Builder
run(String) - Method in class org.acemq.workloads.Workload: Runs it.
run(String[], PrintStream, PrintStream) - Static method in class org.acemq.workloads.endurance.EnduranceCli
run(String[], PrintStream, PrintStream) - Static method in class org.acemq.workloads.endurance.LoadsCli
run(String, Security) - Method in class org.acemq.workloads.Ramp
run(String, Security) - Method in class org.acemq.workloads.Workload: Runs it against a broker that needs more than a URL to reach.
run(Function<Workload, WorkloadReport>) - Method in class org.acemq.workloads.Ramp: Runs the ramp with each step run by the caller — the command line uses this so a step can be stopped by a signal and still report.
run(Scenario, String) - Static method in class org.acemq.workloads.scenario.ScenarioRunner: Runs it and waits.
run(Scenario, String, Security) - Static method in class org.acemq.workloads.scenario.ScenarioRunner: Runs it against a broker that needs TLS, and waits.
run(Scenario, String, Security, ScenarioListener, AtomicBoolean) - Static method in class org.acemq.workloads.scenario.ScenarioRunner: Runs it on this thread, reporting as it goes and stopping when asked.
runFor() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the runFor record component.
runFor(Duration) - Method in class org.acemq.workloads.scenario.Scenario
runFor(Duration) - Method in class org.acemq.workloads.Workload.Builder
RunHandle - Class in org.acemq.workloads: A run in progress.
RunListener - Interface in org.acemq.workloads: Watches a run as it happens.
running() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the running record component.
runsUntilStopped() - Method in class org.acemq.workloads.Workload
runUntilStopped() - Method in class org.acemq.workloads.Workload.Builder: Measure until something stops the run.
runWasLongEnough() - Static method in class org.acemq.workloads.rules.Rules

S

sample(long) - Method in class org.acemq.workloads.endurance.ProcessSampler.Proc
sample(long) - Method in class org.acemq.workloads.endurance.ProcessSampler.PsLsof
sample(long) - Method in interface org.acemq.workloads.endurance.ProcessSampler
Sample - Record Class in org.acemq.workloads: One reading taken while a workload is running.
Sample(Instant, Duration, Sample.Phase, long, long, long, long, long, double, double, LatencySummary, LatencySummary, Long, boolean) - Constructor for record class org.acemq.workloads.Sample: Creates an instance of a Sample record class.
Sample.Phase - Enum Class in org.acemq.workloads: What a run is doing when a reading is taken.
samples() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns the value of the samples record component.
samples() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns the value of the samples record component.
samples() - Method in class org.acemq.workloads.WorkloadReport: What the run looked like as it went, one entry per sampling interval.
sampleSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig
say(String) - Method in interface org.acemq.workloads.endurance.Endurance.Listener
scenario() - Method in class org.acemq.workloads.scenario.ScenarioHandle
scenario() - Method in class org.acemq.workloads.scenario.ScenarioReport
Scenario - Class in org.acemq.workloads.scenario: A whole topology under load, rather than one queue.
ScenarioFile - Record Class in org.acemq.workloads.scenario: A scenario as a file.
ScenarioFile(String, String, String, String, List<ScenarioFile.ExchangeJson>, List<ScenarioFile.QueueJson>, List<ScenarioFile.ProducerJson>, String, String, Boolean, Map<String, Object>) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile: A file written before security: existed.
ScenarioFile(String, String, String, String, List<ScenarioFile.ExchangeJson>, List<ScenarioFile.QueueJson>, List<ScenarioFile.ProducerJson>, String, String, Boolean, ScenarioFile.SecurityJson, Map<String, Object>) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile: Creates an instance of a ScenarioFile record class.
ScenarioFile.BindingJson - Record Class in org.acemq.workloads.scenario
ScenarioFile.ConsumersJson - Record Class in org.acemq.workloads.scenario
ScenarioFile.ExchangeJson - Record Class in org.acemq.workloads.scenario: An exchange.
ScenarioFile.ExpectJson - Record Class in org.acemq.workloads.scenario: What a node is asked to prove, in a file.
ScenarioFile.ProducerJson - Record Class in org.acemq.workloads.scenario
ScenarioFile.QueueJson - Record Class in org.acemq.workloads.scenario: A queue, its bindings and its consumers.
ScenarioFile.SecurityJson - Record Class in org.acemq.workloads.scenario: How to reach a broker over TLS.
ScenarioFormatException(String) - Constructor for exception class org.acemq.workloads.scenario.ScenarioReader.ScenarioFormatException
ScenarioFormatException(String, Throwable) - Constructor for exception class org.acemq.workloads.scenario.ScenarioReader.ScenarioFormatException
ScenarioHandle - Class in org.acemq.workloads.scenario: A scenario in progress.
ScenarioListener - Interface in org.acemq.workloads.scenario: Watches a scenario as it runs.
ScenarioReader - Class in org.acemq.workloads.scenario: Reads a scenario file from disk.
ScenarioReader.ScenarioFormatException - Exception Class in org.acemq.workloads.scenario: A scenario file that cannot be read, with what is wrong with it.
ScenarioReport - Class in org.acemq.workloads.scenario: What a scenario did, node by node.
ScenarioReport.ProducerResult - Record Class in org.acemq.workloads.scenario: What one producer managed.
ScenarioReport.QueueResult - Record Class in org.acemq.workloads.scenario: What one queue saw.
ScenarioReports - Class in org.acemq.workloads.report: A scenario's report as a file.
ScenarioRunner - Class in org.acemq.workloads.scenario: Starts scenarios.
ScenarioSample - Record Class in org.acemq.workloads.scenario: One reading of a whole scenario, node by node.
ScenarioSample(Instant, Duration, Sample.Phase, List<ScenarioSample.ProducerSample>, List<ScenarioSample.QueueSample>, boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioSample: Creates an instance of a ScenarioSample record class.
ScenarioSample.ProducerSample - Record Class in org.acemq.workloads.scenario: What one producer is doing.
ScenarioSample.QueueSample - Record Class in org.acemq.workloads.scenario: What one queue is doing.
Secrets do not belong in this file - Search tag in class org.acemq.workloads.cli.WorkloadFile: Section
security() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the security record component.
SecurityJson(String, String, String, Boolean) - Constructor for record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Creates an instance of a SecurityJson record class.
sendLag() - Method in record class org.acemq.workloads.Sample: Returns the value of the sendLag record component.
sendLag() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns the value of the sendLag record component.
sendLag() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns the value of the sendLag record component.
sendLag() - Method in class org.acemq.workloads.WorkloadReport
sequence(byte[]) - Static method in class org.acemq.workloads.Payload
series(List<Reading>) - Static method in class org.acemq.workloads.endurance.Verdict: Per client, every reading as [minutes from the first reading, RSS in MB, fds, threads]: the shape the console's chart draws.
severity() - Method in class org.acemq.workloads.rules.Finding
severity(Severity) - Method in class org.acemq.workloads.rules.Threshold
Severity - Enum Class in org.acemq.workloads.rules: How much a Finding matters, worst first.
shouldDeclare() - Method in class org.acemq.workloads.scenario.Scenario
shouldDeclare() - Method in class org.acemq.workloads.TopologySpec
size() - Method in class org.acemq.workloads.cli.WorkloadFile
size() - Method in class org.acemq.workloads.Payload
spec() - Method in class org.acemq.workloads.WorkloadReport
stamp() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the stamp record component.
start() - Method in class org.acemq.workloads.endurance.ClientLauncher: Starts every configured client that is not already running, adopts those that are, and waits until each one has written its first sample.
start() - Method in class org.acemq.workloads.Ramp
start(String, Security, RunListener) - Method in class org.acemq.workloads.Workload: Starts it against a broker that needs more than a URL to reach.
start(String, RunListener) - Method in class org.acemq.workloads.Workload: Starts it on a thread of its own, and reports as it goes.
start(Scenario, String, Security, ScenarioListener) - Static method in class org.acemq.workloads.scenario.ScenarioRunner: Starts it against a broker that needs TLS.
start(Scenario, String, ScenarioListener) - Static method in class org.acemq.workloads.scenario.ScenarioRunner: Starts it on a thread of its own and reports as it goes.
startAt(long) - Method in class org.acemq.workloads.Ramp
startedAt() - Method in class org.acemq.workloads.scenario.ScenarioReport
startedAt() - Method in class org.acemq.workloads.WorkloadReport
STARTING - Enum constant in enum class org.acemq.workloads.Sample.Phase: Declaring the topology and starting publishers and consumers.
startupSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig: How long a load has to write its first sample before it counts as one that will not start.
stateDir - Variable in class org.acemq.workloads.endurance.EnduranceConfig: Pid files, sample files and raw readings; relative to the workspace unless absolute.
status() - Method in class org.acemq.workloads.endurance.ClientLauncher
status() - Method in class org.acemq.workloads.endurance.Verdict
Status(String, boolean, long, Duration, double, double, Path) - Constructor for record class org.acemq.workloads.endurance.ClientLauncher.Status: Creates an instance of a Status record class.
Step(long, boolean, WorkloadReport, String) - Constructor for record class org.acemq.workloads.RampReport.Step: Creates an instance of a Step record class.
stepBy(long) - Method in class org.acemq.workloads.Ramp
stepByPercent(double) - Method in class org.acemq.workloads.Ramp
stepFor(Duration) - Method in class org.acemq.workloads.Ramp
steps() - Method in class org.acemq.workloads.RampReport
stop() - Method in class org.acemq.workloads.Ramp: Ends the ramp after the step now running.
stop() - Method in class org.acemq.workloads.RunHandle: Ends the run early and reports on what it measured.
stop() - Method in class org.acemq.workloads.scenario.ScenarioHandle: Ends the run early and reports on what it measured.
stop(List<ClientLauncher.Client>) - Method in class org.acemq.workloads.endurance.ClientLauncher: Stops what this run started.
stopAll() - Method in class org.acemq.workloads.endurance.ClientLauncher: Stops every configured client found by its pid file, whoever started it, and removes stale pid files.
stoppedBy() - Method in record class org.acemq.workloads.RampReport.Step: Returns the value of the stoppedBy record component.
stoppedBy() - Method in class org.acemq.workloads.RampReport
stoppingFinding() - Method in class org.acemq.workloads.RampReport
stoppingStep() - Method in class org.acemq.workloads.RampReport
stopReason() - Method in class org.acemq.workloads.RampReport
stream() - Method in class org.acemq.workloads.scenario.QueueNode
STREAM - Enum constant in enum class org.acemq.workloads.scenario.QueueType: An append-only log, read by offset.
summary() - Method in class org.acemq.workloads.metrics.LatencyRecorder
supports(QueueType) - Method in class org.acemq.workloads.scenario.BrokerCapabilities
sustained() - Method in record class org.acemq.workloads.RampReport.Step

T

table() - Method in class org.acemq.workloads.endurance.Verdict
tailIsNotExtreme() - Static method in class org.acemq.workloads.rules.Rules
tailRatio() - Method in class org.acemq.workloads.metrics.LatencySummary
The broker can come from outside the file - Search tag in class org.acemq.workloads.cli.WorkloadFile: Section
threadCount() - Method in class org.acemq.workloads.PublisherSpec
threadCount() - Method in class org.acemq.workloads.scenario.ProducerNode: How many threads this producer actually needs.
threads - Variable in class org.acemq.workloads.endurance.EnduranceConfig.Allowances
threads() - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Returns the value of the threads record component.
threads() - Method in record class org.acemq.workloads.endurance.Reading: Returns the value of the threads record component.
threads() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns the value of the threads record component.
threads(int) - Method in class org.acemq.workloads.PublisherSpec
threads(int) - Method in class org.acemq.workloads.scenario.ProducerNode
threadsAfter() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the threadsAfter record component.
Threads and rate are separate on purpose - Search tag in class org.acemq.workloads.PublisherSpec: Section
threadsBefore() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns the value of the threadsBefore record component.
Three things kept apart - Search tag in class org.acemq.workloads.Workload: Section
Threshold - Class in org.acemq.workloads.rules: A rule written as a threshold on one number in the report — the shape of the admin library's alerts, so a rule reads the same whether it watches a broker or judges a run.
throughputAtLeast(long) - Static method in class org.acemq.workloads.rules.Objective
to(String, String) - Method in class org.acemq.workloads.scenario.ProducerNode
toHtml(List<WorkloadReport>) - Static method in class org.acemq.workloads.report.Reports
toHtml(List<WorkloadReport>, List<RampReport>) - Static method in class org.acemq.workloads.report.Reports
toHtml(ScenarioReport) - Static method in class org.acemq.workloads.report.ScenarioReports
toJson(List<WorkloadReport>) - Static method in class org.acemq.workloads.report.Reports
toJson(List<WorkloadReport>, List<RampReport>) - Static method in class org.acemq.workloads.report.Reports
toJson(ScenarioReport) - Static method in class org.acemq.workloads.report.ScenarioReports
tolerance(double) - Method in class org.acemq.workloads.Ramp
toMarkdown(List<WorkloadReport>) - Static method in class org.acemq.workloads.report.Reports
toMarkdown(List<WorkloadReport>, List<RampReport>) - Static method in class org.acemq.workloads.report.Reports
toMarkdown(ScenarioReport) - Static method in class org.acemq.workloads.report.ScenarioReports
topology() - Method in class org.acemq.workloads.Workload
topology(Consumer<TopologySpec>) - Method in class org.acemq.workloads.Workload.Builder
TopologySpec - Class in org.acemq.workloads: What the workload publishes to and consumes from.
toScenario() - Method in record class org.acemq.workloads.scenario.ScenarioFile
toSecurity() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson
toString() - Method in class org.acemq.workloads.ConsumerSpec
toString() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Client: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.endurance.ClientLauncher.Status: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.endurance.ProcessSampler.Usage: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.endurance.Reading: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.endurance.Verdict.Row: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.metrics.LatencyRecorder
toString() - Method in class org.acemq.workloads.metrics.LatencySummary
toString() - Method in class org.acemq.workloads.Payload
toString() - Method in class org.acemq.workloads.PublisherSpec
toString() - Method in class org.acemq.workloads.Ramp
toString() - Method in record class org.acemq.workloads.RampReport.Step: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.RampReport
toString() - Method in class org.acemq.workloads.rules.Finding
toString() - Method in class org.acemq.workloads.RunHandle
toString() - Method in record class org.acemq.workloads.Sample: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.Binding: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.scenario.BrokerCapabilities
toString() - Method in class org.acemq.workloads.scenario.ConsumerGroupNode
toString() - Method in class org.acemq.workloads.scenario.ExchangeNode
toString() - Method in class org.acemq.workloads.scenario.Expect
toString() - Method in class org.acemq.workloads.scenario.ProducerNode
toString() - Method in class org.acemq.workloads.scenario.QueueNode
toString() - Method in class org.acemq.workloads.scenario.Scenario
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.BindingJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ConsumersJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ProducerJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.scenario.ScenarioHandle
toString() - Method in record class org.acemq.workloads.scenario.ScenarioReport.ProducerResult: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.scenario.ScenarioReport
toString() - Method in record class org.acemq.workloads.scenario.ScenarioSample.ProducerSample: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioSample.QueueSample: Returns a string representation of this record class.
toString() - Method in record class org.acemq.workloads.scenario.ScenarioSample: Returns a string representation of this record class.
toString() - Method in class org.acemq.workloads.TopologySpec
toString() - Method in class org.acemq.workloads.Workload
toString() - Method in class org.acemq.workloads.WorkloadReport
totalConsumed() - Method in class org.acemq.workloads.scenario.ScenarioReport
totalConsumeRate() - Method in record class org.acemq.workloads.scenario.ScenarioSample
totalDepth() - Method in record class org.acemq.workloads.scenario.ScenarioSample
totalPublished() - Method in class org.acemq.workloads.scenario.ScenarioReport
totalPublishRate() - Method in record class org.acemq.workloads.scenario.ScenarioSample
transient_() - Method in class org.acemq.workloads.scenario.ExchangeNode
transient_() - Method in class org.acemq.workloads.scenario.QueueNode
truststore() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns the value of the truststore record component.
truststorePassword() - Method in record class org.acemq.workloads.scenario.ScenarioFile.SecurityJson: Returns the value of the truststorePassword record component.
tsv() - Method in record class org.acemq.workloads.endurance.Reading
type() - Method in class org.acemq.workloads.scenario.ExchangeNode
type() - Method in class org.acemq.workloads.scenario.QueueNode
type() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExchangeJson: Returns the value of the type record component.
type() - Method in record class org.acemq.workloads.scenario.ScenarioFile.QueueJson: Returns the value of the type record component.
type() - Method in record class org.acemq.workloads.scenario.ScenarioReport.QueueResult: Returns the value of the type record component.
type(String) - Method in class org.acemq.workloads.scenario.ExchangeNode
type(QueueType) - Method in class org.acemq.workloads.scenario.QueueNode

U

ui() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the ui record component.
unknown() - Static method in class org.acemq.workloads.scenario.BrokerCapabilities
Unknown keys are refused - Search tag in class org.acemq.workloads.cli.WorkloadFile: Section
unthrottled() - Method in class org.acemq.workloads.PublisherSpec: Publishes as fast as the client can, with no schedule.
unthrottled() - Method in class org.acemq.workloads.scenario.ProducerNode: As fast as it can, with no schedule.
Usage(long, long, long) - Constructor for record class org.acemq.workloads.endurance.ProcessSampler.Usage: Creates an instance of a Usage record class.
useExisting() - Method in class org.acemq.workloads.scenario.Scenario: Runs against the topology as it already exists.
useExisting() - Method in class org.acemq.workloads.TopologySpec: Uses the topology as it already exists rather than declaring it.
usesDefaultExchange() - Method in class org.acemq.workloads.TopologySpec

V

validate() - Method in class org.acemq.workloads.endurance.EnduranceConfig
Validity first - Search tag in class org.acemq.workloads.rules.Rules: Section
valueOf(String) - Static method in enum class org.acemq.workloads.rules.Severity: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.acemq.workloads.Sample.Phase: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.acemq.workloads.scenario.QueueType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.acemq.workloads.rules.Severity: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.acemq.workloads.Sample.Phase: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.acemq.workloads.scenario.QueueType: Returns an array containing the constants of this enum class, in the order they are declared.
verdict() - Method in record class org.acemq.workloads.endurance.Endurance.Result: Returns the value of the verdict record component.
verdict() - Method in record class org.acemq.workloads.endurance.Verdict.Row
verdict() - Method in class org.acemq.workloads.RampReport
Verdict - Class in org.acemq.workloads.endurance: The soak's verdict, from its readings: medians of the baseline and final readings per client, against the allowances, with known upstream breaches classified rather than failed.
Verdict.Row - Record Class in org.acemq.workloads.endurance: One client's before and after.
version() - Method in class org.acemq.workloads.scenario.BrokerCapabilities

W

warmup() - Method in class org.acemq.workloads.scenario.Scenario
warmup() - Method in record class org.acemq.workloads.scenario.ScenarioFile: Returns the value of the warmup record component.
warmup() - Method in class org.acemq.workloads.Workload
warmup(Duration) - Method in class org.acemq.workloads.scenario.Scenario
warmup(Duration) - Method in class org.acemq.workloads.Workload.Builder
WARMUP - Enum constant in enum class org.acemq.workloads.Sample.Phase: Running, with the numbers thrown away.
warmupEachStep(Duration) - Method in class org.acemq.workloads.Ramp
Warm-up is not measured - Search tag in class org.acemq.workloads.Workload: Section
warmupSeconds - Variable in class org.acemq.workloads.endurance.EnduranceConfig
WARNING - Enum constant in enum class org.acemq.workloads.rules.Severity: Something that changes how the result should be read.
warnings() - Method in class org.acemq.workloads.scenario.Scenario: Warnings about a scenario that will run but may not measure what was intended.
wasBlocked() - Method in class org.acemq.workloads.WorkloadReport
wasStoppedEarly() - Method in class org.acemq.workloads.scenario.ScenarioReport
What counts as a comment - Search tag in class org.acemq.workloads.scenario.YamlComments: Section
What stops it - Search tag in class org.acemq.workloads.Ramp: Section
why - Variable in class org.acemq.workloads.endurance.EnduranceConfig.KnownUpstream
Why a histogram and not a list - Search tag in class org.acemq.workloads.metrics.LatencyRecorder: Section
whyNot(QueueType) - Method in class org.acemq.workloads.scenario.BrokerCapabilities: Why a type is not on offer, in a sentence somebody can act on.
Why not PDF - Search tag in class org.acemq.workloads.report.Reports: Section
Why the intended time and not the actual one - Search tag in class org.acemq.workloads.Payload: Section
Why this is needed at all - Search tag in class org.acemq.workloads.scenario.YamlComments: Section
wireName() - Method in enum class org.acemq.workloads.scenario.QueueType
withBroker(String) - Method in class org.acemq.workloads.cli.WorkloadFile: Settles which broker each workload runs against, the command line winning over the file.
withinPercentOfOffered() - Method in record class org.acemq.workloads.scenario.ScenarioFile.ExpectJson: Returns the value of the withinPercentOfOffered record component.
withinPercentOfOffered(int) - Method in class org.acemq.workloads.scenario.Expect: How far the achieved rate may fall short of the offered one.
withinPercentOfOfferedValue() - Method in class org.acemq.workloads.scenario.Expect
withoutDefaultRules() - Method in class org.acemq.workloads.Workload.Builder: Runs without the default rules.
withRamp(String) - Method in class org.acemq.workloads.cli.WorkloadFile: Makes every workload in the file a ramp, from --ramp start=1000,step=10%,....
workload() - Method in class org.acemq.workloads.Ramp
workload() - Method in class org.acemq.workloads.RunHandle
Workload - Class in org.acemq.workloads: A load test, described.
Workload.Builder - Class in org.acemq.workloads: Builds a Workload.
WorkloadFile - Class in org.acemq.workloads.cli: Reads a workload, or a suite of them, from YAML or JSON.
WorkloadReport - Class in org.acemq.workloads: What one run measured, and what the rules made of it.
workloads() - Method in class org.acemq.workloads.cli.WorkloadFile
workspace - Variable in class org.acemq.workloads.endurance.EnduranceConfig: The workspace the default launch commands, reports and pid files are relative to.

Y

YamlComments - Class in org.acemq.workloads.scenario: Finds the comments in a YAML document, so that substitution can leave them alone.

A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form