Documentation ¶
Overview ¶
A Pulumi package for creating and managing RabbitMQ resources.
Index ¶
- type Binding
- type BindingArgs
- type BindingState
- type Exchange
- type ExchangeArgs
- type ExchangeSettings
- type ExchangeSettingsArgs
- func (ExchangeSettingsArgs) ElementType() reflect.Type
- func (i ExchangeSettingsArgs) ToExchangeSettingsOutput() ExchangeSettingsOutput
- func (i ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput
- func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
- func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
- type ExchangeSettingsInput
- type ExchangeSettingsOutput
- func (o ExchangeSettingsOutput) Arguments() pulumi.MapOutput
- func (o ExchangeSettingsOutput) AutoDelete() pulumi.BoolPtrOutput
- func (o ExchangeSettingsOutput) Durable() pulumi.BoolPtrOutput
- func (ExchangeSettingsOutput) ElementType() reflect.Type
- func (o ExchangeSettingsOutput) ToExchangeSettingsOutput() ExchangeSettingsOutput
- func (o ExchangeSettingsOutput) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput
- func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
- func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
- func (o ExchangeSettingsOutput) Type() pulumi.StringOutput
- type ExchangeSettingsPtrInput
- type ExchangeSettingsPtrOutput
- func (o ExchangeSettingsPtrOutput) Arguments() pulumi.MapOutput
- func (o ExchangeSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput
- func (o ExchangeSettingsPtrOutput) Durable() pulumi.BoolPtrOutput
- func (o ExchangeSettingsPtrOutput) Elem() ExchangeSettingsOutput
- func (ExchangeSettingsPtrOutput) ElementType() reflect.Type
- func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
- func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
- func (o ExchangeSettingsPtrOutput) Type() pulumi.StringPtrOutput
- type ExchangeState
- type FederationUpstream
- type FederationUpstreamArgs
- type FederationUpstreamDefinition
- type FederationUpstreamDefinitionArgs
- func (FederationUpstreamDefinitionArgs) ElementType() reflect.Type
- func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput
- func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput
- func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
- func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
- type FederationUpstreamDefinitionInput
- type FederationUpstreamDefinitionOutput
- func (o FederationUpstreamDefinitionOutput) AckMode() pulumi.StringPtrOutput
- func (FederationUpstreamDefinitionOutput) ElementType() reflect.Type
- func (o FederationUpstreamDefinitionOutput) Exchange() pulumi.StringPtrOutput
- func (o FederationUpstreamDefinitionOutput) Expires() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionOutput) MaxHops() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionOutput) MessageTtl() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionOutput) PrefetchCount() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionOutput) Queue() pulumi.StringPtrOutput
- func (o FederationUpstreamDefinitionOutput) ReconnectDelay() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput
- func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput
- func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
- func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
- func (o FederationUpstreamDefinitionOutput) TrustUserId() pulumi.BoolPtrOutput
- func (o FederationUpstreamDefinitionOutput) Uri() pulumi.StringOutput
- type FederationUpstreamDefinitionPtrInput
- type FederationUpstreamDefinitionPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) AckMode() pulumi.StringPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) Elem() FederationUpstreamDefinitionOutput
- func (FederationUpstreamDefinitionPtrOutput) ElementType() reflect.Type
- func (o FederationUpstreamDefinitionPtrOutput) Exchange() pulumi.StringPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) Expires() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) MaxHops() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) MessageTtl() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) PrefetchCount() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) Queue() pulumi.StringPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) ReconnectDelay() pulumi.IntPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) TrustUserId() pulumi.BoolPtrOutput
- func (o FederationUpstreamDefinitionPtrOutput) Uri() pulumi.StringPtrOutput
- type FederationUpstreamState
- type Permissions
- type PermissionsArgs
- type PermissionsPermissions
- type PermissionsPermissionsArgs
- func (PermissionsPermissionsArgs) ElementType() reflect.Type
- func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput
- func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput
- func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
- func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
- type PermissionsPermissionsInput
- type PermissionsPermissionsOutput
- func (o PermissionsPermissionsOutput) Configure() pulumi.StringOutput
- func (PermissionsPermissionsOutput) ElementType() reflect.Type
- func (o PermissionsPermissionsOutput) Read() pulumi.StringOutput
- func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput
- func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput
- func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
- func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
- func (o PermissionsPermissionsOutput) Write() pulumi.StringOutput
- type PermissionsPermissionsPtrInput
- type PermissionsPermissionsPtrOutput
- func (o PermissionsPermissionsPtrOutput) Configure() pulumi.StringPtrOutput
- func (o PermissionsPermissionsPtrOutput) Elem() PermissionsPermissionsOutput
- func (PermissionsPermissionsPtrOutput) ElementType() reflect.Type
- func (o PermissionsPermissionsPtrOutput) Read() pulumi.StringPtrOutput
- func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
- func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
- func (o PermissionsPermissionsPtrOutput) Write() pulumi.StringPtrOutput
- type PermissionsState
- type Policy
- type PolicyArgs
- type PolicyPolicy
- type PolicyPolicyArgs
- func (PolicyPolicyArgs) ElementType() reflect.Type
- func (i PolicyPolicyArgs) ToPolicyPolicyOutput() PolicyPolicyOutput
- func (i PolicyPolicyArgs) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput
- func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
- func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
- type PolicyPolicyInput
- type PolicyPolicyOutput
- func (o PolicyPolicyOutput) ApplyTo() pulumi.StringOutput
- func (o PolicyPolicyOutput) Definition() pulumi.MapOutput
- func (PolicyPolicyOutput) ElementType() reflect.Type
- func (o PolicyPolicyOutput) Pattern() pulumi.StringOutput
- func (o PolicyPolicyOutput) Priority() pulumi.IntOutput
- func (o PolicyPolicyOutput) ToPolicyPolicyOutput() PolicyPolicyOutput
- func (o PolicyPolicyOutput) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput
- func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
- func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
- type PolicyPolicyPtrInput
- type PolicyPolicyPtrOutput
- func (o PolicyPolicyPtrOutput) ApplyTo() pulumi.StringPtrOutput
- func (o PolicyPolicyPtrOutput) Definition() pulumi.MapOutput
- func (o PolicyPolicyPtrOutput) Elem() PolicyPolicyOutput
- func (PolicyPolicyPtrOutput) ElementType() reflect.Type
- func (o PolicyPolicyPtrOutput) Pattern() pulumi.StringPtrOutput
- func (o PolicyPolicyPtrOutput) Priority() pulumi.IntPtrOutput
- func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
- func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
- type PolicyState
- type Provider
- type ProviderArgs
- type Queue
- type QueueArgs
- type QueueSettings
- type QueueSettingsArgs
- func (QueueSettingsArgs) ElementType() reflect.Type
- func (i QueueSettingsArgs) ToQueueSettingsOutput() QueueSettingsOutput
- func (i QueueSettingsArgs) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput
- func (i QueueSettingsArgs) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
- func (i QueueSettingsArgs) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
- type QueueSettingsInput
- type QueueSettingsOutput
- func (o QueueSettingsOutput) Arguments() pulumi.MapOutput
- func (o QueueSettingsOutput) ArgumentsJson() pulumi.StringPtrOutput
- func (o QueueSettingsOutput) AutoDelete() pulumi.BoolPtrOutput
- func (o QueueSettingsOutput) Durable() pulumi.BoolPtrOutput
- func (QueueSettingsOutput) ElementType() reflect.Type
- func (o QueueSettingsOutput) ToQueueSettingsOutput() QueueSettingsOutput
- func (o QueueSettingsOutput) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput
- func (o QueueSettingsOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
- func (o QueueSettingsOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
- type QueueSettingsPtrInput
- type QueueSettingsPtrOutput
- func (o QueueSettingsPtrOutput) Arguments() pulumi.MapOutput
- func (o QueueSettingsPtrOutput) ArgumentsJson() pulumi.StringPtrOutput
- func (o QueueSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput
- func (o QueueSettingsPtrOutput) Durable() pulumi.BoolPtrOutput
- func (o QueueSettingsPtrOutput) Elem() QueueSettingsOutput
- func (QueueSettingsPtrOutput) ElementType() reflect.Type
- func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
- func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
- type QueueState
- type Shovel
- type ShovelArgs
- type ShovelInfo
- type ShovelInfoArgs
- func (ShovelInfoArgs) ElementType() reflect.Type
- func (i ShovelInfoArgs) ToShovelInfoOutput() ShovelInfoOutput
- func (i ShovelInfoArgs) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput
- func (i ShovelInfoArgs) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
- func (i ShovelInfoArgs) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
- type ShovelInfoInput
- type ShovelInfoOutput
- func (o ShovelInfoOutput) AckMode() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) AddForwardHeaders() pulumi.BoolPtrOutput
- func (o ShovelInfoOutput) DeleteAfter() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) DestinationExchange() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) DestinationExchangeKey() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) DestinationQueue() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) DestinationUri() pulumi.StringOutput
- func (ShovelInfoOutput) ElementType() reflect.Type
- func (o ShovelInfoOutput) PrefetchCount() pulumi.IntPtrOutput
- func (o ShovelInfoOutput) ReconnectDelay() pulumi.IntPtrOutput
- func (o ShovelInfoOutput) SourceExchange() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) SourceExchangeKey() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) SourceQueue() pulumi.StringPtrOutput
- func (o ShovelInfoOutput) SourceUri() pulumi.StringOutput
- func (o ShovelInfoOutput) ToShovelInfoOutput() ShovelInfoOutput
- func (o ShovelInfoOutput) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput
- func (o ShovelInfoOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
- func (o ShovelInfoOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
- type ShovelInfoPtrInput
- type ShovelInfoPtrOutput
- func (o ShovelInfoPtrOutput) AckMode() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) AddForwardHeaders() pulumi.BoolPtrOutput
- func (o ShovelInfoPtrOutput) DeleteAfter() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) DestinationExchange() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) DestinationExchangeKey() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) DestinationQueue() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) DestinationUri() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) Elem() ShovelInfoOutput
- func (ShovelInfoPtrOutput) ElementType() reflect.Type
- func (o ShovelInfoPtrOutput) PrefetchCount() pulumi.IntPtrOutput
- func (o ShovelInfoPtrOutput) ReconnectDelay() pulumi.IntPtrOutput
- func (o ShovelInfoPtrOutput) SourceExchange() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) SourceExchangeKey() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) SourceQueue() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) SourceUri() pulumi.StringPtrOutput
- func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
- func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
- type ShovelState
- type TopicPermissions
- type TopicPermissionsArgs
- type TopicPermissionsPermission
- type TopicPermissionsPermissionArgs
- func (TopicPermissionsPermissionArgs) ElementType() reflect.Type
- func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput
- func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput
- type TopicPermissionsPermissionArray
- func (TopicPermissionsPermissionArray) ElementType() reflect.Type
- func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput
- func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput
- type TopicPermissionsPermissionArrayInput
- type TopicPermissionsPermissionArrayOutput
- func (TopicPermissionsPermissionArrayOutput) ElementType() reflect.Type
- func (o TopicPermissionsPermissionArrayOutput) Index(i pulumi.IntInput) TopicPermissionsPermissionOutput
- func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput
- func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput
- type TopicPermissionsPermissionInput
- type TopicPermissionsPermissionOutput
- func (TopicPermissionsPermissionOutput) ElementType() reflect.Type
- func (o TopicPermissionsPermissionOutput) Exchange() pulumi.StringOutput
- func (o TopicPermissionsPermissionOutput) Read() pulumi.StringOutput
- func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput
- func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput
- func (o TopicPermissionsPermissionOutput) Write() pulumi.StringOutput
- type TopicPermissionsState
- type User
- type UserArgs
- type UserState
- type VHost
- type VHostArgs
- type VHostState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Binding ¶
type Binding struct { pulumi.CustomResourceState // Additional key/value arguments for the binding. Arguments pulumi.MapOutput `pulumi:"arguments"` ArgumentsJson pulumi.StringPtrOutput `pulumi:"argumentsJson"` // The destination queue or exchange. Destination pulumi.StringOutput `pulumi:"destination"` // The type of destination (queue or exchange). DestinationType pulumi.StringOutput `pulumi:"destinationType"` // A unique key to refer to the binding. PropertiesKey pulumi.StringOutput `pulumi:"propertiesKey"` // A routing key for the binding. RoutingKey pulumi.StringPtrOutput `pulumi:"routingKey"` // The source exchange. Source pulumi.StringOutput `pulumi:"source"` // The vhost to create the resource in. Vhost pulumi.StringOutput `pulumi:"vhost"` }
The “Binding“ resource creates and manages a binding relationship between a queue an exchange.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: pulumi.String("guest"), Vhost: testVHost.Name, }) if err != nil { return err } testExchange, err := rabbitmq.NewExchange(ctx, "testExchange", &rabbitmq.ExchangeArgs{ Settings: &rabbitmq.ExchangeSettingsArgs{ AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), Type: pulumi.String("fanout"), }, Vhost: guest.Vhost, }) if err != nil { return err } testQueue, err := rabbitmq.NewQueue(ctx, "testQueue", &rabbitmq.QueueArgs{ Settings: &rabbitmq.QueueSettingsArgs{ AutoDelete: pulumi.Bool(false), Durable: pulumi.Bool(true), }, Vhost: guest.Vhost, }) if err != nil { return err } _, err = rabbitmq.NewBinding(ctx, "testBinding", &rabbitmq.BindingArgs{ Destination: testQueue.Name, DestinationType: pulumi.String("queue"), RoutingKey: pulumi.String("#"), Source: testExchange.Name, Vhost: testVHost.Name, }) if err != nil { return err } return nil }) }
```
func GetBinding ¶
func GetBinding(ctx *pulumi.Context, name string, id pulumi.IDInput, state *BindingState, opts ...pulumi.ResourceOption) (*Binding, error)
GetBinding gets an existing Binding resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewBinding ¶
func NewBinding(ctx *pulumi.Context, name string, args *BindingArgs, opts ...pulumi.ResourceOption) (*Binding, error)
NewBinding registers a new resource with the given unique name, arguments, and options.
type BindingArgs ¶
type BindingArgs struct { // Additional key/value arguments for the binding. Arguments pulumi.MapInput ArgumentsJson pulumi.StringPtrInput // The destination queue or exchange. Destination pulumi.StringInput // The type of destination (queue or exchange). DestinationType pulumi.StringInput // A routing key for the binding. RoutingKey pulumi.StringPtrInput // The source exchange. Source pulumi.StringInput // The vhost to create the resource in. Vhost pulumi.StringInput }
The set of arguments for constructing a Binding resource.
func (BindingArgs) ElementType ¶
func (BindingArgs) ElementType() reflect.Type
type BindingState ¶
type BindingState struct { // Additional key/value arguments for the binding. Arguments pulumi.MapInput ArgumentsJson pulumi.StringPtrInput // The destination queue or exchange. Destination pulumi.StringPtrInput // The type of destination (queue or exchange). DestinationType pulumi.StringPtrInput // A unique key to refer to the binding. PropertiesKey pulumi.StringPtrInput // A routing key for the binding. RoutingKey pulumi.StringPtrInput // The source exchange. Source pulumi.StringPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (BindingState) ElementType ¶
func (BindingState) ElementType() reflect.Type
type Exchange ¶
type Exchange struct { pulumi.CustomResourceState // The name of the exchange. Name pulumi.StringOutput `pulumi:"name"` // The settings of the exchange. The structure is // described below. Settings ExchangeSettingsOutput `pulumi:"settings"` // The vhost to create the resource in. Vhost pulumi.StringPtrOutput `pulumi:"vhost"` }
The “Exchange“ resource creates and manages an exchange.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: pulumi.String("guest"), Vhost: testVHost.Name, }) if err != nil { return err } _, err = rabbitmq.NewExchange(ctx, "testExchange", &rabbitmq.ExchangeArgs{ Settings: &rabbitmq.ExchangeSettingsArgs{ AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), Type: pulumi.String("fanout"), }, Vhost: guest.Vhost, }) if err != nil { return err } return nil }) }
```
func GetExchange ¶
func GetExchange(ctx *pulumi.Context, name string, id pulumi.IDInput, state *ExchangeState, opts ...pulumi.ResourceOption) (*Exchange, error)
GetExchange gets an existing Exchange resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewExchange ¶
func NewExchange(ctx *pulumi.Context, name string, args *ExchangeArgs, opts ...pulumi.ResourceOption) (*Exchange, error)
NewExchange registers a new resource with the given unique name, arguments, and options.
type ExchangeArgs ¶
type ExchangeArgs struct { // The name of the exchange. Name pulumi.StringPtrInput // The settings of the exchange. The structure is // described below. Settings ExchangeSettingsInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
The set of arguments for constructing a Exchange resource.
func (ExchangeArgs) ElementType ¶
func (ExchangeArgs) ElementType() reflect.Type
type ExchangeSettings ¶
type ExchangeSettings struct { // Additional key/value settings for the exchange. Arguments map[string]interface{} `pulumi:"arguments"` // Whether the exchange will self-delete when all // queues have finished using it. AutoDelete *bool `pulumi:"autoDelete"` // Whether the exchange survives server restarts. // Defaults to `false`. Durable *bool `pulumi:"durable"` // The type of exchange. Type string `pulumi:"type"` }
type ExchangeSettingsArgs ¶
type ExchangeSettingsArgs struct { // Additional key/value settings for the exchange. Arguments pulumi.MapInput `pulumi:"arguments"` // Whether the exchange will self-delete when all // queues have finished using it. AutoDelete pulumi.BoolPtrInput `pulumi:"autoDelete"` // Whether the exchange survives server restarts. // Defaults to `false`. Durable pulumi.BoolPtrInput `pulumi:"durable"` // The type of exchange. Type pulumi.StringInput `pulumi:"type"` }
func (ExchangeSettingsArgs) ElementType ¶
func (ExchangeSettingsArgs) ElementType() reflect.Type
func (ExchangeSettingsArgs) ToExchangeSettingsOutput ¶
func (i ExchangeSettingsArgs) ToExchangeSettingsOutput() ExchangeSettingsOutput
func (ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext ¶
func (i ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput
func (ExchangeSettingsArgs) ToExchangeSettingsPtrOutput ¶
func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
func (ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext ¶
func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
type ExchangeSettingsInput ¶
type ExchangeSettingsInput interface { pulumi.Input ToExchangeSettingsOutput() ExchangeSettingsOutput ToExchangeSettingsOutputWithContext(context.Context) ExchangeSettingsOutput }
ExchangeSettingsInput is an input type that accepts ExchangeSettingsArgs and ExchangeSettingsOutput values. You can construct a concrete instance of `ExchangeSettingsInput` via:
ExchangeSettingsArgs{...}
type ExchangeSettingsOutput ¶
type ExchangeSettingsOutput struct{ *pulumi.OutputState }
func (ExchangeSettingsOutput) Arguments ¶
func (o ExchangeSettingsOutput) Arguments() pulumi.MapOutput
Additional key/value settings for the exchange.
func (ExchangeSettingsOutput) AutoDelete ¶
func (o ExchangeSettingsOutput) AutoDelete() pulumi.BoolPtrOutput
Whether the exchange will self-delete when all queues have finished using it.
func (ExchangeSettingsOutput) Durable ¶
func (o ExchangeSettingsOutput) Durable() pulumi.BoolPtrOutput
Whether the exchange survives server restarts. Defaults to `false`.
func (ExchangeSettingsOutput) ElementType ¶
func (ExchangeSettingsOutput) ElementType() reflect.Type
func (ExchangeSettingsOutput) ToExchangeSettingsOutput ¶
func (o ExchangeSettingsOutput) ToExchangeSettingsOutput() ExchangeSettingsOutput
func (ExchangeSettingsOutput) ToExchangeSettingsOutputWithContext ¶
func (o ExchangeSettingsOutput) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput
func (ExchangeSettingsOutput) ToExchangeSettingsPtrOutput ¶
func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
func (ExchangeSettingsOutput) ToExchangeSettingsPtrOutputWithContext ¶
func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
func (ExchangeSettingsOutput) Type ¶
func (o ExchangeSettingsOutput) Type() pulumi.StringOutput
The type of exchange.
type ExchangeSettingsPtrInput ¶
type ExchangeSettingsPtrInput interface { pulumi.Input ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput ToExchangeSettingsPtrOutputWithContext(context.Context) ExchangeSettingsPtrOutput }
ExchangeSettingsPtrInput is an input type that accepts ExchangeSettingsArgs, ExchangeSettingsPtr and ExchangeSettingsPtrOutput values. You can construct a concrete instance of `ExchangeSettingsPtrInput` via:
ExchangeSettingsArgs{...} or: nil
func ExchangeSettingsPtr ¶
func ExchangeSettingsPtr(v *ExchangeSettingsArgs) ExchangeSettingsPtrInput
type ExchangeSettingsPtrOutput ¶
type ExchangeSettingsPtrOutput struct{ *pulumi.OutputState }
func (ExchangeSettingsPtrOutput) Arguments ¶
func (o ExchangeSettingsPtrOutput) Arguments() pulumi.MapOutput
Additional key/value settings for the exchange.
func (ExchangeSettingsPtrOutput) AutoDelete ¶
func (o ExchangeSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput
Whether the exchange will self-delete when all queues have finished using it.
func (ExchangeSettingsPtrOutput) Durable ¶
func (o ExchangeSettingsPtrOutput) Durable() pulumi.BoolPtrOutput
Whether the exchange survives server restarts. Defaults to `false`.
func (ExchangeSettingsPtrOutput) Elem ¶
func (o ExchangeSettingsPtrOutput) Elem() ExchangeSettingsOutput
func (ExchangeSettingsPtrOutput) ElementType ¶
func (ExchangeSettingsPtrOutput) ElementType() reflect.Type
func (ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutput ¶
func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
func (ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutputWithContext ¶
func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput
func (ExchangeSettingsPtrOutput) Type ¶
func (o ExchangeSettingsPtrOutput) Type() pulumi.StringPtrOutput
The type of exchange.
type ExchangeState ¶
type ExchangeState struct { // The name of the exchange. Name pulumi.StringPtrInput // The settings of the exchange. The structure is // described below. Settings ExchangeSettingsPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (ExchangeState) ElementType ¶
func (ExchangeState) ElementType() reflect.Type
type FederationUpstream ¶ added in v2.2.0
type FederationUpstream struct { pulumi.CustomResourceState Component pulumi.StringOutput `pulumi:"component"` Definition FederationUpstreamDefinitionOutput `pulumi:"definition"` Name pulumi.StringOutput `pulumi:"name"` Vhost pulumi.StringOutput `pulumi:"vhost"` }
func GetFederationUpstream ¶ added in v2.2.0
func GetFederationUpstream(ctx *pulumi.Context, name string, id pulumi.IDInput, state *FederationUpstreamState, opts ...pulumi.ResourceOption) (*FederationUpstream, error)
GetFederationUpstream gets an existing FederationUpstream resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewFederationUpstream ¶ added in v2.2.0
func NewFederationUpstream(ctx *pulumi.Context, name string, args *FederationUpstreamArgs, opts ...pulumi.ResourceOption) (*FederationUpstream, error)
NewFederationUpstream registers a new resource with the given unique name, arguments, and options.
type FederationUpstreamArgs ¶ added in v2.2.0
type FederationUpstreamArgs struct { Definition FederationUpstreamDefinitionInput Name pulumi.StringPtrInput Vhost pulumi.StringInput }
The set of arguments for constructing a FederationUpstream resource.
func (FederationUpstreamArgs) ElementType ¶ added in v2.2.0
func (FederationUpstreamArgs) ElementType() reflect.Type
type FederationUpstreamDefinition ¶ added in v2.2.0
type FederationUpstreamDefinition struct { AckMode *string `pulumi:"ackMode"` Exchange *string `pulumi:"exchange"` Expires *int `pulumi:"expires"` MaxHops *int `pulumi:"maxHops"` MessageTtl *int `pulumi:"messageTtl"` PrefetchCount *int `pulumi:"prefetchCount"` Queue *string `pulumi:"queue"` ReconnectDelay *int `pulumi:"reconnectDelay"` TrustUserId *bool `pulumi:"trustUserId"` Uri string `pulumi:"uri"` }
type FederationUpstreamDefinitionArgs ¶ added in v2.2.0
type FederationUpstreamDefinitionArgs struct { AckMode pulumi.StringPtrInput `pulumi:"ackMode"` Exchange pulumi.StringPtrInput `pulumi:"exchange"` Expires pulumi.IntPtrInput `pulumi:"expires"` MaxHops pulumi.IntPtrInput `pulumi:"maxHops"` MessageTtl pulumi.IntPtrInput `pulumi:"messageTtl"` PrefetchCount pulumi.IntPtrInput `pulumi:"prefetchCount"` Queue pulumi.StringPtrInput `pulumi:"queue"` ReconnectDelay pulumi.IntPtrInput `pulumi:"reconnectDelay"` TrustUserId pulumi.BoolPtrInput `pulumi:"trustUserId"` Uri pulumi.StringInput `pulumi:"uri"` }
func (FederationUpstreamDefinitionArgs) ElementType ¶ added in v2.2.0
func (FederationUpstreamDefinitionArgs) ElementType() reflect.Type
func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput ¶ added in v2.2.0
func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput
func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext ¶ added in v2.2.0
func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput
func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput ¶ added in v2.2.0
func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext ¶ added in v2.2.0
func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
type FederationUpstreamDefinitionInput ¶ added in v2.2.0
type FederationUpstreamDefinitionInput interface { pulumi.Input ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput ToFederationUpstreamDefinitionOutputWithContext(context.Context) FederationUpstreamDefinitionOutput }
FederationUpstreamDefinitionInput is an input type that accepts FederationUpstreamDefinitionArgs and FederationUpstreamDefinitionOutput values. You can construct a concrete instance of `FederationUpstreamDefinitionInput` via:
FederationUpstreamDefinitionArgs{...}
type FederationUpstreamDefinitionOutput ¶ added in v2.2.0
type FederationUpstreamDefinitionOutput struct{ *pulumi.OutputState }
func (FederationUpstreamDefinitionOutput) AckMode ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) AckMode() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionOutput) ElementType ¶ added in v2.2.0
func (FederationUpstreamDefinitionOutput) ElementType() reflect.Type
func (FederationUpstreamDefinitionOutput) Exchange ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) Exchange() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionOutput) Expires ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) Expires() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionOutput) MaxHops ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) MaxHops() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionOutput) MessageTtl ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) MessageTtl() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionOutput) PrefetchCount ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) PrefetchCount() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionOutput) Queue ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) Queue() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionOutput) ReconnectDelay ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) ReconnectDelay() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput
func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput
func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
func (FederationUpstreamDefinitionOutput) TrustUserId ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) TrustUserId() pulumi.BoolPtrOutput
func (FederationUpstreamDefinitionOutput) Uri ¶ added in v2.2.0
func (o FederationUpstreamDefinitionOutput) Uri() pulumi.StringOutput
type FederationUpstreamDefinitionPtrInput ¶ added in v2.2.0
type FederationUpstreamDefinitionPtrInput interface { pulumi.Input ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput ToFederationUpstreamDefinitionPtrOutputWithContext(context.Context) FederationUpstreamDefinitionPtrOutput }
FederationUpstreamDefinitionPtrInput is an input type that accepts FederationUpstreamDefinitionArgs, FederationUpstreamDefinitionPtr and FederationUpstreamDefinitionPtrOutput values. You can construct a concrete instance of `FederationUpstreamDefinitionPtrInput` via:
FederationUpstreamDefinitionArgs{...} or: nil
func FederationUpstreamDefinitionPtr ¶ added in v2.2.0
func FederationUpstreamDefinitionPtr(v *FederationUpstreamDefinitionArgs) FederationUpstreamDefinitionPtrInput
type FederationUpstreamDefinitionPtrOutput ¶ added in v2.2.0
type FederationUpstreamDefinitionPtrOutput struct{ *pulumi.OutputState }
func (FederationUpstreamDefinitionPtrOutput) AckMode ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) AckMode() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionPtrOutput) ElementType ¶ added in v2.2.0
func (FederationUpstreamDefinitionPtrOutput) ElementType() reflect.Type
func (FederationUpstreamDefinitionPtrOutput) Exchange ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) Exchange() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionPtrOutput) Expires ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) Expires() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionPtrOutput) MaxHops ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) MaxHops() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionPtrOutput) MessageTtl ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) MessageTtl() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionPtrOutput) PrefetchCount ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) PrefetchCount() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionPtrOutput) Queue ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) Queue() pulumi.StringPtrOutput
func (FederationUpstreamDefinitionPtrOutput) ReconnectDelay ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) ReconnectDelay() pulumi.IntPtrOutput
func (FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
func (FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput
func (FederationUpstreamDefinitionPtrOutput) TrustUserId ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) TrustUserId() pulumi.BoolPtrOutput
func (FederationUpstreamDefinitionPtrOutput) Uri ¶ added in v2.2.0
func (o FederationUpstreamDefinitionPtrOutput) Uri() pulumi.StringPtrOutput
type FederationUpstreamState ¶ added in v2.2.0
type FederationUpstreamState struct { Component pulumi.StringPtrInput Definition FederationUpstreamDefinitionPtrInput Name pulumi.StringPtrInput Vhost pulumi.StringPtrInput }
func (FederationUpstreamState) ElementType ¶ added in v2.2.0
func (FederationUpstreamState) ElementType() reflect.Type
type Permissions ¶
type Permissions struct { pulumi.CustomResourceState // The settings of the permissions. The structure is // described below. Permissions PermissionsPermissionsOutput `pulumi:"permissions"` // The user to apply the permissions to. User pulumi.StringOutput `pulumi:"user"` // The vhost to create the resource in. Vhost pulumi.StringPtrOutput `pulumi:"vhost"` }
The “Permissions“ resource creates and manages a user's set of permissions.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } testUser, err := rabbitmq.NewUser(ctx, "testUser", &rabbitmq.UserArgs{ Password: pulumi.String("foobar"), Tags: pulumi.StringArray{ pulumi.String("administrator"), }, }) if err != nil { return err } _, err = rabbitmq.NewPermissions(ctx, "testPermissions", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: testUser.Name, Vhost: testVHost.Name, }) if err != nil { return err } return nil }) }
```
func GetPermissions ¶
func GetPermissions(ctx *pulumi.Context, name string, id pulumi.IDInput, state *PermissionsState, opts ...pulumi.ResourceOption) (*Permissions, error)
GetPermissions gets an existing Permissions resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewPermissions ¶
func NewPermissions(ctx *pulumi.Context, name string, args *PermissionsArgs, opts ...pulumi.ResourceOption) (*Permissions, error)
NewPermissions registers a new resource with the given unique name, arguments, and options.
type PermissionsArgs ¶
type PermissionsArgs struct { // The settings of the permissions. The structure is // described below. Permissions PermissionsPermissionsInput // The user to apply the permissions to. User pulumi.StringInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
The set of arguments for constructing a Permissions resource.
func (PermissionsArgs) ElementType ¶
func (PermissionsArgs) ElementType() reflect.Type
type PermissionsPermissions ¶
type PermissionsPermissionsArgs ¶
type PermissionsPermissionsArgs struct { // The "configure" ACL. Configure pulumi.StringInput `pulumi:"configure"` // The "read" ACL. Read pulumi.StringInput `pulumi:"read"` // The "write" ACL. Write pulumi.StringInput `pulumi:"write"` }
func (PermissionsPermissionsArgs) ElementType ¶
func (PermissionsPermissionsArgs) ElementType() reflect.Type
func (PermissionsPermissionsArgs) ToPermissionsPermissionsOutput ¶
func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput
func (PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext ¶
func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput
func (PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput ¶
func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
func (PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext ¶
func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
type PermissionsPermissionsInput ¶
type PermissionsPermissionsInput interface { pulumi.Input ToPermissionsPermissionsOutput() PermissionsPermissionsOutput ToPermissionsPermissionsOutputWithContext(context.Context) PermissionsPermissionsOutput }
PermissionsPermissionsInput is an input type that accepts PermissionsPermissionsArgs and PermissionsPermissionsOutput values. You can construct a concrete instance of `PermissionsPermissionsInput` via:
PermissionsPermissionsArgs{...}
type PermissionsPermissionsOutput ¶
type PermissionsPermissionsOutput struct{ *pulumi.OutputState }
func (PermissionsPermissionsOutput) Configure ¶
func (o PermissionsPermissionsOutput) Configure() pulumi.StringOutput
The "configure" ACL.
func (PermissionsPermissionsOutput) ElementType ¶
func (PermissionsPermissionsOutput) ElementType() reflect.Type
func (PermissionsPermissionsOutput) Read ¶
func (o PermissionsPermissionsOutput) Read() pulumi.StringOutput
The "read" ACL.
func (PermissionsPermissionsOutput) ToPermissionsPermissionsOutput ¶
func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput
func (PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext ¶
func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput
func (PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput ¶
func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
func (PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext ¶
func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
func (PermissionsPermissionsOutput) Write ¶
func (o PermissionsPermissionsOutput) Write() pulumi.StringOutput
The "write" ACL.
type PermissionsPermissionsPtrInput ¶
type PermissionsPermissionsPtrInput interface { pulumi.Input ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput ToPermissionsPermissionsPtrOutputWithContext(context.Context) PermissionsPermissionsPtrOutput }
PermissionsPermissionsPtrInput is an input type that accepts PermissionsPermissionsArgs, PermissionsPermissionsPtr and PermissionsPermissionsPtrOutput values. You can construct a concrete instance of `PermissionsPermissionsPtrInput` via:
PermissionsPermissionsArgs{...} or: nil
func PermissionsPermissionsPtr ¶
func PermissionsPermissionsPtr(v *PermissionsPermissionsArgs) PermissionsPermissionsPtrInput
type PermissionsPermissionsPtrOutput ¶
type PermissionsPermissionsPtrOutput struct{ *pulumi.OutputState }
func (PermissionsPermissionsPtrOutput) Configure ¶
func (o PermissionsPermissionsPtrOutput) Configure() pulumi.StringPtrOutput
The "configure" ACL.
func (PermissionsPermissionsPtrOutput) Elem ¶
func (o PermissionsPermissionsPtrOutput) Elem() PermissionsPermissionsOutput
func (PermissionsPermissionsPtrOutput) ElementType ¶
func (PermissionsPermissionsPtrOutput) ElementType() reflect.Type
func (PermissionsPermissionsPtrOutput) Read ¶
func (o PermissionsPermissionsPtrOutput) Read() pulumi.StringPtrOutput
The "read" ACL.
func (PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput ¶
func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
func (PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext ¶
func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput
func (PermissionsPermissionsPtrOutput) Write ¶
func (o PermissionsPermissionsPtrOutput) Write() pulumi.StringPtrOutput
The "write" ACL.
type PermissionsState ¶
type PermissionsState struct { // The settings of the permissions. The structure is // described below. Permissions PermissionsPermissionsPtrInput // The user to apply the permissions to. User pulumi.StringPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (PermissionsState) ElementType ¶
func (PermissionsState) ElementType() reflect.Type
type Policy ¶
type Policy struct { pulumi.CustomResourceState // The name of the policy. Name pulumi.StringOutput `pulumi:"name"` // The settings of the policy. The structure is // described below. Policy PolicyPolicyOutput `pulumi:"policy"` // The vhost to create the resource in. Vhost pulumi.StringOutput `pulumi:"vhost"` }
The “Policy“ resource creates and manages policies for exchanges and queues.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: pulumi.String("guest"), Vhost: testVHost.Name, }) if err != nil { return err } _, err = rabbitmq.NewPolicy(ctx, "testPolicy", &rabbitmq.PolicyArgs{ Policy: &rabbitmq.PolicyPolicyArgs{ ApplyTo: pulumi.String("all"), Definition: pulumi.StringMap{ "ha-mode": pulumi.String("all"), }, Pattern: pulumi.String(".*"), Priority: pulumi.Int(0), }, Vhost: guest.Vhost, }) if err != nil { return err } return nil }) }
```
func GetPolicy ¶
func GetPolicy(ctx *pulumi.Context, name string, id pulumi.IDInput, state *PolicyState, opts ...pulumi.ResourceOption) (*Policy, error)
GetPolicy gets an existing Policy resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewPolicy ¶
func NewPolicy(ctx *pulumi.Context, name string, args *PolicyArgs, opts ...pulumi.ResourceOption) (*Policy, error)
NewPolicy registers a new resource with the given unique name, arguments, and options.
type PolicyArgs ¶
type PolicyArgs struct { // The name of the policy. Name pulumi.StringPtrInput // The settings of the policy. The structure is // described below. Policy PolicyPolicyInput // The vhost to create the resource in. Vhost pulumi.StringInput }
The set of arguments for constructing a Policy resource.
func (PolicyArgs) ElementType ¶
func (PolicyArgs) ElementType() reflect.Type
type PolicyPolicy ¶
type PolicyPolicy struct { // Can either be "exchanges", "queues", or "all". ApplyTo string `pulumi:"applyTo"` // Key/value pairs of the policy definition. See the // RabbitMQ documentation for definition references and examples. Definition map[string]interface{} `pulumi:"definition"` // A pattern to match an exchange or queue name. Pattern string `pulumi:"pattern"` // The policy with the greater priority is applied first. Priority int `pulumi:"priority"` }
type PolicyPolicyArgs ¶
type PolicyPolicyArgs struct { // Can either be "exchanges", "queues", or "all". ApplyTo pulumi.StringInput `pulumi:"applyTo"` // Key/value pairs of the policy definition. See the // RabbitMQ documentation for definition references and examples. Definition pulumi.MapInput `pulumi:"definition"` // A pattern to match an exchange or queue name. Pattern pulumi.StringInput `pulumi:"pattern"` // The policy with the greater priority is applied first. Priority pulumi.IntInput `pulumi:"priority"` }
func (PolicyPolicyArgs) ElementType ¶
func (PolicyPolicyArgs) ElementType() reflect.Type
func (PolicyPolicyArgs) ToPolicyPolicyOutput ¶
func (i PolicyPolicyArgs) ToPolicyPolicyOutput() PolicyPolicyOutput
func (PolicyPolicyArgs) ToPolicyPolicyOutputWithContext ¶
func (i PolicyPolicyArgs) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput
func (PolicyPolicyArgs) ToPolicyPolicyPtrOutput ¶
func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
func (PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext ¶
func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
type PolicyPolicyInput ¶
type PolicyPolicyInput interface { pulumi.Input ToPolicyPolicyOutput() PolicyPolicyOutput ToPolicyPolicyOutputWithContext(context.Context) PolicyPolicyOutput }
PolicyPolicyInput is an input type that accepts PolicyPolicyArgs and PolicyPolicyOutput values. You can construct a concrete instance of `PolicyPolicyInput` via:
PolicyPolicyArgs{...}
type PolicyPolicyOutput ¶
type PolicyPolicyOutput struct{ *pulumi.OutputState }
func (PolicyPolicyOutput) ApplyTo ¶
func (o PolicyPolicyOutput) ApplyTo() pulumi.StringOutput
Can either be "exchanges", "queues", or "all".
func (PolicyPolicyOutput) Definition ¶
func (o PolicyPolicyOutput) Definition() pulumi.MapOutput
Key/value pairs of the policy definition. See the RabbitMQ documentation for definition references and examples.
func (PolicyPolicyOutput) ElementType ¶
func (PolicyPolicyOutput) ElementType() reflect.Type
func (PolicyPolicyOutput) Pattern ¶
func (o PolicyPolicyOutput) Pattern() pulumi.StringOutput
A pattern to match an exchange or queue name.
func (PolicyPolicyOutput) Priority ¶
func (o PolicyPolicyOutput) Priority() pulumi.IntOutput
The policy with the greater priority is applied first.
func (PolicyPolicyOutput) ToPolicyPolicyOutput ¶
func (o PolicyPolicyOutput) ToPolicyPolicyOutput() PolicyPolicyOutput
func (PolicyPolicyOutput) ToPolicyPolicyOutputWithContext ¶
func (o PolicyPolicyOutput) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput
func (PolicyPolicyOutput) ToPolicyPolicyPtrOutput ¶
func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
func (PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext ¶
func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
type PolicyPolicyPtrInput ¶
type PolicyPolicyPtrInput interface { pulumi.Input ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput ToPolicyPolicyPtrOutputWithContext(context.Context) PolicyPolicyPtrOutput }
PolicyPolicyPtrInput is an input type that accepts PolicyPolicyArgs, PolicyPolicyPtr and PolicyPolicyPtrOutput values. You can construct a concrete instance of `PolicyPolicyPtrInput` via:
PolicyPolicyArgs{...} or: nil
func PolicyPolicyPtr ¶
func PolicyPolicyPtr(v *PolicyPolicyArgs) PolicyPolicyPtrInput
type PolicyPolicyPtrOutput ¶
type PolicyPolicyPtrOutput struct{ *pulumi.OutputState }
func (PolicyPolicyPtrOutput) ApplyTo ¶
func (o PolicyPolicyPtrOutput) ApplyTo() pulumi.StringPtrOutput
Can either be "exchanges", "queues", or "all".
func (PolicyPolicyPtrOutput) Definition ¶
func (o PolicyPolicyPtrOutput) Definition() pulumi.MapOutput
Key/value pairs of the policy definition. See the RabbitMQ documentation for definition references and examples.
func (PolicyPolicyPtrOutput) Elem ¶
func (o PolicyPolicyPtrOutput) Elem() PolicyPolicyOutput
func (PolicyPolicyPtrOutput) ElementType ¶
func (PolicyPolicyPtrOutput) ElementType() reflect.Type
func (PolicyPolicyPtrOutput) Pattern ¶
func (o PolicyPolicyPtrOutput) Pattern() pulumi.StringPtrOutput
A pattern to match an exchange or queue name.
func (PolicyPolicyPtrOutput) Priority ¶
func (o PolicyPolicyPtrOutput) Priority() pulumi.IntPtrOutput
The policy with the greater priority is applied first.
func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput ¶
func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext ¶
func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput
type PolicyState ¶
type PolicyState struct { // The name of the policy. Name pulumi.StringPtrInput // The settings of the policy. The structure is // described below. Policy PolicyPolicyPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (PolicyState) ElementType ¶
func (PolicyState) ElementType() reflect.Type
type Provider ¶
type Provider struct {
pulumi.ProviderResourceState
}
The provider type for the rabbitmq package. By default, resources use package-wide configuration settings, however an explicit `Provider` instance may be created and passed during resource construction to achieve fine-grained programmatic control over provider settings. See the [documentation](https://www.pulumi.com/docs/reference/programming-model/#providers) for more information.
func NewProvider ¶
func NewProvider(ctx *pulumi.Context, name string, args *ProviderArgs, opts ...pulumi.ResourceOption) (*Provider, error)
NewProvider registers a new resource with the given unique name, arguments, and options.
type ProviderArgs ¶
type ProviderArgs struct { CacertFile pulumi.StringPtrInput ClientcertFile pulumi.StringPtrInput ClientkeyFile pulumi.StringPtrInput Endpoint pulumi.StringPtrInput Insecure pulumi.BoolPtrInput Password pulumi.StringPtrInput Username pulumi.StringPtrInput }
The set of arguments for constructing a Provider resource.
func (ProviderArgs) ElementType ¶
func (ProviderArgs) ElementType() reflect.Type
type Queue ¶
type Queue struct { pulumi.CustomResourceState // The name of the queue. Name pulumi.StringOutput `pulumi:"name"` // The settings of the queue. The structure is // described below. Settings QueueSettingsOutput `pulumi:"settings"` // The vhost to create the resource in. Vhost pulumi.StringPtrOutput `pulumi:"vhost"` }
The “Queue“ resource creates and manages a queue.
## Example Usage ### Basic Example
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: pulumi.String("guest"), Vhost: testVHost.Name, }) if err != nil { return err } _, err = rabbitmq.NewQueue(ctx, "testQueue", &rabbitmq.QueueArgs{ Settings: &rabbitmq.QueueSettingsArgs{ AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), }, Vhost: guest.Vhost, }) if err != nil { return err } return nil }) }
``` ### Example With JSON Arguments
```go package main
import (
"fmt" "github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi" "github.com/pulumi/pulumi/sdk/v2/go/pulumi/config"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { cfg := config.New(ctx, "") arguments := fmt.Sprintf("%v%v%v%v", "{\n", " \"x-message-ttl\": 5000\n", "}\n", "\n") if param := cfg.Get("arguments"); param != "" { arguments = param } testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{ Permissions: &rabbitmq.PermissionsPermissionsArgs{ Configure: pulumi.String(".*"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, User: pulumi.String("guest"), Vhost: testVHost.Name, }) if err != nil { return err } _, err = rabbitmq.NewQueue(ctx, "testQueue", &rabbitmq.QueueArgs{ Settings: &rabbitmq.QueueSettingsArgs{ ArgumentsJson: pulumi.String(arguments), AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), }, Vhost: guest.Vhost, }) if err != nil { return err } return nil }) }
```
func GetQueue ¶
func GetQueue(ctx *pulumi.Context, name string, id pulumi.IDInput, state *QueueState, opts ...pulumi.ResourceOption) (*Queue, error)
GetQueue gets an existing Queue resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
type QueueArgs ¶
type QueueArgs struct { // The name of the queue. Name pulumi.StringPtrInput // The settings of the queue. The structure is // described below. Settings QueueSettingsInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
The set of arguments for constructing a Queue resource.
func (QueueArgs) ElementType ¶
type QueueSettings ¶
type QueueSettings struct { // 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 map[string]interface{} `pulumi:"arguments"` // A nested JSON string which contains additional // settings for the queue. This is useful for when the arguments contain // non-string values. ArgumentsJson *string `pulumi:"argumentsJson"` // Whether the queue will self-delete when all // consumers have unsubscribed. AutoDelete *bool `pulumi:"autoDelete"` // Whether the queue survives server restarts. // Defaults to `false`. Durable *bool `pulumi:"durable"` }
type QueueSettingsArgs ¶
type QueueSettingsArgs struct { // 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.MapInput `pulumi:"arguments"` // A nested JSON string which contains additional // settings for the queue. This is useful for when the arguments contain // non-string values. ArgumentsJson pulumi.StringPtrInput `pulumi:"argumentsJson"` // Whether the queue will self-delete when all // consumers have unsubscribed. AutoDelete pulumi.BoolPtrInput `pulumi:"autoDelete"` // Whether the queue survives server restarts. // Defaults to `false`. Durable pulumi.BoolPtrInput `pulumi:"durable"` }
func (QueueSettingsArgs) ElementType ¶
func (QueueSettingsArgs) ElementType() reflect.Type
func (QueueSettingsArgs) ToQueueSettingsOutput ¶
func (i QueueSettingsArgs) ToQueueSettingsOutput() QueueSettingsOutput
func (QueueSettingsArgs) ToQueueSettingsOutputWithContext ¶
func (i QueueSettingsArgs) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput
func (QueueSettingsArgs) ToQueueSettingsPtrOutput ¶
func (i QueueSettingsArgs) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
func (QueueSettingsArgs) ToQueueSettingsPtrOutputWithContext ¶
func (i QueueSettingsArgs) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
type QueueSettingsInput ¶
type QueueSettingsInput interface { pulumi.Input ToQueueSettingsOutput() QueueSettingsOutput ToQueueSettingsOutputWithContext(context.Context) QueueSettingsOutput }
QueueSettingsInput is an input type that accepts QueueSettingsArgs and QueueSettingsOutput values. You can construct a concrete instance of `QueueSettingsInput` via:
QueueSettingsArgs{...}
type QueueSettingsOutput ¶
type QueueSettingsOutput struct{ *pulumi.OutputState }
func (QueueSettingsOutput) Arguments ¶
func (o QueueSettingsOutput) Arguments() pulumi.MapOutput
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`.
func (QueueSettingsOutput) ArgumentsJson ¶
func (o QueueSettingsOutput) ArgumentsJson() pulumi.StringPtrOutput
A nested JSON string which contains additional settings for the queue. This is useful for when the arguments contain non-string values.
func (QueueSettingsOutput) AutoDelete ¶
func (o QueueSettingsOutput) AutoDelete() pulumi.BoolPtrOutput
Whether the queue will self-delete when all consumers have unsubscribed.
func (QueueSettingsOutput) Durable ¶
func (o QueueSettingsOutput) Durable() pulumi.BoolPtrOutput
Whether the queue survives server restarts. Defaults to `false`.
func (QueueSettingsOutput) ElementType ¶
func (QueueSettingsOutput) ElementType() reflect.Type
func (QueueSettingsOutput) ToQueueSettingsOutput ¶
func (o QueueSettingsOutput) ToQueueSettingsOutput() QueueSettingsOutput
func (QueueSettingsOutput) ToQueueSettingsOutputWithContext ¶
func (o QueueSettingsOutput) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput
func (QueueSettingsOutput) ToQueueSettingsPtrOutput ¶
func (o QueueSettingsOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
func (QueueSettingsOutput) ToQueueSettingsPtrOutputWithContext ¶
func (o QueueSettingsOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
type QueueSettingsPtrInput ¶
type QueueSettingsPtrInput interface { pulumi.Input ToQueueSettingsPtrOutput() QueueSettingsPtrOutput ToQueueSettingsPtrOutputWithContext(context.Context) QueueSettingsPtrOutput }
QueueSettingsPtrInput is an input type that accepts QueueSettingsArgs, QueueSettingsPtr and QueueSettingsPtrOutput values. You can construct a concrete instance of `QueueSettingsPtrInput` via:
QueueSettingsArgs{...} or: nil
func QueueSettingsPtr ¶
func QueueSettingsPtr(v *QueueSettingsArgs) QueueSettingsPtrInput
type QueueSettingsPtrOutput ¶
type QueueSettingsPtrOutput struct{ *pulumi.OutputState }
func (QueueSettingsPtrOutput) Arguments ¶
func (o QueueSettingsPtrOutput) Arguments() pulumi.MapOutput
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`.
func (QueueSettingsPtrOutput) ArgumentsJson ¶
func (o QueueSettingsPtrOutput) ArgumentsJson() pulumi.StringPtrOutput
A nested JSON string which contains additional settings for the queue. This is useful for when the arguments contain non-string values.
func (QueueSettingsPtrOutput) AutoDelete ¶
func (o QueueSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput
Whether the queue will self-delete when all consumers have unsubscribed.
func (QueueSettingsPtrOutput) Durable ¶
func (o QueueSettingsPtrOutput) Durable() pulumi.BoolPtrOutput
Whether the queue survives server restarts. Defaults to `false`.
func (QueueSettingsPtrOutput) Elem ¶
func (o QueueSettingsPtrOutput) Elem() QueueSettingsOutput
func (QueueSettingsPtrOutput) ElementType ¶
func (QueueSettingsPtrOutput) ElementType() reflect.Type
func (QueueSettingsPtrOutput) ToQueueSettingsPtrOutput ¶
func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
func (QueueSettingsPtrOutput) ToQueueSettingsPtrOutputWithContext ¶
func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput
type QueueState ¶
type QueueState struct { // The name of the queue. Name pulumi.StringPtrInput // The settings of the queue. The structure is // described below. Settings QueueSettingsPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (QueueState) ElementType ¶
func (QueueState) ElementType() reflect.Type
type Shovel ¶ added in v2.2.0
type Shovel struct { pulumi.CustomResourceState // The settings of the shovel. The structure is // described below. Info ShovelInfoOutput `pulumi:"info"` // The shovel name. Name pulumi.StringOutput `pulumi:"name"` // The vhost to create the resource in. Vhost pulumi.StringOutput `pulumi:"vhost"` }
The “Shovel“ resource creates and manages a shovel.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } testExchange, err := rabbitmq.NewExchange(ctx, "testExchange", &rabbitmq.ExchangeArgs{ Settings: &rabbitmq.ExchangeSettingsArgs{ AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), Type: pulumi.String("fanout"), }, Vhost: testVHost.Name, }) if err != nil { return err } testQueue, err := rabbitmq.NewQueue(ctx, "testQueue", &rabbitmq.QueueArgs{ Settings: &rabbitmq.QueueSettingsArgs{ AutoDelete: pulumi.Bool(true), Durable: pulumi.Bool(false), }, Vhost: testVHost.Name, }) if err != nil { return err } _, err = rabbitmq.NewShovel(ctx, "shovelTest", &rabbitmq.ShovelArgs{ Info: &rabbitmq.ShovelInfoArgs{ DestinationQueue: testQueue.Name, DestinationUri: pulumi.String("amqp:///test"), SourceExchange: testExchange.Name, SourceExchangeKey: pulumi.String("test"), SourceUri: pulumi.String("amqp:///test"), }, Vhost: testVHost.Name, }) if err != nil { return err } return nil }) }
```
func GetShovel ¶ added in v2.2.0
func GetShovel(ctx *pulumi.Context, name string, id pulumi.IDInput, state *ShovelState, opts ...pulumi.ResourceOption) (*Shovel, error)
GetShovel gets an existing Shovel resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewShovel ¶ added in v2.2.0
func NewShovel(ctx *pulumi.Context, name string, args *ShovelArgs, opts ...pulumi.ResourceOption) (*Shovel, error)
NewShovel registers a new resource with the given unique name, arguments, and options.
type ShovelArgs ¶ added in v2.2.0
type ShovelArgs struct { // The settings of the shovel. The structure is // described below. Info ShovelInfoInput // The shovel name. Name pulumi.StringPtrInput // The vhost to create the resource in. Vhost pulumi.StringInput }
The set of arguments for constructing a Shovel resource.
func (ShovelArgs) ElementType ¶ added in v2.2.0
func (ShovelArgs) ElementType() reflect.Type
type ShovelInfo ¶ added in v2.2.0
type ShovelInfo struct { // Determines how the shovel should acknowledge messages. // Defaults to `on-confirm`. AckMode *string `pulumi:"ackMode"` // Whether to amqp shovel headers. // Defaults to `false`. AddForwardHeaders *bool `pulumi:"addForwardHeaders"` // Determines when (if ever) the shovel should delete itself . // Defaults to `never`. DeleteAfter *string `pulumi:"deleteAfter"` // The exchange to which messages should be published. // Either this or destinationQueue must be specified but not both. DestinationExchange *string `pulumi:"destinationExchange"` // The routing key when using destination_exchange. DestinationExchangeKey *string `pulumi:"destinationExchangeKey"` // The queue to which messages should be published. // Either this or destinationExchange must be specified but not both. DestinationQueue *string `pulumi:"destinationQueue"` // The amqp uri for the destination . DestinationUri string `pulumi:"destinationUri"` // The maximum number of unacknowledged messages copied over a shovel at any one time. // Defaults to `1000`. PrefetchCount *int `pulumi:"prefetchCount"` // The duration in seconds to reconnect to a broker after disconnected. // Defaults to `1`. ReconnectDelay *int `pulumi:"reconnectDelay"` // The exchange from which to consume. // Either this or sourceQueue must be specified but not both. SourceExchange *string `pulumi:"sourceExchange"` // The routing key when using source_exchange. SourceExchangeKey *string `pulumi:"sourceExchangeKey"` // The queue from which to consume. // Either this or sourceExchange must be specified but not both. SourceQueue *string `pulumi:"sourceQueue"` // The amqp uri for the source. SourceUri string `pulumi:"sourceUri"` }
type ShovelInfoArgs ¶ added in v2.2.0
type ShovelInfoArgs struct { // Determines how the shovel should acknowledge messages. // Defaults to `on-confirm`. AckMode pulumi.StringPtrInput `pulumi:"ackMode"` // Whether to amqp shovel headers. // Defaults to `false`. AddForwardHeaders pulumi.BoolPtrInput `pulumi:"addForwardHeaders"` // Determines when (if ever) the shovel should delete itself . // Defaults to `never`. DeleteAfter pulumi.StringPtrInput `pulumi:"deleteAfter"` // The exchange to which messages should be published. // Either this or destinationQueue must be specified but not both. DestinationExchange pulumi.StringPtrInput `pulumi:"destinationExchange"` // The routing key when using destination_exchange. DestinationExchangeKey pulumi.StringPtrInput `pulumi:"destinationExchangeKey"` // The queue to which messages should be published. // Either this or destinationExchange must be specified but not both. DestinationQueue pulumi.StringPtrInput `pulumi:"destinationQueue"` // The amqp uri for the destination . DestinationUri pulumi.StringInput `pulumi:"destinationUri"` // The maximum number of unacknowledged messages copied over a shovel at any one time. // Defaults to `1000`. PrefetchCount pulumi.IntPtrInput `pulumi:"prefetchCount"` // The duration in seconds to reconnect to a broker after disconnected. // Defaults to `1`. ReconnectDelay pulumi.IntPtrInput `pulumi:"reconnectDelay"` // The exchange from which to consume. // Either this or sourceQueue must be specified but not both. SourceExchange pulumi.StringPtrInput `pulumi:"sourceExchange"` // The routing key when using source_exchange. SourceExchangeKey pulumi.StringPtrInput `pulumi:"sourceExchangeKey"` // The queue from which to consume. // Either this or sourceExchange must be specified but not both. SourceQueue pulumi.StringPtrInput `pulumi:"sourceQueue"` // The amqp uri for the source. SourceUri pulumi.StringInput `pulumi:"sourceUri"` }
func (ShovelInfoArgs) ElementType ¶ added in v2.2.0
func (ShovelInfoArgs) ElementType() reflect.Type
func (ShovelInfoArgs) ToShovelInfoOutput ¶ added in v2.2.0
func (i ShovelInfoArgs) ToShovelInfoOutput() ShovelInfoOutput
func (ShovelInfoArgs) ToShovelInfoOutputWithContext ¶ added in v2.2.0
func (i ShovelInfoArgs) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput
func (ShovelInfoArgs) ToShovelInfoPtrOutput ¶ added in v2.2.0
func (i ShovelInfoArgs) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
func (ShovelInfoArgs) ToShovelInfoPtrOutputWithContext ¶ added in v2.2.0
func (i ShovelInfoArgs) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
type ShovelInfoInput ¶ added in v2.2.0
type ShovelInfoInput interface { pulumi.Input ToShovelInfoOutput() ShovelInfoOutput ToShovelInfoOutputWithContext(context.Context) ShovelInfoOutput }
ShovelInfoInput is an input type that accepts ShovelInfoArgs and ShovelInfoOutput values. You can construct a concrete instance of `ShovelInfoInput` via:
ShovelInfoArgs{...}
type ShovelInfoOutput ¶ added in v2.2.0
type ShovelInfoOutput struct{ *pulumi.OutputState }
func (ShovelInfoOutput) AckMode ¶ added in v2.2.0
func (o ShovelInfoOutput) AckMode() pulumi.StringPtrOutput
Determines how the shovel should acknowledge messages. Defaults to `on-confirm`.
func (ShovelInfoOutput) AddForwardHeaders ¶ added in v2.2.0
func (o ShovelInfoOutput) AddForwardHeaders() pulumi.BoolPtrOutput
Whether to amqp shovel headers. Defaults to `false`.
func (ShovelInfoOutput) DeleteAfter ¶ added in v2.2.0
func (o ShovelInfoOutput) DeleteAfter() pulumi.StringPtrOutput
Determines when (if ever) the shovel should delete itself . Defaults to `never`.
func (ShovelInfoOutput) DestinationExchange ¶ added in v2.2.0
func (o ShovelInfoOutput) DestinationExchange() pulumi.StringPtrOutput
The exchange to which messages should be published. Either this or destinationQueue must be specified but not both.
func (ShovelInfoOutput) DestinationExchangeKey ¶ added in v2.2.0
func (o ShovelInfoOutput) DestinationExchangeKey() pulumi.StringPtrOutput
The routing key when using destination_exchange.
func (ShovelInfoOutput) DestinationQueue ¶ added in v2.2.0
func (o ShovelInfoOutput) DestinationQueue() pulumi.StringPtrOutput
The queue to which messages should be published. Either this or destinationExchange must be specified but not both.
func (ShovelInfoOutput) DestinationUri ¶ added in v2.2.0
func (o ShovelInfoOutput) DestinationUri() pulumi.StringOutput
The amqp uri for the destination .
func (ShovelInfoOutput) ElementType ¶ added in v2.2.0
func (ShovelInfoOutput) ElementType() reflect.Type
func (ShovelInfoOutput) PrefetchCount ¶ added in v2.2.0
func (o ShovelInfoOutput) PrefetchCount() pulumi.IntPtrOutput
The maximum number of unacknowledged messages copied over a shovel at any one time. Defaults to `1000`.
func (ShovelInfoOutput) ReconnectDelay ¶ added in v2.2.0
func (o ShovelInfoOutput) ReconnectDelay() pulumi.IntPtrOutput
The duration in seconds to reconnect to a broker after disconnected. Defaults to `1`.
func (ShovelInfoOutput) SourceExchange ¶ added in v2.2.0
func (o ShovelInfoOutput) SourceExchange() pulumi.StringPtrOutput
The exchange from which to consume. Either this or sourceQueue must be specified but not both.
func (ShovelInfoOutput) SourceExchangeKey ¶ added in v2.2.0
func (o ShovelInfoOutput) SourceExchangeKey() pulumi.StringPtrOutput
The routing key when using source_exchange.
func (ShovelInfoOutput) SourceQueue ¶ added in v2.2.0
func (o ShovelInfoOutput) SourceQueue() pulumi.StringPtrOutput
The queue from which to consume. Either this or sourceExchange must be specified but not both.
func (ShovelInfoOutput) SourceUri ¶ added in v2.2.0
func (o ShovelInfoOutput) SourceUri() pulumi.StringOutput
The amqp uri for the source.
func (ShovelInfoOutput) ToShovelInfoOutput ¶ added in v2.2.0
func (o ShovelInfoOutput) ToShovelInfoOutput() ShovelInfoOutput
func (ShovelInfoOutput) ToShovelInfoOutputWithContext ¶ added in v2.2.0
func (o ShovelInfoOutput) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput
func (ShovelInfoOutput) ToShovelInfoPtrOutput ¶ added in v2.2.0
func (o ShovelInfoOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
func (ShovelInfoOutput) ToShovelInfoPtrOutputWithContext ¶ added in v2.2.0
func (o ShovelInfoOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
type ShovelInfoPtrInput ¶ added in v2.2.0
type ShovelInfoPtrInput interface { pulumi.Input ToShovelInfoPtrOutput() ShovelInfoPtrOutput ToShovelInfoPtrOutputWithContext(context.Context) ShovelInfoPtrOutput }
ShovelInfoPtrInput is an input type that accepts ShovelInfoArgs, ShovelInfoPtr and ShovelInfoPtrOutput values. You can construct a concrete instance of `ShovelInfoPtrInput` via:
ShovelInfoArgs{...} or: nil
func ShovelInfoPtr ¶ added in v2.2.0
func ShovelInfoPtr(v *ShovelInfoArgs) ShovelInfoPtrInput
type ShovelInfoPtrOutput ¶ added in v2.2.0
type ShovelInfoPtrOutput struct{ *pulumi.OutputState }
func (ShovelInfoPtrOutput) AckMode ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) AckMode() pulumi.StringPtrOutput
Determines how the shovel should acknowledge messages. Defaults to `on-confirm`.
func (ShovelInfoPtrOutput) AddForwardHeaders ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) AddForwardHeaders() pulumi.BoolPtrOutput
Whether to amqp shovel headers. Defaults to `false`.
func (ShovelInfoPtrOutput) DeleteAfter ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) DeleteAfter() pulumi.StringPtrOutput
Determines when (if ever) the shovel should delete itself . Defaults to `never`.
func (ShovelInfoPtrOutput) DestinationExchange ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) DestinationExchange() pulumi.StringPtrOutput
The exchange to which messages should be published. Either this or destinationQueue must be specified but not both.
func (ShovelInfoPtrOutput) DestinationExchangeKey ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) DestinationExchangeKey() pulumi.StringPtrOutput
The routing key when using destination_exchange.
func (ShovelInfoPtrOutput) DestinationQueue ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) DestinationQueue() pulumi.StringPtrOutput
The queue to which messages should be published. Either this or destinationExchange must be specified but not both.
func (ShovelInfoPtrOutput) DestinationUri ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) DestinationUri() pulumi.StringPtrOutput
The amqp uri for the destination .
func (ShovelInfoPtrOutput) Elem ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) Elem() ShovelInfoOutput
func (ShovelInfoPtrOutput) ElementType ¶ added in v2.2.0
func (ShovelInfoPtrOutput) ElementType() reflect.Type
func (ShovelInfoPtrOutput) PrefetchCount ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) PrefetchCount() pulumi.IntPtrOutput
The maximum number of unacknowledged messages copied over a shovel at any one time. Defaults to `1000`.
func (ShovelInfoPtrOutput) ReconnectDelay ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) ReconnectDelay() pulumi.IntPtrOutput
The duration in seconds to reconnect to a broker after disconnected. Defaults to `1`.
func (ShovelInfoPtrOutput) SourceExchange ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) SourceExchange() pulumi.StringPtrOutput
The exchange from which to consume. Either this or sourceQueue must be specified but not both.
func (ShovelInfoPtrOutput) SourceExchangeKey ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) SourceExchangeKey() pulumi.StringPtrOutput
The routing key when using source_exchange.
func (ShovelInfoPtrOutput) SourceQueue ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) SourceQueue() pulumi.StringPtrOutput
The queue from which to consume. Either this or sourceExchange must be specified but not both.
func (ShovelInfoPtrOutput) SourceUri ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) SourceUri() pulumi.StringPtrOutput
The amqp uri for the source.
func (ShovelInfoPtrOutput) ToShovelInfoPtrOutput ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput
func (ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext ¶ added in v2.2.0
func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput
type ShovelState ¶ added in v2.2.0
type ShovelState struct { // The settings of the shovel. The structure is // described below. Info ShovelInfoPtrInput // The shovel name. Name pulumi.StringPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (ShovelState) ElementType ¶ added in v2.2.0
func (ShovelState) ElementType() reflect.Type
type TopicPermissions ¶
type TopicPermissions struct { pulumi.CustomResourceState // The settings of the permissions. The structure is // described below. Permissions TopicPermissionsPermissionArrayOutput `pulumi:"permissions"` // The user to apply the permissions to. User pulumi.StringOutput `pulumi:"user"` // The vhost to create the resource in. Vhost pulumi.StringPtrOutput `pulumi:"vhost"` }
The “TopicPermissions“ resource creates and manages a user's set of topic permissions.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { testVHost, err := rabbitmq.NewVHost(ctx, "testVHost", nil) if err != nil { return err } testUser, err := rabbitmq.NewUser(ctx, "testUser", &rabbitmq.UserArgs{ Password: pulumi.String("foobar"), Tags: pulumi.StringArray{ pulumi.String("administrator"), }, }) if err != nil { return err } _, err = rabbitmq.NewTopicPermissions(ctx, "testTopicPermissions", &rabbitmq.TopicPermissionsArgs{ Permissions: rabbitmq.TopicPermissionsPermissionArray{ &rabbitmq.TopicPermissionsPermissionArgs{ Exchange: pulumi.String("amq.topic"), Read: pulumi.String(".*"), Write: pulumi.String(".*"), }, }, User: testUser.Name, Vhost: testVHost.Name, }) if err != nil { return err } return nil }) }
```
func GetTopicPermissions ¶
func GetTopicPermissions(ctx *pulumi.Context, name string, id pulumi.IDInput, state *TopicPermissionsState, opts ...pulumi.ResourceOption) (*TopicPermissions, error)
GetTopicPermissions gets an existing TopicPermissions resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewTopicPermissions ¶
func NewTopicPermissions(ctx *pulumi.Context, name string, args *TopicPermissionsArgs, opts ...pulumi.ResourceOption) (*TopicPermissions, error)
NewTopicPermissions registers a new resource with the given unique name, arguments, and options.
type TopicPermissionsArgs ¶
type TopicPermissionsArgs struct { // The settings of the permissions. The structure is // described below. Permissions TopicPermissionsPermissionArrayInput // The user to apply the permissions to. User pulumi.StringInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
The set of arguments for constructing a TopicPermissions resource.
func (TopicPermissionsArgs) ElementType ¶
func (TopicPermissionsArgs) ElementType() reflect.Type
type TopicPermissionsPermissionArgs ¶
type TopicPermissionsPermissionArgs struct { // The exchange to set the permissions for. Exchange pulumi.StringInput `pulumi:"exchange"` // The "read" ACL. Read pulumi.StringInput `pulumi:"read"` // The "write" ACL. Write pulumi.StringInput `pulumi:"write"` }
func (TopicPermissionsPermissionArgs) ElementType ¶
func (TopicPermissionsPermissionArgs) ElementType() reflect.Type
func (TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput ¶
func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput
func (TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext ¶
func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput
type TopicPermissionsPermissionArray ¶
type TopicPermissionsPermissionArray []TopicPermissionsPermissionInput
func (TopicPermissionsPermissionArray) ElementType ¶
func (TopicPermissionsPermissionArray) ElementType() reflect.Type
func (TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput ¶
func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput
func (TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext ¶
func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput
type TopicPermissionsPermissionArrayInput ¶
type TopicPermissionsPermissionArrayInput interface { pulumi.Input ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput ToTopicPermissionsPermissionArrayOutputWithContext(context.Context) TopicPermissionsPermissionArrayOutput }
TopicPermissionsPermissionArrayInput is an input type that accepts TopicPermissionsPermissionArray and TopicPermissionsPermissionArrayOutput values. You can construct a concrete instance of `TopicPermissionsPermissionArrayInput` via:
TopicPermissionsPermissionArray{ TopicPermissionsPermissionArgs{...} }
type TopicPermissionsPermissionArrayOutput ¶
type TopicPermissionsPermissionArrayOutput struct{ *pulumi.OutputState }
func (TopicPermissionsPermissionArrayOutput) ElementType ¶
func (TopicPermissionsPermissionArrayOutput) ElementType() reflect.Type
func (TopicPermissionsPermissionArrayOutput) Index ¶
func (o TopicPermissionsPermissionArrayOutput) Index(i pulumi.IntInput) TopicPermissionsPermissionOutput
func (TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput ¶
func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput
func (TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext ¶
func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput
type TopicPermissionsPermissionInput ¶
type TopicPermissionsPermissionInput interface { pulumi.Input ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput ToTopicPermissionsPermissionOutputWithContext(context.Context) TopicPermissionsPermissionOutput }
TopicPermissionsPermissionInput is an input type that accepts TopicPermissionsPermissionArgs and TopicPermissionsPermissionOutput values. You can construct a concrete instance of `TopicPermissionsPermissionInput` via:
TopicPermissionsPermissionArgs{...}
type TopicPermissionsPermissionOutput ¶
type TopicPermissionsPermissionOutput struct{ *pulumi.OutputState }
func (TopicPermissionsPermissionOutput) ElementType ¶
func (TopicPermissionsPermissionOutput) ElementType() reflect.Type
func (TopicPermissionsPermissionOutput) Exchange ¶
func (o TopicPermissionsPermissionOutput) Exchange() pulumi.StringOutput
The exchange to set the permissions for.
func (TopicPermissionsPermissionOutput) Read ¶
func (o TopicPermissionsPermissionOutput) Read() pulumi.StringOutput
The "read" ACL.
func (TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput ¶
func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput
func (TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext ¶
func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput
func (TopicPermissionsPermissionOutput) Write ¶
func (o TopicPermissionsPermissionOutput) Write() pulumi.StringOutput
The "write" ACL.
type TopicPermissionsState ¶
type TopicPermissionsState struct { // The settings of the permissions. The structure is // described below. Permissions TopicPermissionsPermissionArrayInput // The user to apply the permissions to. User pulumi.StringPtrInput // The vhost to create the resource in. Vhost pulumi.StringPtrInput }
func (TopicPermissionsState) ElementType ¶
func (TopicPermissionsState) ElementType() reflect.Type
type User ¶
type User struct { pulumi.CustomResourceState // The name of the user. Name pulumi.StringOutput `pulumi:"name"` // The password of the user. The value of this argument // is plain-text so make sure to secure where this is defined. Password pulumi.StringOutput `pulumi:"password"` // Which permission model to apply to the user. Valid // options are: management, policymaker, monitoring, and administrator. Tags pulumi.StringArrayOutput `pulumi:"tags"` }
The “User“ resource creates and manages a user.
> **Note:** All arguments including username and password will be stored in the raw state as plain-text. [Read more about sensitive data in state](https://www.terraform.io/docs/state/sensitive-data.html).
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := rabbitmq.NewUser(ctx, "test", &rabbitmq.UserArgs{ Password: pulumi.String("foobar"), Tags: pulumi.StringArray{ pulumi.String("administrator"), pulumi.String("management"), }, }) if err != nil { return err } return nil }) }
```
func GetUser ¶
func GetUser(ctx *pulumi.Context, name string, id pulumi.IDInput, state *UserState, opts ...pulumi.ResourceOption) (*User, error)
GetUser gets an existing User resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
type UserArgs ¶
type UserArgs struct { // The name of the user. Name pulumi.StringPtrInput // The password of the user. The value of this argument // is plain-text so make sure to secure where this is defined. Password pulumi.StringInput // Which permission model to apply to the user. Valid // options are: management, policymaker, monitoring, and administrator. Tags pulumi.StringArrayInput }
The set of arguments for constructing a User resource.
func (UserArgs) ElementType ¶
type UserState ¶
type UserState struct { // The name of the user. Name pulumi.StringPtrInput // The password of the user. The value of this argument // is plain-text so make sure to secure where this is defined. Password pulumi.StringPtrInput // Which permission model to apply to the user. Valid // options are: management, policymaker, monitoring, and administrator. Tags pulumi.StringArrayInput }
func (UserState) ElementType ¶
type VHost ¶
type VHost struct { pulumi.CustomResourceState // The name of the vhost. Name pulumi.StringOutput `pulumi:"name"` }
The “VHost“ resource creates and manages a vhost.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-rabbitmq/sdk/v2/go/rabbitmq" "github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := rabbitmq.NewVHost(ctx, "myVhost", nil) if err != nil { return err } return nil }) }
```
func GetVHost ¶
func GetVHost(ctx *pulumi.Context, name string, id pulumi.IDInput, state *VHostState, opts ...pulumi.ResourceOption) (*VHost, error)
GetVHost gets an existing VHost resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
type VHostArgs ¶
type VHostArgs struct { // The name of the vhost. Name pulumi.StringPtrInput }
The set of arguments for constructing a VHost resource.
func (VHostArgs) ElementType ¶
type VHostState ¶
type VHostState struct { // The name of the vhost. Name pulumi.StringPtrInput }
func (VHostState) ElementType ¶
func (VHostState) ElementType() reflect.Type