CacheTestDelete checks that deletes work.

CacheTestDoubleAdd ensures that a double add returns an error.

CacheTestGetAndSet checks that we can set and then get n items.

CacheTestMissingKey checks that we get an error on missing key.

CacheTestOpenClose checks that the cache can be started, an item added, and then stopped.

CacheTestOptLogging allows components to log with the given log level.

CacheTestOptPort defines the port of the integration service.

CacheTestOptPreTest adds a closure to be executed before each test.

CacheTestOptTimeout describes an optional timeout spanning the entirety of the test suite.

CacheTestOptVarSet sets an arbitrary variable for the test that can be injected into templated configs.

CacheTests creates a list of tests from variadic arguments.

CheckSkip marks a test to be skipped unless the integration test has been specifically requested using the -run flag.

CheckSkipExact skips a test unless the -run flag specifically targets it.

GetFreePort attempts to get a free port.

StreamBenchs creates a list of benchmarks from variadic arguments.

StreamBenchSend benchmarks the speed at which messages are sent over the templated output and then subsequently received from the input with a given batch size and parallelism.

StreamBenchWrite benchmarks the speed at which messages can be written to the output, with no attempt made to consume the written data.

StreamTestAtLeastOnceDelivery ensures data is delivered through nacks and restarts.

StreamTestCheckpointCapture ensures that data received out of order doesn't result in wrongly acknowledged messages.

StreamTestMetadata ensures that we are able to send and receive metadata values.

StreamTestMetadataFilter ensures that we are able to send and receive metadata values, and that they are filtered.

StreamTestOpenClose ensures that both the input and output can be started and stopped within a reasonable length of time.

StreamTestOpenCloseIsolated ensures that both the input and output can be started and stopped within a reasonable length of time.

StreamTestOptAllowDupes specifies across all stream tests that in this environment we can expect duplicates and these are not considered errors.

StreamTestOptLogging allows components to log with the given log level.

StreamTestOptMaxInFlight configures a maximum inflight (to be injected into the config template) for all tests.

StreamTestOptPort defines the port of the integration service.

StreamTestOptPreTest adds a closure to be executed before each test.

StreamTestOptSleepAfterInput adds a sleep to tests after the input has been created.

StreamTestOptSleepAfterOutput adds a sleep to tests after the output has been created.

StreamTestOptTimeout describes an optional timeout spanning the entirety of the test suite.

StreamTestOptVarSet sets an arbitrary variable for the test that can be injected into templated configs.

StreamTestOutputOnlyOverride tests a config template without an input where duplicate IDs are sent (where we expect updates).

StreamTestOutputOnlySendBatch tests a config template without an input.

StreamTestOutputOnlySendSequential tests a config template without an input.

StreamTestReceiveBatchCount tests that batches can be consumed with an input configured batch count.

StreamTests creates a list of tests from variadic arguments.

StreamTestSendBatch ensures we can send a batch of a given size.

StreamTestSendBatchCount ensures we can send batches using a configured batch count.

StreamTestSendBatchCountIsolated checks batches can be sent and then received.

StreamTestSendBatches ensures that we can send N batches of M parallelism.

StreamTestStreamIsolated tests that data can be sent and received, where data is sent sequentially.

StreamTestStreamParallel tests data transfer with parallel senders.

StreamTestStreamParallelLossy ensures that data is delivered through parallel nacks.

StreamTestStreamParallelLossyThroughReconnect ensures data is delivered through nacks and restarts.

StreamTestStreamSaturatedUnacked writes N messages as a backlog, then consumes half of those messages without acking them, and then after a pause acknowledges them all and resumes consuming.

StreamTestStreamSequential tests that data can be sent and received, where data is sent sequentially.

CacheTestConfigVars exposes some variables injected into template configs for cache unit tests.

CacheTestDefinition encompasses a unit test to be executed against an integration environment.

StreamBenchDefinition encompasses a benchmark to be executed against an integration environment.

StreamTestConfigVars defines variables that will be accessed by test definitions when generating components through the config template.

StreamTestDefinition encompasses a unit test to be executed against an integration environment.

CachePreTestFn is an optional closure to be called before tests are run, this is an opportunity to mutate test config variables and mess with the environment.

CacheTestList is a list of cache test definitions that can be run with a single template and function args.

CacheTestOptFunc is an opt func for customizing the behaviour of cache tests, these are useful for things that are integration environment specific, such as the port of the service being interacted with.

GetMessageFunc is a closure used to extract message contents from an output directly and can be used to test outputs without the need for an input in the config template.

StreamBenchList is a list of stream benchmark definitions that can be run with a single template and function args.

StreamPreTestFn is an optional closure to be called before tests are run, this is an opportunity to mutate test config variables and mess with the environment.

StreamTestList is a list of stream definitions that can be run with a single template and function args.

StreamTestOptFunc is an opt func for customizing the behaviour of stream tests, these are useful for things that are integration environment specific, such as the port of the service being interacted with.