pulumiTypes.go

// *** WARNING: this file was generated by the Pulumi Terraform Bridge (tfgen) Tool. ***
// *** Do not edit by hand unless you're certain you know what you are doing! ***

package rabbitmq

import (
	"context"
	"reflect"

	"github.com/pulumi/pulumi/sdk/v2/go/pulumi"
)

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"`
}

// ExchangeSettingsInput is an input type that accepts ExchangeSettingsArgs and ExchangeSettingsOutput values.
// You can construct a concrete instance of `ExchangeSettingsInput` via:
//
//          ExchangeSettingsArgs{...}
type ExchangeSettingsInput interface {
	pulumi.Input

	ToExchangeSettingsOutput() ExchangeSettingsOutput
	ToExchangeSettingsOutputWithContext(context.Context) ExchangeSettingsOutput
}

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() reflect.Type {
	return reflect.TypeOf((*ExchangeSettings)(nil)).Elem()
}

func (i ExchangeSettingsArgs) ToExchangeSettingsOutput() ExchangeSettingsOutput {
	return i.ToExchangeSettingsOutputWithContext(context.Background())
}

func (i ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ExchangeSettingsOutput)
}

func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput {
	return i.ToExchangeSettingsPtrOutputWithContext(context.Background())
}

func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ExchangeSettingsOutput).ToExchangeSettingsPtrOutputWithContext(ctx)
}

// ExchangeSettingsPtrInput is an input type that accepts ExchangeSettingsArgs, ExchangeSettingsPtr and ExchangeSettingsPtrOutput values.
// You can construct a concrete instance of `ExchangeSettingsPtrInput` via:
//
//          ExchangeSettingsArgs{...}
//
//  or:
//
//          nil
type ExchangeSettingsPtrInput interface {
	pulumi.Input

	ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput
	ToExchangeSettingsPtrOutputWithContext(context.Context) ExchangeSettingsPtrOutput
}

type exchangeSettingsPtrType ExchangeSettingsArgs

func ExchangeSettingsPtr(v *ExchangeSettingsArgs) ExchangeSettingsPtrInput {
	return (*exchangeSettingsPtrType)(v)
}

func (*exchangeSettingsPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**ExchangeSettings)(nil)).Elem()
}

func (i *exchangeSettingsPtrType) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput {
	return i.ToExchangeSettingsPtrOutputWithContext(context.Background())
}

func (i *exchangeSettingsPtrType) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ExchangeSettingsPtrOutput)
}

type ExchangeSettingsOutput struct{ *pulumi.OutputState }

func (ExchangeSettingsOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*ExchangeSettings)(nil)).Elem()
}

func (o ExchangeSettingsOutput) ToExchangeSettingsOutput() ExchangeSettingsOutput {
	return o
}

func (o ExchangeSettingsOutput) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput {
	return o
}

func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput {
	return o.ToExchangeSettingsPtrOutputWithContext(context.Background())
}

func (o ExchangeSettingsOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput {
	return o.ApplyT(func(v ExchangeSettings) *ExchangeSettings {
		return &v
	}).(ExchangeSettingsPtrOutput)
}

// Additional key/value settings for the exchange.
func (o ExchangeSettingsOutput) Arguments() pulumi.MapOutput {
	return o.ApplyT(func(v ExchangeSettings) map[string]interface{} { return v.Arguments }).(pulumi.MapOutput)
}

// Whether the exchange will self-delete when all
// queues have finished using it.
func (o ExchangeSettingsOutput) AutoDelete() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v ExchangeSettings) *bool { return v.AutoDelete }).(pulumi.BoolPtrOutput)
}

// Whether the exchange survives server restarts.
// Defaults to `false`.
func (o ExchangeSettingsOutput) Durable() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v ExchangeSettings) *bool { return v.Durable }).(pulumi.BoolPtrOutput)
}

// The type of exchange.
func (o ExchangeSettingsOutput) Type() pulumi.StringOutput {
	return o.ApplyT(func(v ExchangeSettings) string { return v.Type }).(pulumi.StringOutput)
}

type ExchangeSettingsPtrOutput struct{ *pulumi.OutputState }

func (ExchangeSettingsPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**ExchangeSettings)(nil)).Elem()
}

func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput {
	return o
}

func (o ExchangeSettingsPtrOutput) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput {
	return o
}

func (o ExchangeSettingsPtrOutput) Elem() ExchangeSettingsOutput {
	return o.ApplyT(func(v *ExchangeSettings) ExchangeSettings { return *v }).(ExchangeSettingsOutput)
}

// Additional key/value settings for the exchange.
func (o ExchangeSettingsPtrOutput) Arguments() pulumi.MapOutput {
	return o.ApplyT(func(v *ExchangeSettings) map[string]interface{} {
		if v == nil {
			return nil
		}
		return v.Arguments
	}).(pulumi.MapOutput)
}

// Whether the exchange will self-delete when all
// queues have finished using it.
func (o ExchangeSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *ExchangeSettings) *bool {
		if v == nil {
			return nil
		}
		return v.AutoDelete
	}).(pulumi.BoolPtrOutput)
}

