import * as pulumi from "@pulumi/pulumi"; export interface ExchangeSettings { /** * Additional key/value settings for the exchange. */ arguments?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * Whether the exchange will self-delete when all * queues have finished using it. */ autoDelete?: pulumi.Input; /** * Whether the exchange survives server restarts. * Defaults to `false`. */ durable?: pulumi.Input; /** * The type of exchange. */ type: pulumi.Input; } export interface FederationUpstreamDefinition { /** * Determines how the link should acknowledge messages. Valid values are `on-confirm`, `on-publish`, and `no-ack`. Default is `on-confirm`. */ ackMode?: pulumi.Input; /** * The name of the upstream exchange. */ exchange?: pulumi.Input; /** * The expiry time (in milliseconds) after which an upstream queue for a federated exchange may be deleted if a connection to the upstream is lost. */ expires?: pulumi.Input; /** * Maximum number of federation links that messages can traverse before being dropped. Default is `1`. */ maxHops?: pulumi.Input; /** * The expiry time (in milliseconds) for messages in the upstream queue for a federated exchange (see expires). * * Applicable to Federated Queues Only */ messageTtl?: pulumi.Input; /** * Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default is `1000`. */ prefetchCount?: pulumi.Input; /** * The name of the upstream queue. * * Consult the RabbitMQ [Federation Reference](https://www.rabbitmq.com/federation-reference.html) documentation for detailed information and guidance on setting these values. */ queue?: pulumi.Input; /** * Time in seconds to wait after a network link goes down before attempting reconnection. Default is `5`. */ reconnectDelay?: pulumi.Input; /** * Determines how federation should interact with the validated user-id feature. Default is `false`. * * Applicable to Federated Exchanges Only */ trustUserId?: pulumi.Input; /** * The AMQP URI(s) for the upstream. Note that the URI may contain sensitive information, such as a password. */ uri: pulumi.Input; } export interface OperatorPolicyPolicy { /** * Can be "queues". */ applyTo: pulumi.Input; /** * Key/value pairs of the operator policy definition. See the * RabbitMQ documentation for definition references and examples. */ definition: pulumi.Input<{ [key: string]: pulumi.Input; }>; /** * A pattern to match an exchange or queue name. */ pattern: pulumi.Input; /** * The policy with the greater priority is applied first. */ priority: pulumi.Input; } export interface PermissionsPermissions { /** * The "configure" ACL. */ configure: pulumi.Input; /** * The "read" ACL. */ read: pulumi.Input; /** * The "write" ACL. */ write: pulumi.Input; } export interface PolicyPolicy { /** * Can either be "exchanges", "queues", or "all". */ applyTo: pulumi.Input; /** * Key/value pairs of the policy definition. See the * RabbitMQ documentation for definition references and examples. */ definition: pulumi.Input<{ [key: string]: pulumi.Input; }>; /** * A pattern to match an exchange or queue name. */ pattern: pulumi.Input; /** * The policy with the greater priority is applied first. */ priority: pulumi.Input; } export interface QueueSettings { /** * Additional key/value settings for the queue. * All values will be sent to RabbitMQ as a string. If you require non-string * values, use `argumentsJson`. */ arguments?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * A nested JSON string which contains additional * settings for the queue. This is useful for when the arguments contain * non-string values. */ argumentsJson?: pulumi.Input; /** * Whether the queue will self-delete when all * consumers have unsubscribed. */ autoDelete?: pulumi.Input; /** * Whether the queue survives server restarts. * Defaults to `false`. */ durable?: pulumi.Input; } export interface ShovelInfo { /** * Determines how the shovel should acknowledge messages. Possible values are: `on-confirm`, `on-publish` and `no-ack`. * Defaults to `on-confirm`. */ ackMode?: pulumi.Input; /** * Whether to add `x-shovelled` headers to shovelled messages. * * @deprecated use destinationAddForwardHeaders instead */ addForwardHeaders?: pulumi.Input; /** * Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer. * * @deprecated use sourceDeleteAfter instead */ deleteAfter?: pulumi.Input; /** * Whether to add `x-shovelled` headers to shovelled messages. */ destinationAddForwardHeaders?: pulumi.Input; destinationAddTimestampHeader?: pulumi.Input; /** * The AMQP 1.0 destination link address. */ destinationAddress?: pulumi.Input; /** * Application properties to set when shovelling messages. */ destinationApplicationProperties?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * The exchange to which messages should be published. * Either this or `destinationQueue` must be specified but not both. */ destinationExchange?: pulumi.Input; /** * The routing key when using `destinationExchange`. */ destinationExchangeKey?: pulumi.Input; /** * Properties to overwrite when shovelling messages. * * For more details regarding dynamic shovel parameters please have a look at the official reference documentaion at [RabbitMQ: Configuring Dynamic Shovels](https://www.rabbitmq.com/shovel-dynamic.html). */ destinationProperties?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * The protocol (`amqp091` or `amqp10`) to use when connecting to the destination. * Defaults to `amqp091`. */ destinationProtocol?: pulumi.Input; /** * A map of properties to overwrite when shovelling messages. */ destinationPublishProperties?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * The queue to which messages should be published. * Either this or `destinationExchange` must be specified but not both. */ destinationQueue?: pulumi.Input; destinationQueueArguments?: pulumi.Input<{ [key: string]: pulumi.Input; } | undefined>; /** * The amqp uri for the destination . */ destinationUri: pulumi.Input; /** * The maximum number of unacknowledged messages copied over a shovel at any one time. * * @deprecated use sourcePrefetchCount instead */ prefetchCount?: pulumi.Input; /** * The duration in seconds to reconnect to a broker after disconnected. * Defaults to `1`. */ reconnectDelay?: pulumi.Input; /** * The AMQP 1.0 source link address. */ sourceAddress?: pulumi.Input; /** * Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer. */ sourceDeleteAfter?: pulumi.Input; /** * The exchange from which to consume. * Either this or `sourceQueue` must be specified but not both. */ sourceExchange?: pulumi.Input; /** * The routing key when using `sourceExchange`. */ sourceExchangeKey?: pulumi.Input; /** * The maximum number of unacknowledged messages copied over a shovel at any one time. */ sourcePrefetchCount?: pulumi.Input; /** * The protocol (`amqp091` or `amqp10`) to use when connecting to the source. * Defaults to `amqp091`. */ sourceProtocol?: pulumi.Input; /** * The queue from which to consume. * Either this or `sourceExchange` must be specified but not both. */ sourceQueue?: pulumi.Input; /** * The amqp uri for the source. */ sourceUri: pulumi.Input; } export interface TopicPermissionsPermission { /** * The exchange to set the permissions for. */ exchange: pulumi.Input; /** * The "read" ACL. */ read: pulumi.Input; /** * The "write" ACL. */ write: pulumi.Input; } //# sourceMappingURL=input.d.ts.map