INNER CODE UNIT · Go
newStreamPerfTestCmd
rabbitmq/cluster-operator · kubectl-rabbitmq/commands.go:356
func newStreamPerfTestCmd(getExecutor func() *kubectlExecutor) *cobra.Command {
cmd := &cobra.Command{
Use: "stream-perf-test INSTANCE [STREAM_PERF_TEST_ARGS...]",
Short: "Create a Job to run stream-perf-test against an instance",
Long: `Create a Job to run stream-perf-test against an instance. You can pass any stream perf-test parameters.
See https://rabbitmq.github.io/rabbitmq-stream-java-client/snapshot/htmlsingle/ for more details.`,
Args: cobra.MinimumNArgs(1),
DisableFlagParsing: true,
DisableFlagsInUseLine: true,
RunE: func(cmd *cobra.Command, args []string) error {
executor := getExecutor()
instance := args[0]
streamPerfTestArgs := args[1:]
creds, err := getInstanceCredentials(executor, instance)
if err != nil {
return err
}