// Whether the exchange survives server restarts.
// Defaults to `false`.
func (o ExchangeSettingsPtrOutput) Durable() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *ExchangeSettings) *bool {
		if v == nil {
			return nil
		}
		return v.Durable
	}).(pulumi.BoolPtrOutput)
}

// The type of exchange.
func (o ExchangeSettingsPtrOutput) Type() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ExchangeSettings) *string {
		if v == nil {
			return nil
		}
		return &v.Type
	}).(pulumi.StringPtrOutput)
}

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"`
}

// FederationUpstreamDefinitionInput is an input type that accepts FederationUpstreamDefinitionArgs and FederationUpstreamDefinitionOutput values.
// You can construct a concrete instance of `FederationUpstreamDefinitionInput` via:
//
//          FederationUpstreamDefinitionArgs{...}
type FederationUpstreamDefinitionInput interface {
	pulumi.Input

	ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput
	ToFederationUpstreamDefinitionOutputWithContext(context.Context) FederationUpstreamDefinitionOutput
}

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() reflect.Type {
	return reflect.TypeOf((*FederationUpstreamDefinition)(nil)).Elem()
}

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput {
	return i.ToFederationUpstreamDefinitionOutputWithContext(context.Background())
}

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput {
	return pulumi.ToOutputWithContext(ctx, i).(FederationUpstreamDefinitionOutput)
}

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput {
	return i.ToFederationUpstreamDefinitionPtrOutputWithContext(context.Background())
}

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(FederationUpstreamDefinitionOutput).ToFederationUpstreamDefinitionPtrOutputWithContext(ctx)
}

// FederationUpstreamDefinitionPtrInput is an input type that accepts FederationUpstreamDefinitionArgs, FederationUpstreamDefinitionPtr and FederationUpstreamDefinitionPtrOutput values.
// You can construct a concrete instance of `FederationUpstreamDefinitionPtrInput` via:
//
//          FederationUpstreamDefinitionArgs{...}
//
//  or:
//
//          nil
type FederationUpstreamDefinitionPtrInput interface {
	pulumi.Input

	ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput
	ToFederationUpstreamDefinitionPtrOutputWithContext(context.Context) FederationUpstreamDefinitionPtrOutput
}

type federationUpstreamDefinitionPtrType FederationUpstreamDefinitionArgs

func FederationUpstreamDefinitionPtr(v *FederationUpstreamDefinitionArgs) FederationUpstreamDefinitionPtrInput {
	return (*federationUpstreamDefinitionPtrType)(v)
}

func (*federationUpstreamDefinitionPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**FederationUpstreamDefinition)(nil)).Elem()
}

func (i *federationUpstreamDefinitionPtrType) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput {
	return i.ToFederationUpstreamDefinitionPtrOutputWithContext(context.Background())
}

func (i *federationUpstreamDefinitionPtrType) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(FederationUpstreamDefinitionPtrOutput)
}

type FederationUpstreamDefinitionOutput struct{ *pulumi.OutputState }

func (FederationUpstreamDefinitionOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*FederationUpstreamDefinition)(nil)).Elem()
}

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput {
	return o
}

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput {
	return o
}

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput {
	return o.ToFederationUpstreamDefinitionPtrOutputWithContext(context.Background())
}

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *FederationUpstreamDefinition {
		return &v
	}).(FederationUpstreamDefinitionPtrOutput)
}
func (o FederationUpstreamDefinitionOutput) AckMode() pulumi.StringPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *string { return v.AckMode }).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) Exchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *string { return v.Exchange }).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) Expires() pulumi.IntPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *int { return v.Expires }).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) MaxHops() pulumi.IntPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *int { return v.MaxHops }).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) MessageTtl() pulumi.IntPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *int { return v.MessageTtl }).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) PrefetchCount() pulumi.IntPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *int { return v.PrefetchCount }).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) Queue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *string { return v.Queue }).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) ReconnectDelay() pulumi.IntPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *int { return v.ReconnectDelay }).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) TrustUserId() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) *bool { return v.TrustUserId }).(pulumi.BoolPtrOutput)
}

func (o FederationUpstreamDefinitionOutput) Uri() pulumi.StringOutput {
	return o.ApplyT(func(v FederationUpstreamDefinition) string { return v.Uri }).(pulumi.StringOutput)
}

type FederationUpstreamDefinitionPtrOutput struct{ *pulumi.OutputState }

func (FederationUpstreamDefinitionPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**FederationUpstreamDefinition)(nil)).Elem()
}

func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput {
	return o
}

func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput {
	return o
}

