apirabbitmqdefinitions

package
v1.0.41 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 7, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL