tanzuagentrabbitmqdefinitions

package
v0.3.11 Latest Latest
Warning

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

Go to latest
Published: Dec 2, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	TanzuAgentQueueName = fmt.Sprintf("%s.%s", "tanzu-agent", viper.GetString(configconsts.TANZU_AGENT_DATACENTER))
	TanzuAgentQueue     amqp091.Queue
)

Functions

func InitOrDie

func InitOrDie()

Exchange -> Queue:

        -------------------
        | Exchange: Tanzu |-
        ------------------  \
		                     \
		                      \  --------------------------------------
		                       > | Queue: tanzu-agent.<datacenternam> |
		                         --------------------------------------

Name: tanzu-agent.<datacenternam>

  • Durable: true
  • Arguments: x-queue-type: quorum

Bindings:

  • Exchange: tanzu
  • Routing Key: ""
  • Arguments: x-match: all, datacenter: <datacenternam>

InitOrDie initializes the rabbitmq definitions and panics if it fails

Types

This section is empty.

Jump to

Keyboard shortcuts

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