func (o FederationUpstreamDefinitionPtrOutput) Elem() FederationUpstreamDefinitionOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) FederationUpstreamDefinition { return *v }).(FederationUpstreamDefinitionOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) AckMode() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *string {
		if v == nil {
			return nil
		}
		return v.AckMode
	}).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) Exchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *string {
		if v == nil {
			return nil
		}
		return v.Exchange
	}).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) Expires() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *int {
		if v == nil {
			return nil
		}
		return v.Expires
	}).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) MaxHops() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *int {
		if v == nil {
			return nil
		}
		return v.MaxHops
	}).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) MessageTtl() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *int {
		if v == nil {
			return nil
		}
		return v.MessageTtl
	}).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) PrefetchCount() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *int {
		if v == nil {
			return nil
		}
		return v.PrefetchCount
	}).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) Queue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *string {
		if v == nil {
			return nil
		}
		return v.Queue
	}).(pulumi.StringPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) ReconnectDelay() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *int {
		if v == nil {
			return nil
		}
		return v.ReconnectDelay
	}).(pulumi.IntPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) TrustUserId() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *bool {
		if v == nil {
			return nil
		}
		return v.TrustUserId
	}).(pulumi.BoolPtrOutput)
}

func (o FederationUpstreamDefinitionPtrOutput) Uri() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *FederationUpstreamDefinition) *string {
		if v == nil {
			return nil
		}
		return &v.Uri
	}).(pulumi.StringPtrOutput)
}

type PermissionsPermissions struct {
	// The "configure" ACL.
	Configure string `pulumi:"configure"`
	// The "read" ACL.
	Read string `pulumi:"read"`
	// The "write" ACL.
	Write string `pulumi:"write"`
}

// PermissionsPermissionsInput is an input type that accepts PermissionsPermissionsArgs and PermissionsPermissionsOutput values.
// You can construct a concrete instance of `PermissionsPermissionsInput` via:
//
//          PermissionsPermissionsArgs{...}
type PermissionsPermissionsInput interface {
	pulumi.Input

	ToPermissionsPermissionsOutput() PermissionsPermissionsOutput
	ToPermissionsPermissionsOutputWithContext(context.Context) PermissionsPermissionsOutput
}

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() reflect.Type {
	return reflect.TypeOf((*PermissionsPermissions)(nil)).Elem()
}

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput {
	return i.ToPermissionsPermissionsOutputWithContext(context.Background())
}

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PermissionsPermissionsOutput)
}

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput {
	return i.ToPermissionsPermissionsPtrOutputWithContext(context.Background())
}

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PermissionsPermissionsOutput).ToPermissionsPermissionsPtrOutputWithContext(ctx)
}

// PermissionsPermissionsPtrInput is an input type that accepts PermissionsPermissionsArgs, PermissionsPermissionsPtr and PermissionsPermissionsPtrOutput values.
// You can construct a concrete instance of `PermissionsPermissionsPtrInput` via:
//
//          PermissionsPermissionsArgs{...}
//
//  or:
//
//          nil
type PermissionsPermissionsPtrInput interface {
	pulumi.Input

	ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput
	ToPermissionsPermissionsPtrOutputWithContext(context.Context) PermissionsPermissionsPtrOutput
}

type permissionsPermissionsPtrType PermissionsPermissionsArgs

func PermissionsPermissionsPtr(v *PermissionsPermissionsArgs) PermissionsPermissionsPtrInput {
	return (*permissionsPermissionsPtrType)(v)
}

func (*permissionsPermissionsPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**PermissionsPermissions)(nil)).Elem()
}

func (i *permissionsPermissionsPtrType) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput {
	return i.ToPermissionsPermissionsPtrOutputWithContext(context.Background())
}

func (i *permissionsPermissionsPtrType) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PermissionsPermissionsPtrOutput)
}

type PermissionsPermissionsOutput struct{ *pulumi.OutputState }

func (PermissionsPermissionsOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*PermissionsPermissions)(nil)).Elem()
}

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput {
	return o
}

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput {
	return o
}

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput {
	return o.ToPermissionsPermissionsPtrOutputWithContext(context.Background())
}

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput {
	return o.ApplyT(func(v PermissionsPermissions) *PermissionsPermissions {
		return &v
	}).(PermissionsPermissionsPtrOutput)
}

// The "configure" ACL.
func (o PermissionsPermissionsOutput) Configure() pulumi.StringOutput {
	return o.ApplyT(func(v PermissionsPermissions) string { return v.Configure }).(pulumi.StringOutput)
}

// The "read" ACL.
func (o PermissionsPermissionsOutput) Read() pulumi.StringOutput {
	return o.ApplyT(func(v PermissionsPermissions) string { return v.Read }).(pulumi.StringOutput)
}

// The "write" ACL.
func (o PermissionsPermissionsOutput) Write() pulumi.StringOutput {
	return o.ApplyT(func(v PermissionsPermissions) string { return v.Write }).(pulumi.StringOutput)
}

type PermissionsPermissionsPtrOutput struct{ *pulumi.OutputState }

func (PermissionsPermissionsPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**PermissionsPermissions)(nil)).Elem()
}

func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput {
	return o
}

func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput {
	return o
}

func (o PermissionsPermissionsPtrOutput) Elem() PermissionsPermissionsOutput {
	return o.ApplyT(func(v *PermissionsPermissions) PermissionsPermissions { return *v }).(PermissionsPermissionsOutput)
}

// The "configure" ACL.
func (o PermissionsPermissionsPtrOutput) Configure() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *PermissionsPermissions) *string {
		if v == nil {
			return nil
		}
		return &v.Configure
	}).(pulumi.StringPtrOutput)
}

