Add functions to create/delete super stream in manager

[acogoluegnes]

No description provided.

[acogoluegnes]

AC:

From the umbrella, check out the branch and start the broker:

git checkout super-stream-cli
make run-broker PLUGINS="rabbitmq_stream_management"

Check the help of the add_super_stream command works properly:

sbin/rabbitmqctl add_super_stream --help

It should output the descriptions and the options of command.

Create an invoice super stream:

sbin/rabbitmqctl add_super_stream invoices

Go to http://localhost:15672/#/exchanges/%2F/invoices to check the invoices exchange:

• durable direct exchange
• x-super-stream argument set to true
• 3 bindings to invoices- queues
• the bindings should have a x-stream-partition-order argument each that matches the index of each queue

Go to http://localhost:15672/#/queues to check the queues:

• there should be 3 queues, invoices-0, invoices-1, invoices-2
• they should all be streams

Delete the super stream:

sbin/rabbitmqctl delete_super_stream invoices

Make sure the exchange and the queues have been deleted.

Now create a super stream with 5 partitions (the default is 3)

sbin/rabbitmqctl add_super_stream invoices --partitions 5

Check the exchange and the partition streams have been created, with the appropriate bindings.

Delete the super stream:

sbin/rabbitmqctl delete_super_stream invoices

Make sure the exchange and the queues have been deleted.

Create a super stream using explicit routing keys:

sbin/rabbitmqctl add_super_stream invoices --routing-keys amer,emea,apac

Check the exchange:

• it should have 3 bindings
• the bindings should use the routing keys specified
• the order argument should match the order of the routing keys specified in the command line

Delete the super stream:

sbin/rabbitmqctl delete_super_stream invoices

Create a super stream with stream arguments:

sbin/rabbitmqctl add_super_stream invoices \
  --max-length-bytes 1gb --max-age PT10M \
  --stream-max-segment-size-bytes 50mb --leader-locator random \
  --initial-cluster-size 1

Check the created streams and make sure the specified arguments have been propagated to them.

Delete the super stream:

sbin/rabbitmqctl delete_super_stream invoices