Documentation ¶
Overview ¶
A Pulumi package for creating and managing RabbitMQ resources.
Index ¶
- func PkgVersion() (semver.Version, error)
- type Binding
- func (*Binding) ElementType() reflect.Type
- func (i *Binding) ToBindingOutput() BindingOutput
- func (i *Binding) ToBindingOutputWithContext(ctx context.Context) BindingOutput
- func (i *Binding) ToBindingPtrOutput() BindingPtrOutput
- func (i *Binding) ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput
- type BindingArgs
- type BindingArray
- type BindingArrayInput
- type BindingArrayOutput
- type BindingInput
- type BindingMap
- type BindingMapInput
- type BindingMapOutput
- type BindingOutput
- func (BindingOutput) ElementType() reflect.Type
- func (o BindingOutput) ToBindingOutput() BindingOutput
- func (o BindingOutput) ToBindingOutputWithContext(ctx context.Context) BindingOutput
- func (o BindingOutput) ToBindingPtrOutput() BindingPtrOutput
- func (o BindingOutput) ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput
- type BindingPtrInput
- type BindingPtrOutput
- type BindingState
- type Exchange
- func (*Exchange) ElementType() reflect.Type
- func (i *Exchange) ToExchangeOutput() ExchangeOutput
- func (i *Exchange) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput
- func (i *Exchange) ToExchangePtrOutput() ExchangePtrOutput
- func (i *Exchange) ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput
- type ExchangeArgs
- type ExchangeArray
- type ExchangeArrayInput
- type ExchangeArrayOutput
- type ExchangeInput
- type ExchangeMap
- type ExchangeMapInput
- type ExchangeMapOutput
- type ExchangeOutput
- func (ExchangeOutput) ElementType() reflect.Type
- func (o ExchangeOutput) ToExchangeOutput() ExchangeOutput
- func (o ExchangeOutput) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput
- func (o ExchangeOutput) ToExchangePtrOutput() ExchangePtrOutput
- func (o ExchangeOutput) ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput
- type ExchangePtrInput
- type ExchangePtrOutput
- 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
- func (*FederationUpstream) ElementType() reflect.Type
- func (i *FederationUpstream) ToFederationUpstreamOutput() FederationUpstreamOutput
- func (i *FederationUpstream) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput
- func (i *FederationUpstream) ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput
- func (i *FederationUpstream) ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput
- type FederationUpstreamArgs
- type FederationUpstreamArray
- type FederationUpstreamArrayInput
- type FederationUpstreamArrayOutput
- func (FederationUpstreamArrayOutput) ElementType() reflect.Type
- func (o FederationUpstreamArrayOutput) Index(i pulumi.IntInput) FederationUpstreamOutput
- func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput
- func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutputWithContext(ctx context.Context) FederationUpstreamArrayOutput
- 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 FederationUpstreamInput
- type FederationUpstreamMap
- type FederationUpstreamMapInput
- type FederationUpstreamMapOutput
- func (FederationUpstreamMapOutput) ElementType() reflect.Type
- func (o FederationUpstreamMapOutput) MapIndex(k pulumi.StringInput) FederationUpstreamOutput
- func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutput() FederationUpstreamMapOutput
- func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutputWithContext(ctx context.Context) FederationUpstreamMapOutput
- type FederationUpstreamOutput
- func (FederationUpstreamOutput) ElementType() reflect.Type
- func (o FederationUpstreamOutput) ToFederationUpstreamOutput() FederationUpstreamOutput
- func (o FederationUpstreamOutput) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput
- func (o FederationUpstreamOutput) ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput
- func (o FederationUpstreamOutput) ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput
- type FederationUpstreamPtrInput
- type FederationUpstreamPtrOutput
- type FederationUpstreamState
- type Permissions
- func (*Permissions) ElementType() reflect.Type
- func (i *Permissions) ToPermissionsOutput() PermissionsOutput
- func (i *Permissions) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput
- func (i *Permissions) ToPermissionsPtrOutput() PermissionsPtrOutput
- func (i *Permissions) ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput
- type PermissionsArgs
- type PermissionsArray
- type PermissionsArrayInput
- type PermissionsArrayOutput
- func (PermissionsArrayOutput) ElementType() reflect.Type
- func (o PermissionsArrayOutput) Index(i pulumi.IntInput) PermissionsOutput
- func (o PermissionsArrayOutput) ToPermissionsArrayOutput() PermissionsArrayOutput
- func (o PermissionsArrayOutput) ToPermissionsArrayOutputWithContext(ctx context.Context) PermissionsArrayOutput
- type PermissionsInput
- type PermissionsMap
- type PermissionsMapInput
- type PermissionsMapOutput
- func (PermissionsMapOutput) ElementType() reflect.Type
- func (o PermissionsMapOutput) MapIndex(k pulumi.StringInput) PermissionsOutput
- func (o PermissionsMapOutput) ToPermissionsMapOutput() PermissionsMapOutput
- func (o PermissionsMapOutput) ToPermissionsMapOutputWithContext(ctx context.Context) PermissionsMapOutput
- type PermissionsOutput
- func (PermissionsOutput) ElementType() reflect.Type
- func (o PermissionsOutput) ToPermissionsOutput() PermissionsOutput
- func (o PermissionsOutput) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput
- func (o PermissionsOutput) ToPermissionsPtrOutput() PermissionsPtrOutput
- func (o PermissionsOutput) ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput
- 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 PermissionsPtrInput
- type PermissionsPtrOutput
- type PermissionsState
- type Policy
- func (*Policy) ElementType() reflect.Type
- func (i *Policy) ToPolicyOutput() PolicyOutput
- func (i *Policy) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput
- func (i *Policy) ToPolicyPtrOutput() PolicyPtrOutput
- func (i *Policy) ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput
- type PolicyArgs
- type PolicyArray
- type PolicyArrayInput
- type PolicyArrayOutput
- type PolicyInput
- type PolicyMap
- type PolicyMapInput
- type PolicyMapOutput
- type PolicyOutput
- func (PolicyOutput) ElementType() reflect.Type
- func (o PolicyOutput) ToPolicyOutput() PolicyOutput
- func (o PolicyOutput) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput
- func (o PolicyOutput) ToPolicyPtrOutput() PolicyPtrOutput
- func (o PolicyOutput) ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput
- 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 PolicyPtrInput
- type PolicyPtrOutput
- type PolicyState
- type Provider
- func (*Provider) ElementType() reflect.Type
- func (i *Provider) ToProviderOutput() ProviderOutput
- func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
- func (i *Provider) ToProviderPtrOutput() ProviderPtrOutput
- func (i *Provider) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
- type ProviderArgs
- type ProviderInput
- type ProviderOutput
- func (ProviderOutput) ElementType() reflect.Type
- func (o ProviderOutput) ToProviderOutput() ProviderOutput
- func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
- func (o ProviderOutput) ToProviderPtrOutput() ProviderPtrOutput
- func (o ProviderOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
- type ProviderPtrInput
- type ProviderPtrOutput
- type Queue
- type QueueArgs
- type QueueArray
- type QueueArrayInput
- type QueueArrayOutput
- type QueueInput
- type QueueMap
- type QueueMapInput
- type QueueMapOutput
- type QueueOutput
- func (QueueOutput) ElementType() reflect.Type
- func (o QueueOutput) ToQueueOutput() QueueOutput
- func (o QueueOutput) ToQueueOutputWithContext(ctx context.Context) QueueOutput
- func (o QueueOutput) ToQueuePtrOutput() QueuePtrOutput
- func (o QueueOutput) ToQueuePtrOutputWithContext(ctx context.Context) QueuePtrOutput
- type QueuePtrInput
- type QueuePtrOutput
- 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
- func (*Shovel) ElementType() reflect.Type
- func (i *Shovel) ToShovelOutput() ShovelOutput
- func (i *Shovel) ToShovelOutputWithContext(ctx context.Context) ShovelOutput
- func (i *Shovel) ToShovelPtrOutput() ShovelPtrOutput
- func (i *Shovel) ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput
- type ShovelArgs
- type ShovelArray
- type ShovelArrayInput
- type ShovelArrayOutput
- 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 ShovelInput
- type ShovelMap
- type ShovelMapInput
- type ShovelMapOutput
- type ShovelOutput
- func (ShovelOutput) ElementType() reflect.Type
- func (o ShovelOutput) ToShovelOutput() ShovelOutput
- func (o ShovelOutput) ToShovelOutputWithContext(ctx context.Context) ShovelOutput
- func (o ShovelOutput) ToShovelPtrOutput() ShovelPtrOutput
- func (o ShovelOutput) ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput
- type ShovelPtrInput
- type ShovelPtrOutput
- type ShovelState
- type TopicPermissions
- func (*TopicPermissions) ElementType() reflect.Type
- func (i *TopicPermissions) ToTopicPermissionsOutput() TopicPermissionsOutput
- func (i *TopicPermissions) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput
- func (i *TopicPermissions) ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput
- func (i *TopicPermissions) ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput
- type TopicPermissionsArgs
- type TopicPermissionsArray
- type TopicPermissionsArrayInput
- type TopicPermissionsArrayOutput
- func (TopicPermissionsArrayOutput) ElementType() reflect.Type
- func (o TopicPermissionsArrayOutput) Index(i pulumi.IntInput) TopicPermissionsOutput
- func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput
- func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutputWithContext(ctx context.Context) TopicPermissionsArrayOutput
- type TopicPermissionsInput
- type TopicPermissionsMap
- type TopicPermissionsMapInput
- type TopicPermissionsMapOutput
- func (TopicPermissionsMapOutput) ElementType() reflect.Type
- func (o TopicPermissionsMapOutput) MapIndex(k pulumi.StringInput) TopicPermissionsOutput
- func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutput() TopicPermissionsMapOutput
- func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutputWithContext(ctx context.Context) TopicPermissionsMapOutput
- type TopicPermissionsOutput
- func (TopicPermissionsOutput) ElementType() reflect.Type
- func (o TopicPermissionsOutput) ToTopicPermissionsOutput() TopicPermissionsOutput
- func (o TopicPermissionsOutput) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput
- func (o TopicPermissionsOutput) ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput
- func (o TopicPermissionsOutput) ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput
- 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 TopicPermissionsPtrInput
- type TopicPermissionsPtrOutput
- type TopicPermissionsState
- type User
- type UserArgs
- type UserArray
- type UserArrayInput
- type UserArrayOutput
- type UserInput
- type UserMap
- type UserMapInput
- type UserMapOutput
- type UserOutput
- func (UserOutput) ElementType() reflect.Type
- func (o UserOutput) ToUserOutput() UserOutput
- func (o UserOutput) ToUserOutputWithContext(ctx context.Context) UserOutput
- func (o UserOutput) ToUserPtrOutput() UserPtrOutput
- func (o UserOutput) ToUserPtrOutputWithContext(ctx context.Context) UserPtrOutput
- type UserPtrInput
- type UserPtrOutput
- type UserState
- type VHost
- type VHostArgs
- type VHostArray
- type VHostArrayInput
- type VHostArrayOutput
- type VHostInput
- type VHostMap
- type VHostMapInput
- type VHostMapOutput
- type VHostOutput
- func (VHostOutput) ElementType() reflect.Type
- func (o VHostOutput) ToVHostOutput() VHostOutput
- func (o VHostOutput) ToVHostOutputWithContext(ctx context.Context) VHostOutput
- func (o VHostOutput) ToVHostPtrOutput() VHostPtrOutput
- func (o VHostOutput) ToVHostPtrOutputWithContext(ctx context.Context) VHostPtrOutput
- type VHostPtrInput
- type VHostPtrOutput
- type VHostState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PkgVersion ¶ added in v2.5.0
PkgVersion uses reflection to determine the version of the current package.
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 }) }
```
## Import
Bindings can be imported using the `id` which is composed of
`vhost/source/destination/destination_type/properties_key`. E.g.
```sh
$ pulumi import rabbitmq:index/binding:Binding test test/test/test/queue/%23
```
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.
func (*Binding) ElementType ¶ added in v2.4.1
func (*Binding) ToBindingOutput ¶ added in v2.4.1
func (i *Binding) ToBindingOutput() BindingOutput
func (*Binding) ToBindingOutputWithContext ¶ added in v2.4.1
func (i *Binding) ToBindingOutputWithContext(ctx context.Context) BindingOutput
func (*Binding) ToBindingPtrOutput ¶ added in v2.5.1
func (i *Binding) ToBindingPtrOutput() BindingPtrOutput
func (*Binding) ToBindingPtrOutputWithContext ¶ added in v2.5.1
func (i *Binding) ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput
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 BindingArray ¶ added in v2.5.1
type BindingArray []BindingInput
func (BindingArray) ElementType ¶ added in v2.5.1
func (BindingArray) ElementType() reflect.Type
func (BindingArray) ToBindingArrayOutput ¶ added in v2.5.1
func (i BindingArray) ToBindingArrayOutput() BindingArrayOutput
func (BindingArray) ToBindingArrayOutputWithContext ¶ added in v2.5.1
func (i BindingArray) ToBindingArrayOutputWithContext(ctx context.Context) BindingArrayOutput
type BindingArrayInput ¶ added in v2.5.1
type BindingArrayInput interface { pulumi.Input ToBindingArrayOutput() BindingArrayOutput ToBindingArrayOutputWithContext(context.Context) BindingArrayOutput }
BindingArrayInput is an input type that accepts BindingArray and BindingArrayOutput values. You can construct a concrete instance of `BindingArrayInput` via:
BindingArray{ BindingArgs{...} }
type BindingArrayOutput ¶ added in v2.5.1
type BindingArrayOutput struct{ *pulumi.OutputState }
func (BindingArrayOutput) ElementType ¶ added in v2.5.1
func (BindingArrayOutput) ElementType() reflect.Type
func (BindingArrayOutput) Index ¶ added in v2.5.1
func (o BindingArrayOutput) Index(i pulumi.IntInput) BindingOutput
func (BindingArrayOutput) ToBindingArrayOutput ¶ added in v2.5.1
func (o BindingArrayOutput) ToBindingArrayOutput() BindingArrayOutput
func (BindingArrayOutput) ToBindingArrayOutputWithContext ¶ added in v2.5.1
func (o BindingArrayOutput) ToBindingArrayOutputWithContext(ctx context.Context) BindingArrayOutput
type BindingInput ¶ added in v2.4.1
type BindingInput interface { pulumi.Input ToBindingOutput() BindingOutput ToBindingOutputWithContext(ctx context.Context) BindingOutput }
type BindingMap ¶ added in v2.5.1
type BindingMap map[string]BindingInput
func (BindingMap) ElementType ¶ added in v2.5.1
func (BindingMap) ElementType() reflect.Type
func (BindingMap) ToBindingMapOutput ¶ added in v2.5.1
func (i BindingMap) ToBindingMapOutput() BindingMapOutput
func (BindingMap) ToBindingMapOutputWithContext ¶ added in v2.5.1
func (i BindingMap) ToBindingMapOutputWithContext(ctx context.Context) BindingMapOutput
type BindingMapInput ¶ added in v2.5.1
type BindingMapInput interface { pulumi.Input ToBindingMapOutput() BindingMapOutput ToBindingMapOutputWithContext(context.Context) BindingMapOutput }
BindingMapInput is an input type that accepts BindingMap and BindingMapOutput values. You can construct a concrete instance of `BindingMapInput` via:
BindingMap{ "key": BindingArgs{...} }
type BindingMapOutput ¶ added in v2.5.1
type BindingMapOutput struct{ *pulumi.OutputState }
func (BindingMapOutput) ElementType ¶ added in v2.5.1
func (BindingMapOutput) ElementType() reflect.Type
func (BindingMapOutput) MapIndex ¶ added in v2.5.1
func (o BindingMapOutput) MapIndex(k pulumi.StringInput) BindingOutput
func (BindingMapOutput) ToBindingMapOutput ¶ added in v2.5.1
func (o BindingMapOutput) ToBindingMapOutput() BindingMapOutput
func (BindingMapOutput) ToBindingMapOutputWithContext ¶ added in v2.5.1
func (o BindingMapOutput) ToBindingMapOutputWithContext(ctx context.Context) BindingMapOutput
type BindingOutput ¶ added in v2.4.1
type BindingOutput struct {
*pulumi.OutputState
}
func (BindingOutput) ElementType ¶ added in v2.4.1
func (BindingOutput) ElementType() reflect.Type
func (BindingOutput) ToBindingOutput ¶ added in v2.4.1
func (o BindingOutput) ToBindingOutput() BindingOutput
func (BindingOutput) ToBindingOutputWithContext ¶ added in v2.4.1
func (o BindingOutput) ToBindingOutputWithContext(ctx context.Context) BindingOutput
func (BindingOutput) ToBindingPtrOutput ¶ added in v2.5.1
func (o BindingOutput) ToBindingPtrOutput() BindingPtrOutput
func (BindingOutput) ToBindingPtrOutputWithContext ¶ added in v2.5.1
func (o BindingOutput) ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput
type BindingPtrInput ¶ added in v2.5.1
type BindingPtrInput interface { pulumi.Input ToBindingPtrOutput() BindingPtrOutput ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput }
type BindingPtrOutput ¶ added in v2.5.1
type BindingPtrOutput struct {
*pulumi.OutputState
}
func (BindingPtrOutput) ElementType ¶ added in v2.5.1
func (BindingPtrOutput) ElementType() reflect.Type
func (BindingPtrOutput) ToBindingPtrOutput ¶ added in v2.5.1
func (o BindingPtrOutput) ToBindingPtrOutput() BindingPtrOutput
func (BindingPtrOutput) ToBindingPtrOutputWithContext ¶ added in v2.5.1
func (o BindingPtrOutput) ToBindingPtrOutputWithContext(ctx context.Context) BindingPtrOutput
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 }) }
```
## Import
Exchanges can be imported using the `id` which is composed of ¶
`name@vhost`. E.g.
```sh
$ pulumi import rabbitmq:index/exchange:Exchange test test@vhost
```
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.
func (*Exchange) ElementType ¶ added in v2.4.1
func (*Exchange) ToExchangeOutput ¶ added in v2.4.1
func (i *Exchange) ToExchangeOutput() ExchangeOutput
func (*Exchange) ToExchangeOutputWithContext ¶ added in v2.4.1
func (i *Exchange) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput
func (*Exchange) ToExchangePtrOutput ¶ added in v2.5.1
func (i *Exchange) ToExchangePtrOutput() ExchangePtrOutput
func (*Exchange) ToExchangePtrOutputWithContext ¶ added in v2.5.1
func (i *Exchange) ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput
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 ExchangeArray ¶ added in v2.5.1
type ExchangeArray []ExchangeInput
func (ExchangeArray) ElementType ¶ added in v2.5.1
func (ExchangeArray) ElementType() reflect.Type
func (ExchangeArray) ToExchangeArrayOutput ¶ added in v2.5.1
func (i ExchangeArray) ToExchangeArrayOutput() ExchangeArrayOutput
func (ExchangeArray) ToExchangeArrayOutputWithContext ¶ added in v2.5.1
func (i ExchangeArray) ToExchangeArrayOutputWithContext(ctx context.Context) ExchangeArrayOutput
type ExchangeArrayInput ¶ added in v2.5.1
type ExchangeArrayInput interface { pulumi.Input ToExchangeArrayOutput() ExchangeArrayOutput ToExchangeArrayOutputWithContext(context.Context) ExchangeArrayOutput }
ExchangeArrayInput is an input type that accepts ExchangeArray and ExchangeArrayOutput values. You can construct a concrete instance of `ExchangeArrayInput` via:
ExchangeArray{ ExchangeArgs{...} }
type ExchangeArrayOutput ¶ added in v2.5.1
type ExchangeArrayOutput struct{ *pulumi.OutputState }
func (ExchangeArrayOutput) ElementType ¶ added in v2.5.1
func (ExchangeArrayOutput) ElementType() reflect.Type
func (ExchangeArrayOutput) Index ¶ added in v2.5.1
func (o ExchangeArrayOutput) Index(i pulumi.IntInput) ExchangeOutput
func (ExchangeArrayOutput) ToExchangeArrayOutput ¶ added in v2.5.1
func (o ExchangeArrayOutput) ToExchangeArrayOutput() ExchangeArrayOutput
func (ExchangeArrayOutput) ToExchangeArrayOutputWithContext ¶ added in v2.5.1
func (o ExchangeArrayOutput) ToExchangeArrayOutputWithContext(ctx context.Context) ExchangeArrayOutput
type ExchangeInput ¶ added in v2.4.1
type ExchangeInput interface { pulumi.Input ToExchangeOutput() ExchangeOutput ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput }
type ExchangeMap ¶ added in v2.5.1
type ExchangeMap map[string]ExchangeInput
func (ExchangeMap) ElementType ¶ added in v2.5.1
func (ExchangeMap) ElementType() reflect.Type
func (ExchangeMap) ToExchangeMapOutput ¶ added in v2.5.1
func (i ExchangeMap) ToExchangeMapOutput() ExchangeMapOutput
func (ExchangeMap) ToExchangeMapOutputWithContext ¶ added in v2.5.1
func (i ExchangeMap) ToExchangeMapOutputWithContext(ctx context.Context) ExchangeMapOutput
type ExchangeMapInput ¶ added in v2.5.1
type ExchangeMapInput interface { pulumi.Input ToExchangeMapOutput() ExchangeMapOutput ToExchangeMapOutputWithContext(context.Context) ExchangeMapOutput }
ExchangeMapInput is an input type that accepts ExchangeMap and ExchangeMapOutput values. You can construct a concrete instance of `ExchangeMapInput` via:
ExchangeMap{ "key": ExchangeArgs{...} }
type ExchangeMapOutput ¶ added in v2.5.1
type ExchangeMapOutput struct{ *pulumi.OutputState }
func (ExchangeMapOutput) ElementType ¶ added in v2.5.1
func (ExchangeMapOutput) ElementType() reflect.Type
func (ExchangeMapOutput) MapIndex ¶ added in v2.5.1
func (o ExchangeMapOutput) MapIndex(k pulumi.StringInput) ExchangeOutput
func (ExchangeMapOutput) ToExchangeMapOutput ¶ added in v2.5.1
func (o ExchangeMapOutput) ToExchangeMapOutput() ExchangeMapOutput
func (ExchangeMapOutput) ToExchangeMapOutputWithContext ¶ added in v2.5.1
func (o ExchangeMapOutput) ToExchangeMapOutputWithContext(ctx context.Context) ExchangeMapOutput
type ExchangeOutput ¶ added in v2.4.1
type ExchangeOutput struct {
*pulumi.OutputState
}
func (ExchangeOutput) ElementType ¶ added in v2.4.1
func (ExchangeOutput) ElementType() reflect.Type
func (ExchangeOutput) ToExchangeOutput ¶ added in v2.4.1
func (o ExchangeOutput) ToExchangeOutput() ExchangeOutput
func (ExchangeOutput) ToExchangeOutputWithContext ¶ added in v2.4.1
func (o ExchangeOutput) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput
func (ExchangeOutput) ToExchangePtrOutput ¶ added in v2.5.1
func (o ExchangeOutput) ToExchangePtrOutput() ExchangePtrOutput
func (ExchangeOutput) ToExchangePtrOutputWithContext ¶ added in v2.5.1
func (o ExchangeOutput) ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput
type ExchangePtrInput ¶ added in v2.5.1
type ExchangePtrInput interface { pulumi.Input ToExchangePtrOutput() ExchangePtrOutput ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput }
type ExchangePtrOutput ¶ added in v2.5.1
type ExchangePtrOutput struct {
*pulumi.OutputState
}
func (ExchangePtrOutput) ElementType ¶ added in v2.5.1
func (ExchangePtrOutput) ElementType() reflect.Type
func (ExchangePtrOutput) ToExchangePtrOutput ¶ added in v2.5.1
func (o ExchangePtrOutput) ToExchangePtrOutput() ExchangePtrOutput
func (ExchangePtrOutput) ToExchangePtrOutputWithContext ¶ added in v2.5.1
func (o ExchangePtrOutput) ToExchangePtrOutputWithContext(ctx context.Context) ExchangePtrOutput
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.
func (*FederationUpstream) ElementType ¶ added in v2.4.1
func (*FederationUpstream) ElementType() reflect.Type
func (*FederationUpstream) ToFederationUpstreamOutput ¶ added in v2.4.1
func (i *FederationUpstream) ToFederationUpstreamOutput() FederationUpstreamOutput
func (*FederationUpstream) ToFederationUpstreamOutputWithContext ¶ added in v2.4.1
func (i *FederationUpstream) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput
func (*FederationUpstream) ToFederationUpstreamPtrOutput ¶ added in v2.5.1
func (i *FederationUpstream) ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput
func (*FederationUpstream) ToFederationUpstreamPtrOutputWithContext ¶ added in v2.5.1
func (i *FederationUpstream) ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput
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 FederationUpstreamArray ¶ added in v2.5.1
type FederationUpstreamArray []FederationUpstreamInput
func (FederationUpstreamArray) ElementType ¶ added in v2.5.1
func (FederationUpstreamArray) ElementType() reflect.Type
func (FederationUpstreamArray) ToFederationUpstreamArrayOutput ¶ added in v2.5.1
func (i FederationUpstreamArray) ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput
func (FederationUpstreamArray) ToFederationUpstreamArrayOutputWithContext ¶ added in v2.5.1
func (i FederationUpstreamArray) ToFederationUpstreamArrayOutputWithContext(ctx context.Context) FederationUpstreamArrayOutput
type FederationUpstreamArrayInput ¶ added in v2.5.1
type FederationUpstreamArrayInput interface { pulumi.Input ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput ToFederationUpstreamArrayOutputWithContext(context.Context) FederationUpstreamArrayOutput }
FederationUpstreamArrayInput is an input type that accepts FederationUpstreamArray and FederationUpstreamArrayOutput values. You can construct a concrete instance of `FederationUpstreamArrayInput` via:
FederationUpstreamArray{ FederationUpstreamArgs{...} }
type FederationUpstreamArrayOutput ¶ added in v2.5.1
type FederationUpstreamArrayOutput struct{ *pulumi.OutputState }
func (FederationUpstreamArrayOutput) ElementType ¶ added in v2.5.1
func (FederationUpstreamArrayOutput) ElementType() reflect.Type
func (FederationUpstreamArrayOutput) Index ¶ added in v2.5.1
func (o FederationUpstreamArrayOutput) Index(i pulumi.IntInput) FederationUpstreamOutput
func (FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutput ¶ added in v2.5.1
func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput
func (FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutputWithContext ¶ added in v2.5.1
func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutputWithContext(ctx context.Context) FederationUpstreamArrayOutput
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 FederationUpstreamInput ¶ added in v2.4.1
type FederationUpstreamInput interface { pulumi.Input ToFederationUpstreamOutput() FederationUpstreamOutput ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput }
type FederationUpstreamMap ¶ added in v2.5.1
type FederationUpstreamMap map[string]FederationUpstreamInput
func (FederationUpstreamMap) ElementType ¶ added in v2.5.1
func (FederationUpstreamMap) ElementType() reflect.Type
func (FederationUpstreamMap) ToFederationUpstreamMapOutput ¶ added in v2.5.1
func (i FederationUpstreamMap) ToFederationUpstreamMapOutput() FederationUpstreamMapOutput
func (FederationUpstreamMap) ToFederationUpstreamMapOutputWithContext ¶ added in v2.5.1
func (i FederationUpstreamMap) ToFederationUpstreamMapOutputWithContext(ctx context.Context) FederationUpstreamMapOutput
type FederationUpstreamMapInput ¶ added in v2.5.1
type FederationUpstreamMapInput interface { pulumi.Input ToFederationUpstreamMapOutput() FederationUpstreamMapOutput ToFederationUpstreamMapOutputWithContext(context.Context) FederationUpstreamMapOutput }
FederationUpstreamMapInput is an input type that accepts FederationUpstreamMap and FederationUpstreamMapOutput values. You can construct a concrete instance of `FederationUpstreamMapInput` via:
FederationUpstreamMap{ "key": FederationUpstreamArgs{...} }
type FederationUpstreamMapOutput ¶ added in v2.5.1
type FederationUpstreamMapOutput struct{ *pulumi.OutputState }
func (FederationUpstreamMapOutput) ElementType ¶ added in v2.5.1
func (FederationUpstreamMapOutput) ElementType() reflect.Type
func (FederationUpstreamMapOutput) MapIndex ¶ added in v2.5.1
func (o FederationUpstreamMapOutput) MapIndex(k pulumi.StringInput) FederationUpstreamOutput
func (FederationUpstreamMapOutput) ToFederationUpstreamMapOutput ¶ added in v2.5.1
func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutput() FederationUpstreamMapOutput
func (FederationUpstreamMapOutput) ToFederationUpstreamMapOutputWithContext ¶ added in v2.5.1
func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutputWithContext(ctx context.Context) FederationUpstreamMapOutput
type FederationUpstreamOutput ¶ added in v2.4.1
type FederationUpstreamOutput struct {
*pulumi.OutputState
}
func (FederationUpstreamOutput) ElementType ¶ added in v2.4.1
func (FederationUpstreamOutput) ElementType() reflect.Type
func (FederationUpstreamOutput) ToFederationUpstreamOutput ¶ added in v2.4.1
func (o FederationUpstreamOutput) ToFederationUpstreamOutput() FederationUpstreamOutput
func (FederationUpstreamOutput) ToFederationUpstreamOutputWithContext ¶ added in v2.4.1
func (o FederationUpstreamOutput) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput
func (FederationUpstreamOutput) ToFederationUpstreamPtrOutput ¶ added in v2.5.1
func (o FederationUpstreamOutput) ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput
func (FederationUpstreamOutput) ToFederationUpstreamPtrOutputWithContext ¶ added in v2.5.1
func (o FederationUpstreamOutput) ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput
type FederationUpstreamPtrInput ¶ added in v2.5.1
type FederationUpstreamPtrInput interface { pulumi.Input ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput }
type FederationUpstreamPtrOutput ¶ added in v2.5.1
type FederationUpstreamPtrOutput struct {
*pulumi.OutputState
}
func (FederationUpstreamPtrOutput) ElementType ¶ added in v2.5.1
func (FederationUpstreamPtrOutput) ElementType() reflect.Type
func (FederationUpstreamPtrOutput) ToFederationUpstreamPtrOutput ¶ added in v2.5.1
func (o FederationUpstreamPtrOutput) ToFederationUpstreamPtrOutput() FederationUpstreamPtrOutput
func (FederationUpstreamPtrOutput) ToFederationUpstreamPtrOutputWithContext ¶ added in v2.5.1
func (o FederationUpstreamPtrOutput) ToFederationUpstreamPtrOutputWithContext(ctx context.Context) FederationUpstreamPtrOutput
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 }) }
```
## Import
Permissions can be imported using the `id` which is composed of ¶
`user@vhost`. E.g.
```sh
$ pulumi import rabbitmq:index/permissions:Permissions test user@vhost
```
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.
func (*Permissions) ElementType ¶ added in v2.4.1
func (*Permissions) ElementType() reflect.Type
func (*Permissions) ToPermissionsOutput ¶ added in v2.4.1
func (i *Permissions) ToPermissionsOutput() PermissionsOutput
func (*Permissions) ToPermissionsOutputWithContext ¶ added in v2.4.1
func (i *Permissions) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput
func (*Permissions) ToPermissionsPtrOutput ¶ added in v2.5.1
func (i *Permissions) ToPermissionsPtrOutput() PermissionsPtrOutput
func (*Permissions) ToPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (i *Permissions) ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput
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 PermissionsArray ¶ added in v2.5.1
type PermissionsArray []PermissionsInput
func (PermissionsArray) ElementType ¶ added in v2.5.1
func (PermissionsArray) ElementType() reflect.Type
func (PermissionsArray) ToPermissionsArrayOutput ¶ added in v2.5.1
func (i PermissionsArray) ToPermissionsArrayOutput() PermissionsArrayOutput
func (PermissionsArray) ToPermissionsArrayOutputWithContext ¶ added in v2.5.1
func (i PermissionsArray) ToPermissionsArrayOutputWithContext(ctx context.Context) PermissionsArrayOutput
type PermissionsArrayInput ¶ added in v2.5.1
type PermissionsArrayInput interface { pulumi.Input ToPermissionsArrayOutput() PermissionsArrayOutput ToPermissionsArrayOutputWithContext(context.Context) PermissionsArrayOutput }
PermissionsArrayInput is an input type that accepts PermissionsArray and PermissionsArrayOutput values. You can construct a concrete instance of `PermissionsArrayInput` via:
PermissionsArray{ PermissionsArgs{...} }
type PermissionsArrayOutput ¶ added in v2.5.1
type PermissionsArrayOutput struct{ *pulumi.OutputState }
func (PermissionsArrayOutput) ElementType ¶ added in v2.5.1
func (PermissionsArrayOutput) ElementType() reflect.Type
func (PermissionsArrayOutput) Index ¶ added in v2.5.1
func (o PermissionsArrayOutput) Index(i pulumi.IntInput) PermissionsOutput
func (PermissionsArrayOutput) ToPermissionsArrayOutput ¶ added in v2.5.1
func (o PermissionsArrayOutput) ToPermissionsArrayOutput() PermissionsArrayOutput
func (PermissionsArrayOutput) ToPermissionsArrayOutputWithContext ¶ added in v2.5.1
func (o PermissionsArrayOutput) ToPermissionsArrayOutputWithContext(ctx context.Context) PermissionsArrayOutput
type PermissionsInput ¶ added in v2.4.1
type PermissionsInput interface { pulumi.Input ToPermissionsOutput() PermissionsOutput ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput }
type PermissionsMap ¶ added in v2.5.1
type PermissionsMap map[string]PermissionsInput
func (PermissionsMap) ElementType ¶ added in v2.5.1
func (PermissionsMap) ElementType() reflect.Type
func (PermissionsMap) ToPermissionsMapOutput ¶ added in v2.5.1
func (i PermissionsMap) ToPermissionsMapOutput() PermissionsMapOutput
func (PermissionsMap) ToPermissionsMapOutputWithContext ¶ added in v2.5.1
func (i PermissionsMap) ToPermissionsMapOutputWithContext(ctx context.Context) PermissionsMapOutput
type PermissionsMapInput ¶ added in v2.5.1
type PermissionsMapInput interface { pulumi.Input ToPermissionsMapOutput() PermissionsMapOutput ToPermissionsMapOutputWithContext(context.Context) PermissionsMapOutput }
PermissionsMapInput is an input type that accepts PermissionsMap and PermissionsMapOutput values. You can construct a concrete instance of `PermissionsMapInput` via:
PermissionsMap{ "key": PermissionsArgs{...} }
type PermissionsMapOutput ¶ added in v2.5.1
type PermissionsMapOutput struct{ *pulumi.OutputState }
func (PermissionsMapOutput) ElementType ¶ added in v2.5.1
func (PermissionsMapOutput) ElementType() reflect.Type
func (PermissionsMapOutput) MapIndex ¶ added in v2.5.1
func (o PermissionsMapOutput) MapIndex(k pulumi.StringInput) PermissionsOutput
func (PermissionsMapOutput) ToPermissionsMapOutput ¶ added in v2.5.1
func (o PermissionsMapOutput) ToPermissionsMapOutput() PermissionsMapOutput
func (PermissionsMapOutput) ToPermissionsMapOutputWithContext ¶ added in v2.5.1
func (o PermissionsMapOutput) ToPermissionsMapOutputWithContext(ctx context.Context) PermissionsMapOutput
type PermissionsOutput ¶ added in v2.4.1
type PermissionsOutput struct {
*pulumi.OutputState
}
func (PermissionsOutput) ElementType ¶ added in v2.4.1
func (PermissionsOutput) ElementType() reflect.Type
func (PermissionsOutput) ToPermissionsOutput ¶ added in v2.4.1
func (o PermissionsOutput) ToPermissionsOutput() PermissionsOutput
func (PermissionsOutput) ToPermissionsOutputWithContext ¶ added in v2.4.1
func (o PermissionsOutput) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput
func (PermissionsOutput) ToPermissionsPtrOutput ¶ added in v2.5.1
func (o PermissionsOutput) ToPermissionsPtrOutput() PermissionsPtrOutput
func (PermissionsOutput) ToPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (o PermissionsOutput) ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput
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 PermissionsPtrInput ¶ added in v2.5.1
type PermissionsPtrInput interface { pulumi.Input ToPermissionsPtrOutput() PermissionsPtrOutput ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput }
type PermissionsPtrOutput ¶ added in v2.5.1
type PermissionsPtrOutput struct {
*pulumi.OutputState
}
func (PermissionsPtrOutput) ElementType ¶ added in v2.5.1
func (PermissionsPtrOutput) ElementType() reflect.Type
func (PermissionsPtrOutput) ToPermissionsPtrOutput ¶ added in v2.5.1
func (o PermissionsPtrOutput) ToPermissionsPtrOutput() PermissionsPtrOutput
func (PermissionsPtrOutput) ToPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (o PermissionsPtrOutput) ToPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPtrOutput
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 }) }
```
## Import
Policies can be imported using the `id` which is composed of `name@vhost`. E.g.
```sh
$ pulumi import rabbitmq:index/policy:Policy test name@vhost
```
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.
func (*Policy) ElementType ¶ added in v2.4.1
func (*Policy) ToPolicyOutput ¶ added in v2.4.1
func (i *Policy) ToPolicyOutput() PolicyOutput
func (*Policy) ToPolicyOutputWithContext ¶ added in v2.4.1
func (i *Policy) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput
func (*Policy) ToPolicyPtrOutput ¶ added in v2.5.1
func (i *Policy) ToPolicyPtrOutput() PolicyPtrOutput
func (*Policy) ToPolicyPtrOutputWithContext ¶ added in v2.5.1
func (i *Policy) ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput
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 PolicyArray ¶ added in v2.5.1
type PolicyArray []PolicyInput
func (PolicyArray) ElementType ¶ added in v2.5.1
func (PolicyArray) ElementType() reflect.Type
func (PolicyArray) ToPolicyArrayOutput ¶ added in v2.5.1
func (i PolicyArray) ToPolicyArrayOutput() PolicyArrayOutput
func (PolicyArray) ToPolicyArrayOutputWithContext ¶ added in v2.5.1
func (i PolicyArray) ToPolicyArrayOutputWithContext(ctx context.Context) PolicyArrayOutput
type PolicyArrayInput ¶ added in v2.5.1
type PolicyArrayInput interface { pulumi.Input ToPolicyArrayOutput() PolicyArrayOutput ToPolicyArrayOutputWithContext(context.Context) PolicyArrayOutput }
PolicyArrayInput is an input type that accepts PolicyArray and PolicyArrayOutput values. You can construct a concrete instance of `PolicyArrayInput` via:
PolicyArray{ PolicyArgs{...} }
type PolicyArrayOutput ¶ added in v2.5.1
type PolicyArrayOutput struct{ *pulumi.OutputState }
func (PolicyArrayOutput) ElementType ¶ added in v2.5.1
func (PolicyArrayOutput) ElementType() reflect.Type
func (PolicyArrayOutput) Index ¶ added in v2.5.1
func (o PolicyArrayOutput) Index(i pulumi.IntInput) PolicyOutput
func (PolicyArrayOutput) ToPolicyArrayOutput ¶ added in v2.5.1
func (o PolicyArrayOutput) ToPolicyArrayOutput() PolicyArrayOutput
func (PolicyArrayOutput) ToPolicyArrayOutputWithContext ¶ added in v2.5.1
func (o PolicyArrayOutput) ToPolicyArrayOutputWithContext(ctx context.Context) PolicyArrayOutput
type PolicyInput ¶ added in v2.4.1
type PolicyInput interface { pulumi.Input ToPolicyOutput() PolicyOutput ToPolicyOutputWithContext(ctx context.Context) PolicyOutput }
type PolicyMap ¶ added in v2.5.1
type PolicyMap map[string]PolicyInput
func (PolicyMap) ElementType ¶ added in v2.5.1
func (PolicyMap) ToPolicyMapOutput ¶ added in v2.5.1
func (i PolicyMap) ToPolicyMapOutput() PolicyMapOutput
func (PolicyMap) ToPolicyMapOutputWithContext ¶ added in v2.5.1
func (i PolicyMap) ToPolicyMapOutputWithContext(ctx context.Context) PolicyMapOutput
type PolicyMapInput ¶ added in v2.5.1
type PolicyMapInput interface { pulumi.Input ToPolicyMapOutput() PolicyMapOutput ToPolicyMapOutputWithContext(context.Context) PolicyMapOutput }
PolicyMapInput is an input type that accepts PolicyMap and PolicyMapOutput values. You can construct a concrete instance of `PolicyMapInput` via:
PolicyMap{ "key": PolicyArgs{...} }
type PolicyMapOutput ¶ added in v2.5.1
type PolicyMapOutput struct{ *pulumi.OutputState }
func (PolicyMapOutput) ElementType ¶ added in v2.5.1
func (PolicyMapOutput) ElementType() reflect.Type
func (PolicyMapOutput) MapIndex ¶ added in v2.5.1
func (o PolicyMapOutput) MapIndex(k pulumi.StringInput) PolicyOutput
func (PolicyMapOutput) ToPolicyMapOutput ¶ added in v2.5.1
func (o PolicyMapOutput) ToPolicyMapOutput() PolicyMapOutput
func (PolicyMapOutput) ToPolicyMapOutputWithContext ¶ added in v2.5.1
func (o PolicyMapOutput) ToPolicyMapOutputWithContext(ctx context.Context) PolicyMapOutput
type PolicyOutput ¶ added in v2.4.1
type PolicyOutput struct {
*pulumi.OutputState
}
func (PolicyOutput) ElementType ¶ added in v2.4.1
func (PolicyOutput) ElementType() reflect.Type
func (PolicyOutput) ToPolicyOutput ¶ added in v2.4.1
func (o PolicyOutput) ToPolicyOutput() PolicyOutput
func (PolicyOutput) ToPolicyOutputWithContext ¶ added in v2.4.1
func (o PolicyOutput) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput
func (PolicyOutput) ToPolicyPtrOutput ¶ added in v2.5.1
func (o PolicyOutput) ToPolicyPtrOutput() PolicyPtrOutput
func (PolicyOutput) ToPolicyPtrOutputWithContext ¶ added in v2.5.1
func (o PolicyOutput) ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput
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 PolicyPtrInput ¶ added in v2.5.1
type PolicyPtrInput interface { pulumi.Input ToPolicyPtrOutput() PolicyPtrOutput ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput }
type PolicyPtrOutput ¶ added in v2.5.1
type PolicyPtrOutput struct {
*pulumi.OutputState
}
func (PolicyPtrOutput) ElementType ¶ added in v2.5.1
func (PolicyPtrOutput) ElementType() reflect.Type
func (PolicyPtrOutput) ToPolicyPtrOutput ¶ added in v2.5.1
func (o PolicyPtrOutput) ToPolicyPtrOutput() PolicyPtrOutput
func (PolicyPtrOutput) ToPolicyPtrOutputWithContext ¶ added in v2.5.1
func (o PolicyPtrOutput) ToPolicyPtrOutputWithContext(ctx context.Context) PolicyPtrOutput
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.
func (*Provider) ElementType ¶ added in v2.4.1
func (*Provider) ToProviderOutput ¶ added in v2.4.1
func (i *Provider) ToProviderOutput() ProviderOutput
func (*Provider) ToProviderOutputWithContext ¶ added in v2.4.1
func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
func (*Provider) ToProviderPtrOutput ¶ added in v2.5.1
func (i *Provider) ToProviderPtrOutput() ProviderPtrOutput
func (*Provider) ToProviderPtrOutputWithContext ¶ added in v2.5.1
func (i *Provider) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
type ProviderArgs ¶
type ProviderArgs struct { CacertFile pulumi.StringPtrInput ClientcertFile pulumi.StringPtrInput ClientkeyFile pulumi.StringPtrInput Endpoint pulumi.StringInput Insecure pulumi.BoolPtrInput Password pulumi.StringInput Username pulumi.StringInput }
The set of arguments for constructing a Provider resource.
func (ProviderArgs) ElementType ¶
func (ProviderArgs) ElementType() reflect.Type
type ProviderInput ¶ added in v2.4.1
type ProviderInput interface { pulumi.Input ToProviderOutput() ProviderOutput ToProviderOutputWithContext(ctx context.Context) ProviderOutput }
type ProviderOutput ¶ added in v2.4.1
type ProviderOutput struct {
*pulumi.OutputState
}
func (ProviderOutput) ElementType ¶ added in v2.4.1
func (ProviderOutput) ElementType() reflect.Type
func (ProviderOutput) ToProviderOutput ¶ added in v2.4.1
func (o ProviderOutput) ToProviderOutput() ProviderOutput
func (ProviderOutput) ToProviderOutputWithContext ¶ added in v2.4.1
func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput
func (ProviderOutput) ToProviderPtrOutput ¶ added in v2.5.1
func (o ProviderOutput) ToProviderPtrOutput() ProviderPtrOutput
func (ProviderOutput) ToProviderPtrOutputWithContext ¶ added in v2.5.1
func (o ProviderOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
type ProviderPtrInput ¶ added in v2.5.1
type ProviderPtrInput interface { pulumi.Input ToProviderPtrOutput() ProviderPtrOutput ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput }
type ProviderPtrOutput ¶ added in v2.5.1
type ProviderPtrOutput struct {
*pulumi.OutputState
}
func (ProviderPtrOutput) ElementType ¶ added in v2.5.1
func (ProviderPtrOutput) ElementType() reflect.Type
func (ProviderPtrOutput) ToProviderPtrOutput ¶ added in v2.5.1
func (o ProviderPtrOutput) ToProviderPtrOutput() ProviderPtrOutput
func (ProviderPtrOutput) ToProviderPtrOutputWithContext ¶ added in v2.5.1
func (o ProviderPtrOutput) ToProviderPtrOutputWithContext(ctx context.Context) ProviderPtrOutput
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 }) }
```
## Import
Queues can be imported using the `id` which is composed of `name@vhost`. E.g.
```sh
$ pulumi import rabbitmq:index/queue:Queue test name@vhost
```
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).
func NewQueue ¶
func NewQueue(ctx *pulumi.Context, name string, args *QueueArgs, opts ...pulumi.ResourceOption) (*Queue, error)
NewQueue registers a new resource with the given unique name, arguments, and options.
func (*Queue) ElementType ¶ added in v2.4.1
func (*Queue) ToQueueOutput ¶ added in v2.4.1
func (i *Queue) ToQueueOutput() QueueOutput
func (*Queue) ToQueueOutputWithContext ¶ added in v2.4.1
func (i *Queue) ToQueueOutputWithContext(ctx context.Context) QueueOutput
func (*Queue) ToQueuePtrOutput ¶ added in v2.5.1
func (i *Queue) ToQueuePtrOutput() QueuePtrOutput
func (*Queue) ToQueuePtrOutputWithContext ¶ added in v2.5.1
func (i *Queue) ToQueuePtrOutputWithContext(ctx context.Context) QueuePtrOutput
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 QueueArray ¶ added in v2.5.1
type QueueArray []QueueInput
func (QueueArray) ElementType ¶ added in v2.5.1
func (QueueArray) ElementType() reflect.Type
func (QueueArray) ToQueueArrayOutput ¶ added in v2.5.1
func (i QueueArray) ToQueueArrayOutput() QueueArrayOutput
func (QueueArray) ToQueueArrayOutputWithContext ¶ added in v2.5.1
func (i QueueArray) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput
type QueueArrayInput ¶ added in v2.5.1
type QueueArrayInput interface { pulumi.Input ToQueueArrayOutput() QueueArrayOutput ToQueueArrayOutputWithContext(context.Context) QueueArrayOutput }
QueueArrayInput is an input type that accepts QueueArray and QueueArrayOutput values. You can construct a concrete instance of `QueueArrayInput` via:
QueueArray{ QueueArgs{...} }
type QueueArrayOutput ¶ added in v2.5.1
type QueueArrayOutput struct{ *pulumi.OutputState }
func (QueueArrayOutput) ElementType ¶ added in v2.5.1
func (QueueArrayOutput) ElementType() reflect.Type
func (QueueArrayOutput) Index ¶ added in v2.5.1
func (o QueueArrayOutput) Index(i pulumi.IntInput) QueueOutput
func (QueueArrayOutput) ToQueueArrayOutput ¶ added in v2.5.1
func (o QueueArrayOutput) ToQueueArrayOutput() QueueArrayOutput
func (QueueArrayOutput) ToQueueArrayOutputWithContext ¶ added in v2.5.1
func (o QueueArrayOutput) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput
type QueueInput ¶ added in v2.4.1
type QueueInput interface { pulumi.Input ToQueueOutput() QueueOutput ToQueueOutputWithContext(ctx context.Context) QueueOutput }
type QueueMap ¶ added in v2.5.1
type QueueMap map[string]QueueInput
func (QueueMap) ElementType ¶ added in v2.5.1
func (QueueMap) ToQueueMapOutput ¶ added in v2.5.1
func (i QueueMap) ToQueueMapOutput() QueueMapOutput
func (QueueMap) ToQueueMapOutputWithContext ¶ added in v2.5.1
func (i QueueMap) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput
type QueueMapInput ¶ added in v2.5.1
type QueueMapInput interface { pulumi.Input ToQueueMapOutput() QueueMapOutput ToQueueMapOutputWithContext(context.Context) QueueMapOutput }
QueueMapInput is an input type that accepts QueueMap and QueueMapOutput values. You can construct a concrete instance of `QueueMapInput` via:
QueueMap{ "key": QueueArgs{...} }
type QueueMapOutput ¶ added in v2.5.1
type QueueMapOutput struct{ *pulumi.OutputState }
func (QueueMapOutput) ElementType ¶ added in v2.5.1
func (QueueMapOutput) ElementType() reflect.Type
func (QueueMapOutput) MapIndex ¶ added in v2.5.1
func (o QueueMapOutput) MapIndex(k pulumi.StringInput) QueueOutput
func (QueueMapOutput) ToQueueMapOutput ¶ added in v2.5.1
func (o QueueMapOutput) ToQueueMapOutput() QueueMapOutput
func (QueueMapOutput) ToQueueMapOutputWithContext ¶ added in v2.5.1
func (o QueueMapOutput) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput
type QueueOutput ¶ added in v2.4.1
type QueueOutput struct {
*pulumi.OutputState
}
func (QueueOutput) ElementType ¶ added in v2.4.1
func (QueueOutput) ElementType() reflect.Type
func (QueueOutput) ToQueueOutput ¶ added in v2.4.1
func (o QueueOutput) ToQueueOutput() QueueOutput
func (QueueOutput) ToQueueOutputWithContext ¶ added in v2.4.1
func (o QueueOutput) ToQueueOutputWithContext(ctx context.Context) QueueOutput
func (QueueOutput) ToQueuePtrOutput ¶ added in v2.5.1
func (o QueueOutput) ToQueuePtrOutput() QueuePtrOutput
func (QueueOutput) ToQueuePtrOutputWithContext ¶ added in v2.5.1
func (o QueueOutput) ToQueuePtrOutputWithContext(ctx context.Context) QueuePtrOutput
type QueuePtrInput ¶ added in v2.5.1
type QueuePtrInput interface { pulumi.Input ToQueuePtrOutput() QueuePtrOutput ToQueuePtrOutputWithContext(ctx context.Context) QueuePtrOutput }
type QueuePtrOutput ¶ added in v2.5.1
type QueuePtrOutput struct {
*pulumi.OutputState
}
func (QueuePtrOutput) ElementType ¶ added in v2.5.1
func (QueuePtrOutput) ElementType() reflect.Type
func (QueuePtrOutput) ToQueuePtrOutput ¶ added in v2.5.1
func (o QueuePtrOutput) ToQueuePtrOutput() QueuePtrOutput
func (QueuePtrOutput) ToQueuePtrOutputWithContext ¶ added in v2.5.1
func (o QueuePtrOutput) ToQueuePtrOutputWithContext(ctx context.Context) QueuePtrOutput
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 }) }
```
## Import
Shovels can be imported using the `name` and `vhost` E.g.
```sh
$ pulumi import rabbitmq:index/shovel:Shovel test shovelTest@test
```
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.
func (*Shovel) ElementType ¶ added in v2.4.1
func (*Shovel) ToShovelOutput ¶ added in v2.4.1
func (i *Shovel) ToShovelOutput() ShovelOutput
func (*Shovel) ToShovelOutputWithContext ¶ added in v2.4.1
func (i *Shovel) ToShovelOutputWithContext(ctx context.Context) ShovelOutput
func (*Shovel) ToShovelPtrOutput ¶ added in v2.5.1
func (i *Shovel) ToShovelPtrOutput() ShovelPtrOutput
func (*Shovel) ToShovelPtrOutputWithContext ¶ added in v2.5.1
func (i *Shovel) ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput
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 ShovelArray ¶ added in v2.5.1
type ShovelArray []ShovelInput
func (ShovelArray) ElementType ¶ added in v2.5.1
func (ShovelArray) ElementType() reflect.Type
func (ShovelArray) ToShovelArrayOutput ¶ added in v2.5.1
func (i ShovelArray) ToShovelArrayOutput() ShovelArrayOutput
func (ShovelArray) ToShovelArrayOutputWithContext ¶ added in v2.5.1
func (i ShovelArray) ToShovelArrayOutputWithContext(ctx context.Context) ShovelArrayOutput
type ShovelArrayInput ¶ added in v2.5.1
type ShovelArrayInput interface { pulumi.Input ToShovelArrayOutput() ShovelArrayOutput ToShovelArrayOutputWithContext(context.Context) ShovelArrayOutput }
ShovelArrayInput is an input type that accepts ShovelArray and ShovelArrayOutput values. You can construct a concrete instance of `ShovelArrayInput` via:
ShovelArray{ ShovelArgs{...} }
type ShovelArrayOutput ¶ added in v2.5.1
type ShovelArrayOutput struct{ *pulumi.OutputState }
func (ShovelArrayOutput) ElementType ¶ added in v2.5.1
func (ShovelArrayOutput) ElementType() reflect.Type
func (ShovelArrayOutput) Index ¶ added in v2.5.1
func (o ShovelArrayOutput) Index(i pulumi.IntInput) ShovelOutput
func (ShovelArrayOutput) ToShovelArrayOutput ¶ added in v2.5.1
func (o ShovelArrayOutput) ToShovelArrayOutput() ShovelArrayOutput
func (ShovelArrayOutput) ToShovelArrayOutputWithContext ¶ added in v2.5.1
func (o ShovelArrayOutput) ToShovelArrayOutputWithContext(ctx context.Context) ShovelArrayOutput
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 ShovelInput ¶ added in v2.4.1
type ShovelInput interface { pulumi.Input ToShovelOutput() ShovelOutput ToShovelOutputWithContext(ctx context.Context) ShovelOutput }
type ShovelMap ¶ added in v2.5.1
type ShovelMap map[string]ShovelInput
func (ShovelMap) ElementType ¶ added in v2.5.1
func (ShovelMap) ToShovelMapOutput ¶ added in v2.5.1
func (i ShovelMap) ToShovelMapOutput() ShovelMapOutput
func (ShovelMap) ToShovelMapOutputWithContext ¶ added in v2.5.1
func (i ShovelMap) ToShovelMapOutputWithContext(ctx context.Context) ShovelMapOutput
type ShovelMapInput ¶ added in v2.5.1
type ShovelMapInput interface { pulumi.Input ToShovelMapOutput() ShovelMapOutput ToShovelMapOutputWithContext(context.Context) ShovelMapOutput }
ShovelMapInput is an input type that accepts ShovelMap and ShovelMapOutput values. You can construct a concrete instance of `ShovelMapInput` via:
ShovelMap{ "key": ShovelArgs{...} }
type ShovelMapOutput ¶ added in v2.5.1
type ShovelMapOutput struct{ *pulumi.OutputState }
func (ShovelMapOutput) ElementType ¶ added in v2.5.1
func (ShovelMapOutput) ElementType() reflect.Type
func (ShovelMapOutput) MapIndex ¶ added in v2.5.1
func (o ShovelMapOutput) MapIndex(k pulumi.StringInput) ShovelOutput
func (ShovelMapOutput) ToShovelMapOutput ¶ added in v2.5.1
func (o ShovelMapOutput) ToShovelMapOutput() ShovelMapOutput
func (ShovelMapOutput) ToShovelMapOutputWithContext ¶ added in v2.5.1
func (o ShovelMapOutput) ToShovelMapOutputWithContext(ctx context.Context) ShovelMapOutput
type ShovelOutput ¶ added in v2.4.1
type ShovelOutput struct {
*pulumi.OutputState
}
func (ShovelOutput) ElementType ¶ added in v2.4.1
func (ShovelOutput) ElementType() reflect.Type
func (ShovelOutput) ToShovelOutput ¶ added in v2.4.1
func (o ShovelOutput) ToShovelOutput() ShovelOutput
func (ShovelOutput) ToShovelOutputWithContext ¶ added in v2.4.1
func (o ShovelOutput) ToShovelOutputWithContext(ctx context.Context) ShovelOutput
func (ShovelOutput) ToShovelPtrOutput ¶ added in v2.5.1
func (o ShovelOutput) ToShovelPtrOutput() ShovelPtrOutput
func (ShovelOutput) ToShovelPtrOutputWithContext ¶ added in v2.5.1
func (o ShovelOutput) ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput
type ShovelPtrInput ¶ added in v2.5.1
type ShovelPtrInput interface { pulumi.Input ToShovelPtrOutput() ShovelPtrOutput ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput }
type ShovelPtrOutput ¶ added in v2.5.1
type ShovelPtrOutput struct {
*pulumi.OutputState
}
func (ShovelPtrOutput) ElementType ¶ added in v2.5.1
func (ShovelPtrOutput) ElementType() reflect.Type
func (ShovelPtrOutput) ToShovelPtrOutput ¶ added in v2.5.1
func (o ShovelPtrOutput) ToShovelPtrOutput() ShovelPtrOutput
func (ShovelPtrOutput) ToShovelPtrOutputWithContext ¶ added in v2.5.1
func (o ShovelPtrOutput) ToShovelPtrOutputWithContext(ctx context.Context) ShovelPtrOutput
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 }) }
```
## Import
Permissions can be imported using the `id` which is composed of ¶
`user@vhost`. E.g.
```sh
$ pulumi import rabbitmq:index/topicPermissions:TopicPermissions test user@vhost
```
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.
func (*TopicPermissions) ElementType ¶ added in v2.4.1
func (*TopicPermissions) ElementType() reflect.Type
func (*TopicPermissions) ToTopicPermissionsOutput ¶ added in v2.4.1
func (i *TopicPermissions) ToTopicPermissionsOutput() TopicPermissionsOutput
func (*TopicPermissions) ToTopicPermissionsOutputWithContext ¶ added in v2.4.1
func (i *TopicPermissions) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput
func (*TopicPermissions) ToTopicPermissionsPtrOutput ¶ added in v2.5.1
func (i *TopicPermissions) ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput
func (*TopicPermissions) ToTopicPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (i *TopicPermissions) ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput
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 TopicPermissionsArray ¶ added in v2.5.1
type TopicPermissionsArray []TopicPermissionsInput
func (TopicPermissionsArray) ElementType ¶ added in v2.5.1
func (TopicPermissionsArray) ElementType() reflect.Type
func (TopicPermissionsArray) ToTopicPermissionsArrayOutput ¶ added in v2.5.1
func (i TopicPermissionsArray) ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput
func (TopicPermissionsArray) ToTopicPermissionsArrayOutputWithContext ¶ added in v2.5.1
func (i TopicPermissionsArray) ToTopicPermissionsArrayOutputWithContext(ctx context.Context) TopicPermissionsArrayOutput
type TopicPermissionsArrayInput ¶ added in v2.5.1
type TopicPermissionsArrayInput interface { pulumi.Input ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput ToTopicPermissionsArrayOutputWithContext(context.Context) TopicPermissionsArrayOutput }
TopicPermissionsArrayInput is an input type that accepts TopicPermissionsArray and TopicPermissionsArrayOutput values. You can construct a concrete instance of `TopicPermissionsArrayInput` via:
TopicPermissionsArray{ TopicPermissionsArgs{...} }
type TopicPermissionsArrayOutput ¶ added in v2.5.1
type TopicPermissionsArrayOutput struct{ *pulumi.OutputState }
func (TopicPermissionsArrayOutput) ElementType ¶ added in v2.5.1
func (TopicPermissionsArrayOutput) ElementType() reflect.Type
func (TopicPermissionsArrayOutput) Index ¶ added in v2.5.1
func (o TopicPermissionsArrayOutput) Index(i pulumi.IntInput) TopicPermissionsOutput
func (TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutput ¶ added in v2.5.1
func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput
func (TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutputWithContext ¶ added in v2.5.1
func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutputWithContext(ctx context.Context) TopicPermissionsArrayOutput
type TopicPermissionsInput ¶ added in v2.4.1
type TopicPermissionsInput interface { pulumi.Input ToTopicPermissionsOutput() TopicPermissionsOutput ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput }
type TopicPermissionsMap ¶ added in v2.5.1
type TopicPermissionsMap map[string]TopicPermissionsInput
func (TopicPermissionsMap) ElementType ¶ added in v2.5.1
func (TopicPermissionsMap) ElementType() reflect.Type
func (TopicPermissionsMap) ToTopicPermissionsMapOutput ¶ added in v2.5.1
func (i TopicPermissionsMap) ToTopicPermissionsMapOutput() TopicPermissionsMapOutput
func (TopicPermissionsMap) ToTopicPermissionsMapOutputWithContext ¶ added in v2.5.1
func (i TopicPermissionsMap) ToTopicPermissionsMapOutputWithContext(ctx context.Context) TopicPermissionsMapOutput
type TopicPermissionsMapInput ¶ added in v2.5.1
type TopicPermissionsMapInput interface { pulumi.Input ToTopicPermissionsMapOutput() TopicPermissionsMapOutput ToTopicPermissionsMapOutputWithContext(context.Context) TopicPermissionsMapOutput }
TopicPermissionsMapInput is an input type that accepts TopicPermissionsMap and TopicPermissionsMapOutput values. You can construct a concrete instance of `TopicPermissionsMapInput` via:
TopicPermissionsMap{ "key": TopicPermissionsArgs{...} }
type TopicPermissionsMapOutput ¶ added in v2.5.1
type TopicPermissionsMapOutput struct{ *pulumi.OutputState }
func (TopicPermissionsMapOutput) ElementType ¶ added in v2.5.1
func (TopicPermissionsMapOutput) ElementType() reflect.Type
func (TopicPermissionsMapOutput) MapIndex ¶ added in v2.5.1
func (o TopicPermissionsMapOutput) MapIndex(k pulumi.StringInput) TopicPermissionsOutput
func (TopicPermissionsMapOutput) ToTopicPermissionsMapOutput ¶ added in v2.5.1
func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutput() TopicPermissionsMapOutput
func (TopicPermissionsMapOutput) ToTopicPermissionsMapOutputWithContext ¶ added in v2.5.1
func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutputWithContext(ctx context.Context) TopicPermissionsMapOutput
type TopicPermissionsOutput ¶ added in v2.4.1
type TopicPermissionsOutput struct {
*pulumi.OutputState
}
func (TopicPermissionsOutput) ElementType ¶ added in v2.4.1
func (TopicPermissionsOutput) ElementType() reflect.Type
func (TopicPermissionsOutput) ToTopicPermissionsOutput ¶ added in v2.4.1
func (o TopicPermissionsOutput) ToTopicPermissionsOutput() TopicPermissionsOutput
func (TopicPermissionsOutput) ToTopicPermissionsOutputWithContext ¶ added in v2.4.1
func (o TopicPermissionsOutput) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput
func (TopicPermissionsOutput) ToTopicPermissionsPtrOutput ¶ added in v2.5.1
func (o TopicPermissionsOutput) ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput
func (TopicPermissionsOutput) ToTopicPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (o TopicPermissionsOutput) ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput
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 TopicPermissionsPtrInput ¶ added in v2.5.1
type TopicPermissionsPtrInput interface { pulumi.Input ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput }
type TopicPermissionsPtrOutput ¶ added in v2.5.1
type TopicPermissionsPtrOutput struct {
*pulumi.OutputState
}
func (TopicPermissionsPtrOutput) ElementType ¶ added in v2.5.1
func (TopicPermissionsPtrOutput) ElementType() reflect.Type
func (TopicPermissionsPtrOutput) ToTopicPermissionsPtrOutput ¶ added in v2.5.1
func (o TopicPermissionsPtrOutput) ToTopicPermissionsPtrOutput() TopicPermissionsPtrOutput
func (TopicPermissionsPtrOutput) ToTopicPermissionsPtrOutputWithContext ¶ added in v2.5.1
func (o TopicPermissionsPtrOutput) ToTopicPermissionsPtrOutputWithContext(ctx context.Context) TopicPermissionsPtrOutput
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 }) }
```
## Import
Users can be imported using the `name`, e.g.
```sh
$ pulumi import rabbitmq:index/user:User test mctest
```
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).
func NewUser ¶
func NewUser(ctx *pulumi.Context, name string, args *UserArgs, opts ...pulumi.ResourceOption) (*User, error)
NewUser registers a new resource with the given unique name, arguments, and options.
func (*User) ElementType ¶ added in v2.4.1
func (*User) ToUserOutput ¶ added in v2.4.1
func (i *User) ToUserOutput() UserOutput
func (*User) ToUserOutputWithContext ¶ added in v2.4.1
func (i *User) ToUserOutputWithContext(ctx context.Context) UserOutput
func (*User) ToUserPtrOutput ¶ added in v2.5.1
func (i *User) ToUserPtrOutput() UserPtrOutput
func (*User) ToUserPtrOutputWithContext ¶ added in v2.5.1
func (i *User) ToUserPtrOutputWithContext(ctx context.Context) UserPtrOutput
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 UserArray ¶ added in v2.5.1
type UserArray []UserInput
func (UserArray) ElementType ¶ added in v2.5.1
func (UserArray) ToUserArrayOutput ¶ added in v2.5.1
func (i UserArray) ToUserArrayOutput() UserArrayOutput
func (UserArray) ToUserArrayOutputWithContext ¶ added in v2.5.1
func (i UserArray) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput
type UserArrayInput ¶ added in v2.5.1
type UserArrayInput interface { pulumi.Input ToUserArrayOutput() UserArrayOutput ToUserArrayOutputWithContext(context.Context) UserArrayOutput }
UserArrayInput is an input type that accepts UserArray and UserArrayOutput values. You can construct a concrete instance of `UserArrayInput` via:
UserArray{ UserArgs{...} }
type UserArrayOutput ¶ added in v2.5.1
type UserArrayOutput struct{ *pulumi.OutputState }
func (UserArrayOutput) ElementType ¶ added in v2.5.1
func (UserArrayOutput) ElementType() reflect.Type
func (UserArrayOutput) Index ¶ added in v2.5.1
func (o UserArrayOutput) Index(i pulumi.IntInput) UserOutput
func (UserArrayOutput) ToUserArrayOutput ¶ added in v2.5.1
func (o UserArrayOutput) ToUserArrayOutput() UserArrayOutput
func (UserArrayOutput) ToUserArrayOutputWithContext ¶ added in v2.5.1
func (o UserArrayOutput) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput
type UserInput ¶ added in v2.4.1
type UserInput interface { pulumi.Input ToUserOutput() UserOutput ToUserOutputWithContext(ctx context.Context) UserOutput }
type UserMap ¶ added in v2.5.1
func (UserMap) ElementType ¶ added in v2.5.1
func (UserMap) ToUserMapOutput ¶ added in v2.5.1
func (i UserMap) ToUserMapOutput() UserMapOutput
func (UserMap) ToUserMapOutputWithContext ¶ added in v2.5.1
func (i UserMap) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput
type UserMapInput ¶ added in v2.5.1
type UserMapInput interface { pulumi.Input ToUserMapOutput() UserMapOutput ToUserMapOutputWithContext(context.Context) UserMapOutput }
UserMapInput is an input type that accepts UserMap and UserMapOutput values. You can construct a concrete instance of `UserMapInput` via:
UserMap{ "key": UserArgs{...} }
type UserMapOutput ¶ added in v2.5.1
type UserMapOutput struct{ *pulumi.OutputState }
func (UserMapOutput) ElementType ¶ added in v2.5.1
func (UserMapOutput) ElementType() reflect.Type
func (UserMapOutput) MapIndex ¶ added in v2.5.1
func (o UserMapOutput) MapIndex(k pulumi.StringInput) UserOutput
func (UserMapOutput) ToUserMapOutput ¶ added in v2.5.1
func (o UserMapOutput) ToUserMapOutput() UserMapOutput
func (UserMapOutput) ToUserMapOutputWithContext ¶ added in v2.5.1
func (o UserMapOutput) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput
type UserOutput ¶ added in v2.4.1
type UserOutput struct {
*pulumi.OutputState
}
func (UserOutput) ElementType ¶ added in v2.4.1
func (UserOutput) ElementType() reflect.Type
func (UserOutput) ToUserOutput ¶ added in v2.4.1
func (o UserOutput) ToUserOutput() UserOutput
func (UserOutput) ToUserOutputWithContext ¶ added in v2.4.1
func (o UserOutput) ToUserOutputWithContext(ctx context.Context) UserOutput
func (UserOutput) ToUserPtrOutput ¶ added in v2.5.1
func (o UserOutput) ToUserPtrOutput() UserPtrOutput
func (UserOutput) ToUserPtrOutputWithContext ¶ added in v2.5.1
func (o UserOutput) ToUserPtrOutputWithContext(ctx context.Context) UserPtrOutput
type UserPtrInput ¶ added in v2.5.1
type UserPtrInput interface { pulumi.Input ToUserPtrOutput() UserPtrOutput ToUserPtrOutputWithContext(ctx context.Context) UserPtrOutput }
type UserPtrOutput ¶ added in v2.5.1
type UserPtrOutput struct {
*pulumi.OutputState
}
func (UserPtrOutput) ElementType ¶ added in v2.5.1
func (UserPtrOutput) ElementType() reflect.Type
func (UserPtrOutput) ToUserPtrOutput ¶ added in v2.5.1
func (o UserPtrOutput) ToUserPtrOutput() UserPtrOutput
func (UserPtrOutput) ToUserPtrOutputWithContext ¶ added in v2.5.1
func (o UserPtrOutput) ToUserPtrOutputWithContext(ctx context.Context) UserPtrOutput
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 }) }
```
## Import
Vhosts can be imported using the `name`, e.g.
```sh
$ pulumi import rabbitmq:index/vHost:VHost my_vhost my_vhost
```
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).
func NewVHost ¶
func NewVHost(ctx *pulumi.Context, name string, args *VHostArgs, opts ...pulumi.ResourceOption) (*VHost, error)
NewVHost registers a new resource with the given unique name, arguments, and options.
func (*VHost) ElementType ¶ added in v2.4.1
func (*VHost) ToVHostOutput ¶ added in v2.4.1
func (i *VHost) ToVHostOutput() VHostOutput
func (*VHost) ToVHostOutputWithContext ¶ added in v2.4.1
func (i *VHost) ToVHostOutputWithContext(ctx context.Context) VHostOutput
func (*VHost) ToVHostPtrOutput ¶ added in v2.5.1
func (i *VHost) ToVHostPtrOutput() VHostPtrOutput
func (*VHost) ToVHostPtrOutputWithContext ¶ added in v2.5.1
func (i *VHost) ToVHostPtrOutputWithContext(ctx context.Context) VHostPtrOutput
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 VHostArray ¶ added in v2.5.1
type VHostArray []VHostInput
func (VHostArray) ElementType ¶ added in v2.5.1
func (VHostArray) ElementType() reflect.Type
func (VHostArray) ToVHostArrayOutput ¶ added in v2.5.1
func (i VHostArray) ToVHostArrayOutput() VHostArrayOutput
func (VHostArray) ToVHostArrayOutputWithContext ¶ added in v2.5.1
func (i VHostArray) ToVHostArrayOutputWithContext(ctx context.Context) VHostArrayOutput
type VHostArrayInput ¶ added in v2.5.1
type VHostArrayInput interface { pulumi.Input ToVHostArrayOutput() VHostArrayOutput ToVHostArrayOutputWithContext(context.Context) VHostArrayOutput }
VHostArrayInput is an input type that accepts VHostArray and VHostArrayOutput values. You can construct a concrete instance of `VHostArrayInput` via:
VHostArray{ VHostArgs{...} }
type VHostArrayOutput ¶ added in v2.5.1
type VHostArrayOutput struct{ *pulumi.OutputState }
func (VHostArrayOutput) ElementType ¶ added in v2.5.1
func (VHostArrayOutput) ElementType() reflect.Type
func (VHostArrayOutput) Index ¶ added in v2.5.1
func (o VHostArrayOutput) Index(i pulumi.IntInput) VHostOutput
func (VHostArrayOutput) ToVHostArrayOutput ¶ added in v2.5.1
func (o VHostArrayOutput) ToVHostArrayOutput() VHostArrayOutput
func (VHostArrayOutput) ToVHostArrayOutputWithContext ¶ added in v2.5.1
func (o VHostArrayOutput) ToVHostArrayOutputWithContext(ctx context.Context) VHostArrayOutput
type VHostInput ¶ added in v2.4.1
type VHostInput interface { pulumi.Input ToVHostOutput() VHostOutput ToVHostOutputWithContext(ctx context.Context) VHostOutput }
type VHostMap ¶ added in v2.5.1
type VHostMap map[string]VHostInput
func (VHostMap) ElementType ¶ added in v2.5.1
func (VHostMap) ToVHostMapOutput ¶ added in v2.5.1
func (i VHostMap) ToVHostMapOutput() VHostMapOutput
func (VHostMap) ToVHostMapOutputWithContext ¶ added in v2.5.1
func (i VHostMap) ToVHostMapOutputWithContext(ctx context.Context) VHostMapOutput
type VHostMapInput ¶ added in v2.5.1
type VHostMapInput interface { pulumi.Input ToVHostMapOutput() VHostMapOutput ToVHostMapOutputWithContext(context.Context) VHostMapOutput }
VHostMapInput is an input type that accepts VHostMap and VHostMapOutput values. You can construct a concrete instance of `VHostMapInput` via:
VHostMap{ "key": VHostArgs{...} }
type VHostMapOutput ¶ added in v2.5.1
type VHostMapOutput struct{ *pulumi.OutputState }
func (VHostMapOutput) ElementType ¶ added in v2.5.1
func (VHostMapOutput) ElementType() reflect.Type
func (VHostMapOutput) MapIndex ¶ added in v2.5.1
func (o VHostMapOutput) MapIndex(k pulumi.StringInput) VHostOutput
func (VHostMapOutput) ToVHostMapOutput ¶ added in v2.5.1
func (o VHostMapOutput) ToVHostMapOutput() VHostMapOutput
func (VHostMapOutput) ToVHostMapOutputWithContext ¶ added in v2.5.1
func (o VHostMapOutput) ToVHostMapOutputWithContext(ctx context.Context) VHostMapOutput
type VHostOutput ¶ added in v2.4.1
type VHostOutput struct {
*pulumi.OutputState
}
func (VHostOutput) ElementType ¶ added in v2.4.1
func (VHostOutput) ElementType() reflect.Type
func (VHostOutput) ToVHostOutput ¶ added in v2.4.1
func (o VHostOutput) ToVHostOutput() VHostOutput
func (VHostOutput) ToVHostOutputWithContext ¶ added in v2.4.1
func (o VHostOutput) ToVHostOutputWithContext(ctx context.Context) VHostOutput
func (VHostOutput) ToVHostPtrOutput ¶ added in v2.5.1
func (o VHostOutput) ToVHostPtrOutput() VHostPtrOutput
func (VHostOutput) ToVHostPtrOutputWithContext ¶ added in v2.5.1
func (o VHostOutput) ToVHostPtrOutputWithContext(ctx context.Context) VHostPtrOutput
type VHostPtrInput ¶ added in v2.5.1
type VHostPtrInput interface { pulumi.Input ToVHostPtrOutput() VHostPtrOutput ToVHostPtrOutputWithContext(ctx context.Context) VHostPtrOutput }
type VHostPtrOutput ¶ added in v2.5.1
type VHostPtrOutput struct {
*pulumi.OutputState
}
func (VHostPtrOutput) ElementType ¶ added in v2.5.1
func (VHostPtrOutput) ElementType() reflect.Type
func (VHostPtrOutput) ToVHostPtrOutput ¶ added in v2.5.1
func (o VHostPtrOutput) ToVHostPtrOutput() VHostPtrOutput
func (VHostPtrOutput) ToVHostPtrOutputWithContext ¶ added in v2.5.1
func (o VHostPtrOutput) ToVHostPtrOutputWithContext(ctx context.Context) VHostPtrOutput
type VHostState ¶
type VHostState struct { // The name of the vhost. Name pulumi.StringPtrInput }
func (VHostState) ElementType ¶
func (VHostState) ElementType() reflect.Type