// The "read" ACL.
func (o PermissionsPermissionsPtrOutput) Read() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *PermissionsPermissions) *string {
		if v == nil {
			return nil
		}
		return &v.Read
	}).(pulumi.StringPtrOutput)
}

// The "write" ACL.
func (o PermissionsPermissionsPtrOutput) Write() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *PermissionsPermissions) *string {
		if v == nil {
			return nil
		}
		return &v.Write
	}).(pulumi.StringPtrOutput)
}

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"`
}

// PolicyPolicyInput is an input type that accepts PolicyPolicyArgs and PolicyPolicyOutput values.
// You can construct a concrete instance of `PolicyPolicyInput` via:
//
//          PolicyPolicyArgs{...}
type PolicyPolicyInput interface {
	pulumi.Input

	ToPolicyPolicyOutput() PolicyPolicyOutput
	ToPolicyPolicyOutputWithContext(context.Context) PolicyPolicyOutput
}

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() reflect.Type {
	return reflect.TypeOf((*PolicyPolicy)(nil)).Elem()
}

func (i PolicyPolicyArgs) ToPolicyPolicyOutput() PolicyPolicyOutput {
	return i.ToPolicyPolicyOutputWithContext(context.Background())
}

func (i PolicyPolicyArgs) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PolicyPolicyOutput)
}

func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput {
	return i.ToPolicyPolicyPtrOutputWithContext(context.Background())
}

func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PolicyPolicyOutput).ToPolicyPolicyPtrOutputWithContext(ctx)
}

// PolicyPolicyPtrInput is an input type that accepts PolicyPolicyArgs, PolicyPolicyPtr and PolicyPolicyPtrOutput values.
// You can construct a concrete instance of `PolicyPolicyPtrInput` via:
//
//          PolicyPolicyArgs{...}
//
//  or:
//
//          nil
type PolicyPolicyPtrInput interface {
	pulumi.Input

	ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput
	ToPolicyPolicyPtrOutputWithContext(context.Context) PolicyPolicyPtrOutput
}

type policyPolicyPtrType PolicyPolicyArgs

func PolicyPolicyPtr(v *PolicyPolicyArgs) PolicyPolicyPtrInput {
	return (*policyPolicyPtrType)(v)
}

func (*policyPolicyPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**PolicyPolicy)(nil)).Elem()
}

func (i *policyPolicyPtrType) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput {
	return i.ToPolicyPolicyPtrOutputWithContext(context.Background())
}

func (i *policyPolicyPtrType) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(PolicyPolicyPtrOutput)
}

type PolicyPolicyOutput struct{ *pulumi.OutputState }

func (PolicyPolicyOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*PolicyPolicy)(nil)).Elem()
}

func (o PolicyPolicyOutput) ToPolicyPolicyOutput() PolicyPolicyOutput {
	return o
}

func (o PolicyPolicyOutput) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput {
	return o
}

func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput {
	return o.ToPolicyPolicyPtrOutputWithContext(context.Background())
}

func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput {
	return o.ApplyT(func(v PolicyPolicy) *PolicyPolicy {
		return &v
	}).(PolicyPolicyPtrOutput)
}

// Can either be "exchanges", "queues", or "all".
func (o PolicyPolicyOutput) ApplyTo() pulumi.StringOutput {
	return o.ApplyT(func(v PolicyPolicy) string { return v.ApplyTo }).(pulumi.StringOutput)
}

// Key/value pairs of the policy definition. See the
// RabbitMQ documentation for definition references and examples.
func (o PolicyPolicyOutput) Definition() pulumi.MapOutput {
	return o.ApplyT(func(v PolicyPolicy) map[string]interface{} { return v.Definition }).(pulumi.MapOutput)
}

// A pattern to match an exchange or queue name.
func (o PolicyPolicyOutput) Pattern() pulumi.StringOutput {
	return o.ApplyT(func(v PolicyPolicy) string { return v.Pattern }).(pulumi.StringOutput)
}

// The policy with the greater priority is applied first.
func (o PolicyPolicyOutput) Priority() pulumi.IntOutput {
	return o.ApplyT(func(v PolicyPolicy) int { return v.Priority }).(pulumi.IntOutput)
}

type PolicyPolicyPtrOutput struct{ *pulumi.OutputState }

func (PolicyPolicyPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**PolicyPolicy)(nil)).Elem()
}

func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput {
	return o
}

func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput {
	return o
}

func (o PolicyPolicyPtrOutput) Elem() PolicyPolicyOutput {
	return o.ApplyT(func(v *PolicyPolicy) PolicyPolicy { return *v }).(PolicyPolicyOutput)
}

// Can either be "exchanges", "queues", or "all".
func (o PolicyPolicyPtrOutput) ApplyTo() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *PolicyPolicy) *string {
		if v == nil {
			return nil
		}
		return &v.ApplyTo
	}).(pulumi.StringPtrOutput)
}

// Key/value pairs of the policy definition. See the
// RabbitMQ documentation for definition references and examples.
func (o PolicyPolicyPtrOutput) Definition() pulumi.MapOutput {
	return o.ApplyT(func(v *PolicyPolicy) map[string]interface{} {
		if v == nil {
			return nil
		}
		return v.Definition
	}).(pulumi.MapOutput)
}

