Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ApiEventsQueueName string = "sse-events" ApiEventsqueue amqp091.Queue )
Functions ¶
func InitOrDie ¶
func InitOrDie()
Exchanges: ----------------- | Ror | - ----------------- \ | \ | \ ----------------- | > | ROR Resources | | ----------------- | ----------------- | ROR Events | ----------------- | | ---------------------- | Queue: sse-events | ----------------------
Ror Exchange: - type: topic
- durable: true
- autoDelete: false
- internal: false
- noWait: false
- arguments: nil
Ror.Resources Exchange:
- type: headers
- durable: true
- autoDelete: false
- internal: false
- noWait: false
- arguments: nil
Bindings:
- ROR -> ROR Resources
- key: resources.#
- noWait: false
- arguments: nil
Ror.Events Exchange:
- type: headers
- durable: true
- autoDelete: false
- internal: false
- noWait: false
- arguments: nil
Bindings:
- ROR -> ROR Events
- key: event.#
- noWait: false
- arguments: nil
Queue: Bindings:
- ROR -> Tanzu
- key: "provider.tanzu.#"
- noWait: false
- arguments: nil
Queue:
- Name: api-events
- Durable: true
- Arguments: x-queue-type: quorum
- Bindings:
- Exchange: ror.events
- Routing Key: "resource.*"
InitOrDie initializes the RabbitMQ definitions and panics if it fails It is called from the main function and it is blocking
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.