mstalosrabbitmqdefinitions

Documentation

Index

• Variables
• func InitOrDie()

Variables

var (
	MsTalosQueueName = "ms-talos"
	MsTalosQueue     amqp091.Queue
)

Functions

func InitOrDie

func InitOrDie()

InitOrDie Exchange

	     -----------------
		 | Exchange: Ror | -
		 -----------------  \
				             \
			                  >  -------------------
					             | Exchange: talos |
					             -------------------
                            /
                           /
                          /
     ----------------------
    | Queue: ms-talos      |
     ----------------------

Talos Exchange: - type: headers

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

Bindings:

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

Queue:

• Name: ms-talos
• Durable: true
• Arguments: x-queue-type: quorum
• Bindings:
• Exchange: talos
• Routing Key: "resource.*"
• Arguments: x-match: all, apiVersion: general.ror.internal/v1alpha1, kind: ClusterOrder
• Bindings:
• Exchange: talos
• Routing Key: "resource.*"

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