// A pattern to match an exchange or queue name.
func (o PolicyPolicyPtrOutput) Pattern() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *PolicyPolicy) *string {
		if v == nil {
			return nil
		}
		return &v.Pattern
	}).(pulumi.StringPtrOutput)
}

// The policy with the greater priority is applied first.
func (o PolicyPolicyPtrOutput) Priority() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *PolicyPolicy) *int {
		if v == nil {
			return nil
		}
		return &v.Priority
	}).(pulumi.IntPtrOutput)
}

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"`
}

// QueueSettingsInput is an input type that accepts QueueSettingsArgs and QueueSettingsOutput values.
// You can construct a concrete instance of `QueueSettingsInput` via:
//
//          QueueSettingsArgs{...}
type QueueSettingsInput interface {
	pulumi.Input

	ToQueueSettingsOutput() QueueSettingsOutput
	ToQueueSettingsOutputWithContext(context.Context) QueueSettingsOutput
}

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() reflect.Type {
	return reflect.TypeOf((*QueueSettings)(nil)).Elem()
}

func (i QueueSettingsArgs) ToQueueSettingsOutput() QueueSettingsOutput {
	return i.ToQueueSettingsOutputWithContext(context.Background())
}

func (i QueueSettingsArgs) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput {
	return pulumi.ToOutputWithContext(ctx, i).(QueueSettingsOutput)
}

func (i QueueSettingsArgs) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput {
	return i.ToQueueSettingsPtrOutputWithContext(context.Background())
}

func (i QueueSettingsArgs) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(QueueSettingsOutput).ToQueueSettingsPtrOutputWithContext(ctx)
}

// QueueSettingsPtrInput is an input type that accepts QueueSettingsArgs, QueueSettingsPtr and QueueSettingsPtrOutput values.
// You can construct a concrete instance of `QueueSettingsPtrInput` via:
//
//          QueueSettingsArgs{...}
//
//  or:
//
//          nil
type QueueSettingsPtrInput interface {
	pulumi.Input

	ToQueueSettingsPtrOutput() QueueSettingsPtrOutput
	ToQueueSettingsPtrOutputWithContext(context.Context) QueueSettingsPtrOutput
}

type queueSettingsPtrType QueueSettingsArgs

func QueueSettingsPtr(v *QueueSettingsArgs) QueueSettingsPtrInput {
	return (*queueSettingsPtrType)(v)
}

func (*queueSettingsPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**QueueSettings)(nil)).Elem()
}

func (i *queueSettingsPtrType) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput {
	return i.ToQueueSettingsPtrOutputWithContext(context.Background())
}

func (i *queueSettingsPtrType) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(QueueSettingsPtrOutput)
}

type QueueSettingsOutput struct{ *pulumi.OutputState }

func (QueueSettingsOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*QueueSettings)(nil)).Elem()
}

func (o QueueSettingsOutput) ToQueueSettingsOutput() QueueSettingsOutput {
	return o
}

func (o QueueSettingsOutput) ToQueueSettingsOutputWithContext(ctx context.Context) QueueSettingsOutput {
	return o
}

func (o QueueSettingsOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput {
	return o.ToQueueSettingsPtrOutputWithContext(context.Background())
}

func (o QueueSettingsOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput {
	return o.ApplyT(func(v QueueSettings) *QueueSettings {
		return &v
	}).(QueueSettingsPtrOutput)
}

// 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 (o QueueSettingsOutput) Arguments() pulumi.MapOutput {
	return o.ApplyT(func(v QueueSettings) map[string]interface{} { return v.Arguments }).(pulumi.MapOutput)
}

// A nested JSON string which contains additional
// settings for the queue. This is useful for when the arguments contain
// non-string values.
func (o QueueSettingsOutput) ArgumentsJson() pulumi.StringPtrOutput {
	return o.ApplyT(func(v QueueSettings) *string { return v.ArgumentsJson }).(pulumi.StringPtrOutput)
}

// Whether the queue will self-delete when all
// consumers have unsubscribed.
func (o QueueSettingsOutput) AutoDelete() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v QueueSettings) *bool { return v.AutoDelete }).(pulumi.BoolPtrOutput)
}

// Whether the queue survives server restarts.
// Defaults to `false`.
func (o QueueSettingsOutput) Durable() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v QueueSettings) *bool { return v.Durable }).(pulumi.BoolPtrOutput)
}

type QueueSettingsPtrOutput struct{ *pulumi.OutputState }

func (QueueSettingsPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**QueueSettings)(nil)).Elem()
}

func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutput() QueueSettingsPtrOutput {
	return o
}

func (o QueueSettingsPtrOutput) ToQueueSettingsPtrOutputWithContext(ctx context.Context) QueueSettingsPtrOutput {
	return o
}

func (o QueueSettingsPtrOutput) Elem() QueueSettingsOutput {
	return o.ApplyT(func(v *QueueSettings) QueueSettings { return *v }).(QueueSettingsOutput)
}

