Documentation
¶
Index ¶
- func RunAssertions(ctx context.Context, queueNames []string, testSpec *api.TestSpec, ...) error
- func RunSetup(ctx context.Context, testSpec *api.TestSpec, conn *client.ApiConnectionDetails, ...) ([]string, error)
- func RunTeardown(queueNames []string, testSpec *api.TestSpec, conn *client.ApiConnectionDetails, ...) error
- func RunUpdate(ctx context.Context, queueNames []string, testSpec *api.TestSpec, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunAssertions ¶
func RunAssertions(ctx context.Context, queueNames []string, testSpec *api.TestSpec, conn *client.ApiConnectionDetails, out io.Writer) error
RunAssertions checks queue state assertions. activeInPool is checked against testSpec.Queue (the queue jobs are submitted to); appearsInStream and matches are checked against every queue in queueNames, since a batched setup creates and updates many queues that must all be valid.
func RunSetup ¶
func RunSetup(ctx context.Context, testSpec *api.TestSpec, conn *client.ApiConnectionDetails, out io.Writer) ([]string, error)
RunSetup creates the queue(s) if configured and returns list of created queue names
func RunTeardown ¶
func RunTeardown(queueNames []string, testSpec *api.TestSpec, conn *client.ApiConnectionDetails, out io.Writer) error
RunTeardown deletes the queue(s).
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.