mstanzurabbitmqdefinitions

Documentation

Index

• Variables
• func InitOrDie()

Variables

var (
	MsTanzuQueueName = "ms-tanzu"
	MsTanzuqueue     amqp091.Queue
)

Functions

func InitOrDie

func InitOrDie()

InitOrDie Exchange

	     -----------------
		 | Exchange: Ror | -
		 -----------------  \
				             \
			                  >  -------------------
					             | Exchange: Tanzu |
					             -------------------
                            /
                           /
                          /
     ----------------------
    | Queue: ms-tanzu      |
     ----------------------

Tanzu Exchange: - type: headers

• durable: true
• autoDelete: false
• internal: false
• noWait: false
• arguments: nil

Bindings:

• ROR -> Tanzu
• key: "provider.tanzu.#"
• noWait: false
• arguments: nil

Queue:

• Name: ms-tanzu
• Durable: true
• Arguments: x-queue-type: quorum
• Bindings:
• Exchange: Tanzu
• Routing Key: "resource.*"
• Arguments: x-match: all, apiVersion: general.ror.internal/v1alpha1, kind: ClusterOrder
• Bindings:
• Exchange: Tanzu
• Routing Key: "resource.*"
• Arguments: x-match: all, apiVersion: run.tanzu.vmware.com/v1alpha2, kind: TanzuKubernetesCluster

InitOrDie initializes the RabbitMQ definitions and panics if it fails It is called from the main function and it is blocking