// 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 (o QueueSettingsPtrOutput) Arguments() pulumi.MapOutput {
	return o.ApplyT(func(v *QueueSettings) map[string]interface{} {
		if v == nil {
			return nil
		}
		return v.Arguments
	}).(pulumi.MapOutput)
}

// A nested JSON string which contains additional
// settings for the queue. This is useful for when the arguments contain
// non-string values.
func (o QueueSettingsPtrOutput) ArgumentsJson() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *QueueSettings) *string {
		if v == nil {
			return nil
		}
		return v.ArgumentsJson
	}).(pulumi.StringPtrOutput)
}

// Whether the queue will self-delete when all
// consumers have unsubscribed.
func (o QueueSettingsPtrOutput) AutoDelete() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *QueueSettings) *bool {
		if v == nil {
			return nil
		}
		return v.AutoDelete
	}).(pulumi.BoolPtrOutput)
}

// Whether the queue survives server restarts.
// Defaults to `false`.
func (o QueueSettingsPtrOutput) Durable() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *QueueSettings) *bool {
		if v == nil {
			return nil
		}
		return v.Durable
	}).(pulumi.BoolPtrOutput)
}

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"`
}

// ShovelInfoInput is an input type that accepts ShovelInfoArgs and ShovelInfoOutput values.
// You can construct a concrete instance of `ShovelInfoInput` via:
//
//          ShovelInfoArgs{...}
type ShovelInfoInput interface {
	pulumi.Input

	ToShovelInfoOutput() ShovelInfoOutput
	ToShovelInfoOutputWithContext(context.Context) ShovelInfoOutput
}

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() reflect.Type {
	return reflect.TypeOf((*ShovelInfo)(nil)).Elem()
}

func (i ShovelInfoArgs) ToShovelInfoOutput() ShovelInfoOutput {
	return i.ToShovelInfoOutputWithContext(context.Background())
}

func (i ShovelInfoArgs) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ShovelInfoOutput)
}

func (i ShovelInfoArgs) ToShovelInfoPtrOutput() ShovelInfoPtrOutput {
	return i.ToShovelInfoPtrOutputWithContext(context.Background())
}

func (i ShovelInfoArgs) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ShovelInfoOutput).ToShovelInfoPtrOutputWithContext(ctx)
}

// ShovelInfoPtrInput is an input type that accepts ShovelInfoArgs, ShovelInfoPtr and ShovelInfoPtrOutput values.
// You can construct a concrete instance of `ShovelInfoPtrInput` via:
//
//          ShovelInfoArgs{...}
//
//  or:
//
//          nil
type ShovelInfoPtrInput interface {
	pulumi.Input

	ToShovelInfoPtrOutput() ShovelInfoPtrOutput
	ToShovelInfoPtrOutputWithContext(context.Context) ShovelInfoPtrOutput
}

type shovelInfoPtrType ShovelInfoArgs

func ShovelInfoPtr(v *ShovelInfoArgs) ShovelInfoPtrInput {
	return (*shovelInfoPtrType)(v)
}

func (*shovelInfoPtrType) ElementType() reflect.Type {
	return reflect.TypeOf((**ShovelInfo)(nil)).Elem()
}

func (i *shovelInfoPtrType) ToShovelInfoPtrOutput() ShovelInfoPtrOutput {
	return i.ToShovelInfoPtrOutputWithContext(context.Background())
}

func (i *shovelInfoPtrType) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput {
	return pulumi.ToOutputWithContext(ctx, i).(ShovelInfoPtrOutput)
}

type ShovelInfoOutput struct{ *pulumi.OutputState }

func (ShovelInfoOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*ShovelInfo)(nil)).Elem()
}

func (o ShovelInfoOutput) ToShovelInfoOutput() ShovelInfoOutput {
	return o
}

func (o ShovelInfoOutput) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput {
	return o
}

func (o ShovelInfoOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput {
	return o.ToShovelInfoPtrOutputWithContext(context.Background())
}

func (o ShovelInfoOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *ShovelInfo {
		return &v
	}).(ShovelInfoPtrOutput)
}

// Determines how the shovel should acknowledge messages.
// Defaults to `on-confirm`.
func (o ShovelInfoOutput) AckMode() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.AckMode }).(pulumi.StringPtrOutput)
}

// Whether to amqp shovel headers.
// Defaults to `false`.
func (o ShovelInfoOutput) AddForwardHeaders() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *bool { return v.AddForwardHeaders }).(pulumi.BoolPtrOutput)
}

// Determines when (if ever) the shovel should delete itself .
// Defaults to `never`.
func (o ShovelInfoOutput) DeleteAfter() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.DeleteAfter }).(pulumi.StringPtrOutput)
}

// The exchange to which messages should be published.
// Either this or destinationQueue must be specified but not both.
func (o ShovelInfoOutput) DestinationExchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.DestinationExchange }).(pulumi.StringPtrOutput)
}

// The routing key when using destination_exchange.
func (o ShovelInfoOutput) DestinationExchangeKey() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.DestinationExchangeKey }).(pulumi.StringPtrOutput)
}

// The queue to which messages should be published.
// Either this or destinationExchange must be specified but not both.
func (o ShovelInfoOutput) DestinationQueue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.DestinationQueue }).(pulumi.StringPtrOutput)
}

// The amqp uri for the destination .
func (o ShovelInfoOutput) DestinationUri() pulumi.StringOutput {
	return o.ApplyT(func(v ShovelInfo) string { return v.DestinationUri }).(pulumi.StringOutput)
}

// The maximum number of unacknowledged messages copied over a shovel at any one time.
// Defaults to `1000`.
func (o ShovelInfoOutput) PrefetchCount() pulumi.IntPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *int { return v.PrefetchCount }).(pulumi.IntPtrOutput)
}

// The duration in seconds to reconnect to a broker after disconnected.
// Defaults to `1`.
func (o ShovelInfoOutput) ReconnectDelay() pulumi.IntPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *int { return v.ReconnectDelay }).(pulumi.IntPtrOutput)
}

// The exchange from which to consume.
// Either this or sourceQueue must be specified but not both.
func (o ShovelInfoOutput) SourceExchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.SourceExchange }).(pulumi.StringPtrOutput)
}

// The routing key when using source_exchange.
func (o ShovelInfoOutput) SourceExchangeKey() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.SourceExchangeKey }).(pulumi.StringPtrOutput)
}

// The queue from which to consume.
// Either this or sourceExchange must be specified but not both.
func (o ShovelInfoOutput) SourceQueue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v ShovelInfo) *string { return v.SourceQueue }).(pulumi.StringPtrOutput)
}

// The amqp uri for the source.
func (o ShovelInfoOutput) SourceUri() pulumi.StringOutput {
	return o.ApplyT(func(v ShovelInfo) string { return v.SourceUri }).(pulumi.StringOutput)
}

type ShovelInfoPtrOutput struct{ *pulumi.OutputState }

func (ShovelInfoPtrOutput) ElementType() reflect.Type {
	return reflect.TypeOf((**ShovelInfo)(nil)).Elem()
}

func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput {
	return o
}

func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput {
	return o
}

func (o ShovelInfoPtrOutput) Elem() ShovelInfoOutput {
	return o.ApplyT(func(v *ShovelInfo) ShovelInfo { return *v }).(ShovelInfoOutput)
}

// Determines how the shovel should acknowledge messages.
// Defaults to `on-confirm`.
func (o ShovelInfoPtrOutput) AckMode() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.AckMode
	}).(pulumi.StringPtrOutput)
}

// Whether to amqp shovel headers.
// Defaults to `false`.
func (o ShovelInfoPtrOutput) AddForwardHeaders() pulumi.BoolPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *bool {
		if v == nil {
			return nil
		}
		return v.AddForwardHeaders
	}).(pulumi.BoolPtrOutput)
}

// Determines when (if ever) the shovel should delete itself .
// Defaults to `never`.
func (o ShovelInfoPtrOutput) DeleteAfter() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.DeleteAfter
	}).(pulumi.StringPtrOutput)
}

// The exchange to which messages should be published.
// Either this or destinationQueue must be specified but not both.
func (o ShovelInfoPtrOutput) DestinationExchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.DestinationExchange
	}).(pulumi.StringPtrOutput)
}

// The routing key when using destination_exchange.
func (o ShovelInfoPtrOutput) DestinationExchangeKey() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.DestinationExchangeKey
	}).(pulumi.StringPtrOutput)
}

// The queue to which messages should be published.
// Either this or destinationExchange must be specified but not both.
func (o ShovelInfoPtrOutput) DestinationQueue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.DestinationQueue
	}).(pulumi.StringPtrOutput)
}

// The amqp uri for the destination .
func (o ShovelInfoPtrOutput) DestinationUri() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return &v.DestinationUri
	}).(pulumi.StringPtrOutput)
}

// The maximum number of unacknowledged messages copied over a shovel at any one time.
// Defaults to `1000`.
func (o ShovelInfoPtrOutput) PrefetchCount() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *int {
		if v == nil {
			return nil
		}
		return v.PrefetchCount
	}).(pulumi.IntPtrOutput)
}

// The duration in seconds to reconnect to a broker after disconnected.
// Defaults to `1`.
func (o ShovelInfoPtrOutput) ReconnectDelay() pulumi.IntPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *int {
		if v == nil {
			return nil
		}
		return v.ReconnectDelay
	}).(pulumi.IntPtrOutput)
}

// The exchange from which to consume.
// Either this or sourceQueue must be specified but not both.
func (o ShovelInfoPtrOutput) SourceExchange() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.SourceExchange
	}).(pulumi.StringPtrOutput)
}

// The routing key when using source_exchange.
func (o ShovelInfoPtrOutput) SourceExchangeKey() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.SourceExchangeKey
	}).(pulumi.StringPtrOutput)
}

// The queue from which to consume.
// Either this or sourceExchange must be specified but not both.
func (o ShovelInfoPtrOutput) SourceQueue() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return v.SourceQueue
	}).(pulumi.StringPtrOutput)
}

// The amqp uri for the source.
func (o ShovelInfoPtrOutput) SourceUri() pulumi.StringPtrOutput {
	return o.ApplyT(func(v *ShovelInfo) *string {
		if v == nil {
			return nil
		}
		return &v.SourceUri
	}).(pulumi.StringPtrOutput)
}

type TopicPermissionsPermission struct {
	// The exchange to set the permissions for.
	Exchange string `pulumi:"exchange"`
	// The "read" ACL.
	Read string `pulumi:"read"`
	// The "write" ACL.
	Write string `pulumi:"write"`
}

// TopicPermissionsPermissionInput is an input type that accepts TopicPermissionsPermissionArgs and TopicPermissionsPermissionOutput values.
// You can construct a concrete instance of `TopicPermissionsPermissionInput` via:
//
//          TopicPermissionsPermissionArgs{...}
type TopicPermissionsPermissionInput interface {
	pulumi.Input

	ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput
	ToTopicPermissionsPermissionOutputWithContext(context.Context) TopicPermissionsPermissionOutput
}

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() reflect.Type {
	return reflect.TypeOf((*TopicPermissionsPermission)(nil)).Elem()
}

func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput {
	return i.ToTopicPermissionsPermissionOutputWithContext(context.Background())
}

func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput {
	return pulumi.ToOutputWithContext(ctx, i).(TopicPermissionsPermissionOutput)
}

// TopicPermissionsPermissionArrayInput is an input type that accepts TopicPermissionsPermissionArray and TopicPermissionsPermissionArrayOutput values.
// You can construct a concrete instance of `TopicPermissionsPermissionArrayInput` via:
//
//          TopicPermissionsPermissionArray{ TopicPermissionsPermissionArgs{...} }
type TopicPermissionsPermissionArrayInput interface {
	pulumi.Input

	ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput
	ToTopicPermissionsPermissionArrayOutputWithContext(context.Context) TopicPermissionsPermissionArrayOutput
}

type TopicPermissionsPermissionArray []TopicPermissionsPermissionInput

func (TopicPermissionsPermissionArray) ElementType() reflect.Type {
	return reflect.TypeOf((*[]TopicPermissionsPermission)(nil)).Elem()
}

func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput {
	return i.ToTopicPermissionsPermissionArrayOutputWithContext(context.Background())
}

func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput {
	return pulumi.ToOutputWithContext(ctx, i).(TopicPermissionsPermissionArrayOutput)
}

type TopicPermissionsPermissionOutput struct{ *pulumi.OutputState }

func (TopicPermissionsPermissionOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*TopicPermissionsPermission)(nil)).Elem()
}

func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput {
	return o
}

func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput {
	return o
}

// The exchange to set the permissions for.
func (o TopicPermissionsPermissionOutput) Exchange() pulumi.StringOutput {
	return o.ApplyT(func(v TopicPermissionsPermission) string { return v.Exchange }).(pulumi.StringOutput)
}

// The "read" ACL.
func (o TopicPermissionsPermissionOutput) Read() pulumi.StringOutput {
	return o.ApplyT(func(v TopicPermissionsPermission) string { return v.Read }).(pulumi.StringOutput)
}

// The "write" ACL.
func (o TopicPermissionsPermissionOutput) Write() pulumi.StringOutput {
	return o.ApplyT(func(v TopicPermissionsPermission) string { return v.Write }).(pulumi.StringOutput)
}

type TopicPermissionsPermissionArrayOutput struct{ *pulumi.OutputState }

func (TopicPermissionsPermissionArrayOutput) ElementType() reflect.Type {
	return reflect.TypeOf((*[]TopicPermissionsPermission)(nil)).Elem()
}

func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput {
	return o
}

func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput {
	return o
}

func (o TopicPermissionsPermissionArrayOutput) Index(i pulumi.IntInput) TopicPermissionsPermissionOutput {
	return pulumi.All(o, i).ApplyT(func(vs []interface{}) TopicPermissionsPermission {
		return vs[0].([]TopicPermissionsPermission)[vs[1].(int)]
	}).(TopicPermissionsPermissionOutput)
}

func init() {
	pulumi.RegisterOutputType(ExchangeSettingsOutput{})
	pulumi.RegisterOutputType(ExchangeSettingsPtrOutput{})
	pulumi.RegisterOutputType(FederationUpstreamDefinitionOutput{})
	pulumi.RegisterOutputType(FederationUpstreamDefinitionPtrOutput{})
	pulumi.RegisterOutputType(PermissionsPermissionsOutput{})
	pulumi.RegisterOutputType(PermissionsPermissionsPtrOutput{})
	pulumi.RegisterOutputType(PolicyPolicyOutput{})
	pulumi.RegisterOutputType(PolicyPolicyPtrOutput{})
	pulumi.RegisterOutputType(QueueSettingsOutput{})
	pulumi.RegisterOutputType(QueueSettingsPtrOutput{})
	pulumi.RegisterOutputType(ShovelInfoOutput{})
	pulumi.RegisterOutputType(ShovelInfoPtrOutput{})
	pulumi.RegisterOutputType(TopicPermissionsPermissionOutput{})
	pulumi.RegisterOutputType(TopicPermissionsPermissionArrayOutput{})
}