rabbitmq

package
v3.3.2 Latest Latest
Warning

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

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

Documentation

Overview

A Pulumi package for creating and managing RabbitMQ resources.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Binding 

type Binding struct {
	pulumi.CustomResourceState

	// Additional key/value arguments for the binding.
	Arguments     pulumi.MapOutput       `pulumi:"arguments"`
	ArgumentsJson pulumi.StringPtrOutput `pulumi:"argumentsJson"`
	// The destination queue or exchange.
	Destination pulumi.StringOutput `pulumi:"destination"`
	// The type of destination (queue or exchange).
	DestinationType pulumi.StringOutput `pulumi:"destinationType"`
	// A unique key to refer to the binding.
	PropertiesKey pulumi.StringOutput `pulumi:"propertiesKey"`
	// A routing key for the binding.
	RoutingKey pulumi.StringPtrOutput `pulumi:"routingKey"`
	// The source exchange.
	Source pulumi.StringOutput `pulumi:"source"`
	// The vhost to create the resource in.
	Vhost pulumi.StringOutput `pulumi:"vhost"`
}

The “Binding“ resource creates and manages a binding relationship between a queue an exchange.

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## 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/%! (MISSING)``` ```

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 

func (*Binding) ElementType() reflect.Type

func (*Binding) ToBindingOutput 

func (i *Binding) ToBindingOutput() BindingOutput

func (*Binding) ToBindingOutputWithContext 

func (i *Binding) ToBindingOutputWithContext(ctx context.Context) BindingOutput

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 

type BindingArray []BindingInput

func (BindingArray) ElementType 

func (BindingArray) ElementType() reflect.Type

func (BindingArray) ToBindingArrayOutput 

func (i BindingArray) ToBindingArrayOutput() BindingArrayOutput

func (BindingArray) ToBindingArrayOutputWithContext 

func (i BindingArray) ToBindingArrayOutputWithContext(ctx context.Context) BindingArrayOutput

type BindingArrayInput 

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 

type BindingArrayOutput struct{ *pulumi.OutputState }

func (BindingArrayOutput) ElementType 

func (BindingArrayOutput) ElementType() reflect.Type

func (BindingArrayOutput) Index 

func (o BindingArrayOutput) Index(i pulumi.IntInput) BindingOutput

func (BindingArrayOutput) ToBindingArrayOutput 

func (o BindingArrayOutput) ToBindingArrayOutput() BindingArrayOutput

func (BindingArrayOutput) ToBindingArrayOutputWithContext 

func (o BindingArrayOutput) ToBindingArrayOutputWithContext(ctx context.Context) BindingArrayOutput

type BindingInput 

type BindingInput interface {
	pulumi.Input

	ToBindingOutput() BindingOutput
	ToBindingOutputWithContext(ctx context.Context) BindingOutput
}

type BindingMap 

type BindingMap map[string]BindingInput

func (BindingMap) ElementType 

func (BindingMap) ElementType() reflect.Type

func (BindingMap) ToBindingMapOutput 

func (i BindingMap) ToBindingMapOutput() BindingMapOutput

func (BindingMap) ToBindingMapOutputWithContext 

func (i BindingMap) ToBindingMapOutputWithContext(ctx context.Context) BindingMapOutput

type BindingMapInput 

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 

type BindingMapOutput struct{ *pulumi.OutputState }

func (BindingMapOutput) ElementType 

func (BindingMapOutput) ElementType() reflect.Type

func (BindingMapOutput) MapIndex 

func (o BindingMapOutput) MapIndex(k pulumi.StringInput) BindingOutput

func (BindingMapOutput) ToBindingMapOutput 

func (o BindingMapOutput) ToBindingMapOutput() BindingMapOutput

func (BindingMapOutput) ToBindingMapOutputWithContext 

func (o BindingMapOutput) ToBindingMapOutputWithContext(ctx context.Context) BindingMapOutput

type BindingOutput 

type BindingOutput struct{ *pulumi.OutputState }

func (BindingOutput) Arguments added in v3.3.0 

func (o BindingOutput) Arguments() pulumi.MapOutput

Additional key/value arguments for the binding.

func (BindingOutput) ArgumentsJson added in v3.3.0 

func (o BindingOutput) ArgumentsJson() pulumi.StringPtrOutput

func (BindingOutput) Destination added in v3.3.0 

func (o BindingOutput) Destination() pulumi.StringOutput

The destination queue or exchange.

func (BindingOutput) DestinationType added in v3.3.0 

func (o BindingOutput) DestinationType() pulumi.StringOutput

The type of destination (queue or exchange).

func (BindingOutput) ElementType 

func (BindingOutput) ElementType() reflect.Type

func (BindingOutput) PropertiesKey added in v3.3.0 

func (o BindingOutput) PropertiesKey() pulumi.StringOutput

A unique key to refer to the binding.

func (BindingOutput) RoutingKey added in v3.3.0 

func (o BindingOutput) RoutingKey() pulumi.StringPtrOutput

A routing key for the binding.

func (BindingOutput) Source added in v3.3.0 

func (o BindingOutput) Source() pulumi.StringOutput

The source exchange.

func (BindingOutput) ToBindingOutput 

func (o BindingOutput) ToBindingOutput() BindingOutput

func (BindingOutput) ToBindingOutputWithContext 

func (o BindingOutput) ToBindingOutputWithContext(ctx context.Context) BindingOutput

func (BindingOutput) Vhost added in v3.3.0 

func (o BindingOutput) Vhost() pulumi.StringOutput

The vhost to create the resource in.

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

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*Exchange) ElementType() reflect.Type

func (*Exchange) ToExchangeOutput 

func (i *Exchange) ToExchangeOutput() ExchangeOutput

func (*Exchange) ToExchangeOutputWithContext 

func (i *Exchange) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput

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 

type ExchangeArray []ExchangeInput

func (ExchangeArray) ElementType 

func (ExchangeArray) ElementType() reflect.Type

func (ExchangeArray) ToExchangeArrayOutput 

func (i ExchangeArray) ToExchangeArrayOutput() ExchangeArrayOutput

func (ExchangeArray) ToExchangeArrayOutputWithContext 

func (i ExchangeArray) ToExchangeArrayOutputWithContext(ctx context.Context) ExchangeArrayOutput

type ExchangeArrayInput 

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 

type ExchangeArrayOutput struct{ *pulumi.OutputState }

func (ExchangeArrayOutput) ElementType 

func (ExchangeArrayOutput) ElementType() reflect.Type

func (ExchangeArrayOutput) Index 

func (o ExchangeArrayOutput) Index(i pulumi.IntInput) ExchangeOutput

func (ExchangeArrayOutput) ToExchangeArrayOutput 

func (o ExchangeArrayOutput) ToExchangeArrayOutput() ExchangeArrayOutput

func (ExchangeArrayOutput) ToExchangeArrayOutputWithContext 

func (o ExchangeArrayOutput) ToExchangeArrayOutputWithContext(ctx context.Context) ExchangeArrayOutput

type ExchangeInput 

type ExchangeInput interface {
	pulumi.Input

	ToExchangeOutput() ExchangeOutput
	ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput
}

type ExchangeMap 

type ExchangeMap map[string]ExchangeInput

func (ExchangeMap) ElementType 

func (ExchangeMap) ElementType() reflect.Type

func (ExchangeMap) ToExchangeMapOutput 

func (i ExchangeMap) ToExchangeMapOutput() ExchangeMapOutput

func (ExchangeMap) ToExchangeMapOutputWithContext 

func (i ExchangeMap) ToExchangeMapOutputWithContext(ctx context.Context) ExchangeMapOutput

type ExchangeMapInput 

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 

type ExchangeMapOutput struct{ *pulumi.OutputState }

func (ExchangeMapOutput) ElementType 

func (ExchangeMapOutput) ElementType() reflect.Type

func (ExchangeMapOutput) MapIndex 

func (o ExchangeMapOutput) MapIndex(k pulumi.StringInput) ExchangeOutput

func (ExchangeMapOutput) ToExchangeMapOutput 

func (o ExchangeMapOutput) ToExchangeMapOutput() ExchangeMapOutput

func (ExchangeMapOutput) ToExchangeMapOutputWithContext 

func (o ExchangeMapOutput) ToExchangeMapOutputWithContext(ctx context.Context) ExchangeMapOutput

type ExchangeOutput 

type ExchangeOutput struct{ *pulumi.OutputState }

func (ExchangeOutput) ElementType 

func (ExchangeOutput) ElementType() reflect.Type

func (ExchangeOutput) Name added in v3.3.0 

func (o ExchangeOutput) Name() pulumi.StringOutput

The name of the exchange.

func (ExchangeOutput) Settings added in v3.3.0 

func (o ExchangeOutput) Settings() ExchangeSettingsOutput

The settings of the exchange. The structure is described below.

func (ExchangeOutput) ToExchangeOutput 

func (o ExchangeOutput) ToExchangeOutput() ExchangeOutput

func (ExchangeOutput) ToExchangeOutputWithContext 

func (o ExchangeOutput) ToExchangeOutputWithContext(ctx context.Context) ExchangeOutput

func (ExchangeOutput) Vhost added in v3.3.0 

func (o ExchangeOutput) Vhost() pulumi.StringPtrOutput

The vhost to create the resource in.

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 

type FederationUpstream struct {
	pulumi.CustomResourceState

	// Set to `federation-upstream` by the underlying RabbitMQ provider. You do not set this attribute but will see it in state and plan output.
	Component pulumi.StringOutput `pulumi:"component"`
	// The configuration of the federation upstream. The structure is described below.
	Definition FederationUpstreamDefinitionOutput `pulumi:"definition"`
	// The name of the federation upstream.
	Name pulumi.StringOutput `pulumi:"name"`
	// The vhost to create the resource in.
	Vhost pulumi.StringOutput `pulumi:"vhost"`
}

The “FederationUpstream“ resource creates and manages a federation upstream parameter.

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		test, err := rabbitmq.NewVHost(ctx, "test", nil)
		if err != nil {
			return err
		}
		guest, err := rabbitmq.NewPermissions(ctx, "guest", &rabbitmq.PermissionsArgs{
			User:  pulumi.String("guest"),
			Vhost: test.Name,
			Permissions: &rabbitmq.PermissionsPermissionsArgs{
				Configure: pulumi.String(".*"),
				Write:     pulumi.String(".*"),
				Read:      pulumi.String(".*"),
			},
		})
		if err != nil {
			return err
		}
		// downstream exchange
		fooExchange, err := rabbitmq.NewExchange(ctx, "fooExchange", &rabbitmq.ExchangeArgs{
			Vhost: guest.Vhost,
			Settings: &rabbitmq.ExchangeSettingsArgs{
				Type:    pulumi.String("topic"),
				Durable: pulumi.Bool(true),
			},
		})
		if err != nil {
			return err
		}
		// upstream broker
		fooFederationUpstream, err := rabbitmq.NewFederationUpstream(ctx, "fooFederationUpstream", &rabbitmq.FederationUpstreamArgs{
			Vhost: guest.Vhost,
			Definition: &rabbitmq.FederationUpstreamDefinitionArgs{
				Uri:            pulumi.String("amqp://guest:guest@upstream-server-name:5672/%2f"),
				PrefetchCount:  pulumi.Int(1000),
				ReconnectDelay: pulumi.Int(5),
				AckMode:        pulumi.String("on-confirm"),
				TrustUserId:    pulumi.Bool(false),
				MaxHops:        pulumi.Int(1),
			},
		})
		if err != nil {
			return err
		}
		_, err = rabbitmq.NewPolicy(ctx, "fooPolicy", &rabbitmq.PolicyArgs{
			Vhost: guest.Vhost,
			Policy: &rabbitmq.PolicyPolicyArgs{
				Pattern: fooExchange.Name.ApplyT(func(name string) (string, error) {
					return fmt.Sprintf("(^%v$)", name), nil
				}).(pulumi.StringOutput),
				Priority: pulumi.Int(1),
				ApplyTo:  pulumi.String("exchanges"),
				Definition: pulumi.Map{
					"federation-upstream": fooFederationUpstream.Name,
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

## Import

A Federation upstream can be imported using the resource `id` which is composed of `name@vhost`, e.g.

```sh $ pulumi import rabbitmq:index/federationUpstream:FederationUpstream foo foo@test ```

func GetFederationUpstream 

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 

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 

func (*FederationUpstream) ElementType() reflect.Type

func (*FederationUpstream) ToFederationUpstreamOutput 

func (i *FederationUpstream) ToFederationUpstreamOutput() FederationUpstreamOutput

func (*FederationUpstream) ToFederationUpstreamOutputWithContext 

func (i *FederationUpstream) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput

type FederationUpstreamArgs 

type FederationUpstreamArgs struct {
	// The configuration of the federation upstream. The structure is described below.
	Definition FederationUpstreamDefinitionInput
	// The name of the federation upstream.
	Name pulumi.StringPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringInput
}

The set of arguments for constructing a FederationUpstream resource.

func (FederationUpstreamArgs) ElementType 

func (FederationUpstreamArgs) ElementType() reflect.Type

type FederationUpstreamArray 

type FederationUpstreamArray []FederationUpstreamInput

func (FederationUpstreamArray) ElementType 

func (FederationUpstreamArray) ElementType() reflect.Type

func (FederationUpstreamArray) ToFederationUpstreamArrayOutput 

func (i FederationUpstreamArray) ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput

func (FederationUpstreamArray) ToFederationUpstreamArrayOutputWithContext 

func (i FederationUpstreamArray) ToFederationUpstreamArrayOutputWithContext(ctx context.Context) FederationUpstreamArrayOutput

type FederationUpstreamArrayInput 

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 

type FederationUpstreamArrayOutput struct{ *pulumi.OutputState }

func (FederationUpstreamArrayOutput) ElementType 

func (FederationUpstreamArrayOutput) ElementType() reflect.Type

func (FederationUpstreamArrayOutput) Index 

func (o FederationUpstreamArrayOutput) Index(i pulumi.IntInput) FederationUpstreamOutput

func (FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutput 

func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutput() FederationUpstreamArrayOutput

func (FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutputWithContext 

func (o FederationUpstreamArrayOutput) ToFederationUpstreamArrayOutputWithContext(ctx context.Context) FederationUpstreamArrayOutput

type FederationUpstreamDefinition 

type FederationUpstreamDefinition struct {
	// Determines how the link should acknowledge messages. Valid values are `on-confirm`, `on-publish`, and `no-ack`. Default is `on-confirm`.
	AckMode *string `pulumi:"ackMode"`
	// The name of the upstream exchange.
	Exchange *string `pulumi:"exchange"`
	// The expiry time (in milliseconds) after which an upstream queue for a federated exchange may be deleted if a connection to the upstream is lost.
	Expires *int `pulumi:"expires"`
	// Maximum number of federation links that messages can traverse before being dropped. Default is `1`.
	MaxHops *int `pulumi:"maxHops"`
	// The expiry time (in milliseconds) for messages in the upstream queue for a federated exchange (see expires).
	//
	// Applicable to Federated Queues Only
	MessageTtl *int `pulumi:"messageTtl"`
	// Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default is `1000`.
	PrefetchCount *int `pulumi:"prefetchCount"`
	// The name of the upstream queue.
	//
	// Consult the RabbitMQ [Federation Reference](https://www.rabbitmq.com/federation-reference.html) documentation for detailed information and guidance on setting these values.
	Queue *string `pulumi:"queue"`
	// Time in seconds to wait after a network link goes down before attempting reconnection. Default is `5`.
	ReconnectDelay *int `pulumi:"reconnectDelay"`
	// Determines how federation should interact with the validated user-id feature. Default is `false`.
	//
	// Applicable to Federated Exchanges Only
	TrustUserId *bool `pulumi:"trustUserId"`
	// The AMQP URI(s) for the upstream. Note that the URI may contain sensitive information, such as a password.
	Uri string `pulumi:"uri"`
}

type FederationUpstreamDefinitionArgs 

type FederationUpstreamDefinitionArgs struct {
	// Determines how the link should acknowledge messages. Valid values are `on-confirm`, `on-publish`, and `no-ack`. Default is `on-confirm`.
	AckMode pulumi.StringPtrInput `pulumi:"ackMode"`
	// The name of the upstream exchange.
	Exchange pulumi.StringPtrInput `pulumi:"exchange"`
	// The expiry time (in milliseconds) after which an upstream queue for a federated exchange may be deleted if a connection to the upstream is lost.
	Expires pulumi.IntPtrInput `pulumi:"expires"`
	// Maximum number of federation links that messages can traverse before being dropped. Default is `1`.
	MaxHops pulumi.IntPtrInput `pulumi:"maxHops"`
	// The expiry time (in milliseconds) for messages in the upstream queue for a federated exchange (see expires).
	//
	// Applicable to Federated Queues Only
	MessageTtl pulumi.IntPtrInput `pulumi:"messageTtl"`
	// Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default is `1000`.
	PrefetchCount pulumi.IntPtrInput `pulumi:"prefetchCount"`
	// The name of the upstream queue.
	//
	// Consult the RabbitMQ [Federation Reference](https://www.rabbitmq.com/federation-reference.html) documentation for detailed information and guidance on setting these values.
	Queue pulumi.StringPtrInput `pulumi:"queue"`
	// Time in seconds to wait after a network link goes down before attempting reconnection. Default is `5`.
	ReconnectDelay pulumi.IntPtrInput `pulumi:"reconnectDelay"`
	// Determines how federation should interact with the validated user-id feature. Default is `false`.
	//
	// Applicable to Federated Exchanges Only
	TrustUserId pulumi.BoolPtrInput `pulumi:"trustUserId"`
	// The AMQP URI(s) for the upstream. Note that the URI may contain sensitive information, such as a password.
	Uri pulumi.StringInput `pulumi:"uri"`
}

func (FederationUpstreamDefinitionArgs) ElementType 

func (FederationUpstreamDefinitionArgs) ElementType() reflect.Type

func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput 

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput

func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext 

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput

func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput 

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput

func (FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext 

func (i FederationUpstreamDefinitionArgs) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput

type FederationUpstreamDefinitionInput 

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 

type FederationUpstreamDefinitionOutput struct{ *pulumi.OutputState }

func (FederationUpstreamDefinitionOutput) AckMode 

func (o FederationUpstreamDefinitionOutput) AckMode() pulumi.StringPtrOutput

Determines how the link should acknowledge messages. Valid values are `on-confirm`, `on-publish`, and `no-ack`. Default is `on-confirm`.

func (FederationUpstreamDefinitionOutput) ElementType 

func (FederationUpstreamDefinitionOutput) ElementType() reflect.Type

func (FederationUpstreamDefinitionOutput) Exchange 

func (o FederationUpstreamDefinitionOutput) Exchange() pulumi.StringPtrOutput

The name of the upstream exchange.

func (FederationUpstreamDefinitionOutput) Expires 

func (o FederationUpstreamDefinitionOutput) Expires() pulumi.IntPtrOutput

The expiry time (in milliseconds) after which an upstream queue for a federated exchange may be deleted if a connection to the upstream is lost.

func (FederationUpstreamDefinitionOutput) MaxHops 

func (o FederationUpstreamDefinitionOutput) MaxHops() pulumi.IntPtrOutput

Maximum number of federation links that messages can traverse before being dropped. Default is `1`.

func (FederationUpstreamDefinitionOutput) MessageTtl 

func (o FederationUpstreamDefinitionOutput) MessageTtl() pulumi.IntPtrOutput

The expiry time (in milliseconds) for messages in the upstream queue for a federated exchange (see expires).

Applicable to Federated Queues Only

func (FederationUpstreamDefinitionOutput) PrefetchCount 

func (o FederationUpstreamDefinitionOutput) PrefetchCount() pulumi.IntPtrOutput

Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default is `1000`.

func (FederationUpstreamDefinitionOutput) Queue 

func (o FederationUpstreamDefinitionOutput) Queue() pulumi.StringPtrOutput

The name of the upstream queue.

Consult the RabbitMQ [Federation Reference](https://www.rabbitmq.com/federation-reference.html) documentation for detailed information and guidance on setting these values.

func (FederationUpstreamDefinitionOutput) ReconnectDelay 

func (o FederationUpstreamDefinitionOutput) ReconnectDelay() pulumi.IntPtrOutput

Time in seconds to wait after a network link goes down before attempting reconnection. Default is `5`.

func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput 

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutput() FederationUpstreamDefinitionOutput

func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext 

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionOutputWithContext(ctx context.Context) FederationUpstreamDefinitionOutput

func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput 

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput

func (FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext 

func (o FederationUpstreamDefinitionOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput

func (FederationUpstreamDefinitionOutput) TrustUserId 

func (o FederationUpstreamDefinitionOutput) TrustUserId() pulumi.BoolPtrOutput

Determines how federation should interact with the validated user-id feature. Default is `false`.

Applicable to Federated Exchanges Only

func (FederationUpstreamDefinitionOutput) Uri 

func (o FederationUpstreamDefinitionOutput) Uri() pulumi.StringOutput

The AMQP URI(s) for the upstream. Note that the URI may contain sensitive information, such as a password.

type FederationUpstreamDefinitionPtrInput 

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 

func FederationUpstreamDefinitionPtr(v *FederationUpstreamDefinitionArgs) FederationUpstreamDefinitionPtrInput

type FederationUpstreamDefinitionPtrOutput 

type FederationUpstreamDefinitionPtrOutput struct{ *pulumi.OutputState }

func (FederationUpstreamDefinitionPtrOutput) AckMode 

func (o FederationUpstreamDefinitionPtrOutput) AckMode() pulumi.StringPtrOutput

Determines how the link should acknowledge messages. Valid values are `on-confirm`, `on-publish`, and `no-ack`. Default is `on-confirm`.

func (FederationUpstreamDefinitionPtrOutput) Elem 

func (o FederationUpstreamDefinitionPtrOutput) Elem() FederationUpstreamDefinitionOutput

func (FederationUpstreamDefinitionPtrOutput) ElementType 

func (FederationUpstreamDefinitionPtrOutput) ElementType() reflect.Type

func (FederationUpstreamDefinitionPtrOutput) Exchange 

func (o FederationUpstreamDefinitionPtrOutput) Exchange() pulumi.StringPtrOutput

The name of the upstream exchange.

func (FederationUpstreamDefinitionPtrOutput) Expires 

func (o FederationUpstreamDefinitionPtrOutput) Expires() pulumi.IntPtrOutput

The expiry time (in milliseconds) after which an upstream queue for a federated exchange may be deleted if a connection to the upstream is lost.

func (FederationUpstreamDefinitionPtrOutput) MaxHops 

func (o FederationUpstreamDefinitionPtrOutput) MaxHops() pulumi.IntPtrOutput

Maximum number of federation links that messages can traverse before being dropped. Default is `1`.

func (FederationUpstreamDefinitionPtrOutput) MessageTtl 

func (o FederationUpstreamDefinitionPtrOutput) MessageTtl() pulumi.IntPtrOutput

The expiry time (in milliseconds) for messages in the upstream queue for a federated exchange (see expires).

Applicable to Federated Queues Only

func (FederationUpstreamDefinitionPtrOutput) PrefetchCount 

func (o FederationUpstreamDefinitionPtrOutput) PrefetchCount() pulumi.IntPtrOutput

Maximum number of unacknowledged messages that may be in flight over a federation link at one time. Default is `1000`.

func (FederationUpstreamDefinitionPtrOutput) Queue 

func (o FederationUpstreamDefinitionPtrOutput) Queue() pulumi.StringPtrOutput

The name of the upstream queue.

Consult the RabbitMQ [Federation Reference](https://www.rabbitmq.com/federation-reference.html) documentation for detailed information and guidance on setting these values.

func (FederationUpstreamDefinitionPtrOutput) ReconnectDelay 

func (o FederationUpstreamDefinitionPtrOutput) ReconnectDelay() pulumi.IntPtrOutput

Time in seconds to wait after a network link goes down before attempting reconnection. Default is `5`.

func (FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput 

func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutput() FederationUpstreamDefinitionPtrOutput

func (FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext 

func (o FederationUpstreamDefinitionPtrOutput) ToFederationUpstreamDefinitionPtrOutputWithContext(ctx context.Context) FederationUpstreamDefinitionPtrOutput

func (FederationUpstreamDefinitionPtrOutput) TrustUserId 

func (o FederationUpstreamDefinitionPtrOutput) TrustUserId() pulumi.BoolPtrOutput

Determines how federation should interact with the validated user-id feature. Default is `false`.

Applicable to Federated Exchanges Only

func (FederationUpstreamDefinitionPtrOutput) Uri 

func (o FederationUpstreamDefinitionPtrOutput) Uri() pulumi.StringPtrOutput

The AMQP URI(s) for the upstream. Note that the URI may contain sensitive information, such as a password.

type FederationUpstreamInput 

type FederationUpstreamInput interface {
	pulumi.Input

	ToFederationUpstreamOutput() FederationUpstreamOutput
	ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput
}

type FederationUpstreamMap 

type FederationUpstreamMap map[string]FederationUpstreamInput

func (FederationUpstreamMap) ElementType 

func (FederationUpstreamMap) ElementType() reflect.Type

func (FederationUpstreamMap) ToFederationUpstreamMapOutput 

func (i FederationUpstreamMap) ToFederationUpstreamMapOutput() FederationUpstreamMapOutput

func (FederationUpstreamMap) ToFederationUpstreamMapOutputWithContext 

func (i FederationUpstreamMap) ToFederationUpstreamMapOutputWithContext(ctx context.Context) FederationUpstreamMapOutput

type FederationUpstreamMapInput 

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 

type FederationUpstreamMapOutput struct{ *pulumi.OutputState }

func (FederationUpstreamMapOutput) ElementType 

func (FederationUpstreamMapOutput) ElementType() reflect.Type

func (FederationUpstreamMapOutput) MapIndex 

func (o FederationUpstreamMapOutput) MapIndex(k pulumi.StringInput) FederationUpstreamOutput

func (FederationUpstreamMapOutput) ToFederationUpstreamMapOutput 

func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutput() FederationUpstreamMapOutput

func (FederationUpstreamMapOutput) ToFederationUpstreamMapOutputWithContext 

func (o FederationUpstreamMapOutput) ToFederationUpstreamMapOutputWithContext(ctx context.Context) FederationUpstreamMapOutput

type FederationUpstreamOutput 

type FederationUpstreamOutput struct{ *pulumi.OutputState }

func (FederationUpstreamOutput) Component added in v3.3.0 

func (o FederationUpstreamOutput) Component() pulumi.StringOutput

Set to `federation-upstream` by the underlying RabbitMQ provider. You do not set this attribute but will see it in state and plan output.

func (FederationUpstreamOutput) Definition added in v3.3.0 

func (o FederationUpstreamOutput) Definition() FederationUpstreamDefinitionOutput

The configuration of the federation upstream. The structure is described below.

func (FederationUpstreamOutput) ElementType 

func (FederationUpstreamOutput) ElementType() reflect.Type

func (FederationUpstreamOutput) Name added in v3.3.0 

func (o FederationUpstreamOutput) Name() pulumi.StringOutput

The name of the federation upstream.

func (FederationUpstreamOutput) ToFederationUpstreamOutput 

func (o FederationUpstreamOutput) ToFederationUpstreamOutput() FederationUpstreamOutput

func (FederationUpstreamOutput) ToFederationUpstreamOutputWithContext 

func (o FederationUpstreamOutput) ToFederationUpstreamOutputWithContext(ctx context.Context) FederationUpstreamOutput

func (FederationUpstreamOutput) Vhost added in v3.3.0 

func (o FederationUpstreamOutput) Vhost() pulumi.StringOutput

The vhost to create the resource in.

type FederationUpstreamState 

type FederationUpstreamState struct {
	// Set to `federation-upstream` by the underlying RabbitMQ provider. You do not set this attribute but will see it in state and plan output.
	Component pulumi.StringPtrInput
	// The configuration of the federation upstream. The structure is described below.
	Definition FederationUpstreamDefinitionPtrInput
	// The name of the federation upstream.
	Name pulumi.StringPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

func (FederationUpstreamState) ElementType 

func (FederationUpstreamState) ElementType() reflect.Type

type GetExchangeSetting added in v3.3.0 

type GetExchangeSetting struct {
	Arguments  map[string]interface{} `pulumi:"arguments"`
	AutoDelete *bool                  `pulumi:"autoDelete"`
	Durable    *bool                  `pulumi:"durable"`
	Type       string                 `pulumi:"type"`
}

type GetExchangeSettingArgs added in v3.3.0 

type GetExchangeSettingArgs struct {
	Arguments  pulumi.MapInput     `pulumi:"arguments"`
	AutoDelete pulumi.BoolPtrInput `pulumi:"autoDelete"`
	Durable    pulumi.BoolPtrInput `pulumi:"durable"`
	Type       pulumi.StringInput  `pulumi:"type"`
}

func (GetExchangeSettingArgs) ElementType added in v3.3.0 

func (GetExchangeSettingArgs) ElementType() reflect.Type

func (GetExchangeSettingArgs) ToGetExchangeSettingOutput added in v3.3.0 

func (i GetExchangeSettingArgs) ToGetExchangeSettingOutput() GetExchangeSettingOutput

func (GetExchangeSettingArgs) ToGetExchangeSettingOutputWithContext added in v3.3.0 

func (i GetExchangeSettingArgs) ToGetExchangeSettingOutputWithContext(ctx context.Context) GetExchangeSettingOutput

type GetExchangeSettingArray added in v3.3.0 

type GetExchangeSettingArray []GetExchangeSettingInput

func (GetExchangeSettingArray) ElementType added in v3.3.0 

func (GetExchangeSettingArray) ElementType() reflect.Type

func (GetExchangeSettingArray) ToGetExchangeSettingArrayOutput added in v3.3.0 

func (i GetExchangeSettingArray) ToGetExchangeSettingArrayOutput() GetExchangeSettingArrayOutput

func (GetExchangeSettingArray) ToGetExchangeSettingArrayOutputWithContext added in v3.3.0 

func (i GetExchangeSettingArray) ToGetExchangeSettingArrayOutputWithContext(ctx context.Context) GetExchangeSettingArrayOutput

type GetExchangeSettingArrayInput added in v3.3.0 

type GetExchangeSettingArrayInput interface {
	pulumi.Input

	ToGetExchangeSettingArrayOutput() GetExchangeSettingArrayOutput
	ToGetExchangeSettingArrayOutputWithContext(context.Context) GetExchangeSettingArrayOutput
}

GetExchangeSettingArrayInput is an input type that accepts GetExchangeSettingArray and GetExchangeSettingArrayOutput values. You can construct a concrete instance of `GetExchangeSettingArrayInput` via: 

GetExchangeSettingArray{ GetExchangeSettingArgs{...} }

type GetExchangeSettingArrayOutput added in v3.3.0 

type GetExchangeSettingArrayOutput struct{ *pulumi.OutputState }

func (GetExchangeSettingArrayOutput) ElementType added in v3.3.0 

func (GetExchangeSettingArrayOutput) ElementType() reflect.Type

func (GetExchangeSettingArrayOutput) Index added in v3.3.0 

func (o GetExchangeSettingArrayOutput) Index(i pulumi.IntInput) GetExchangeSettingOutput

func (GetExchangeSettingArrayOutput) ToGetExchangeSettingArrayOutput added in v3.3.0 

func (o GetExchangeSettingArrayOutput) ToGetExchangeSettingArrayOutput() GetExchangeSettingArrayOutput

func (GetExchangeSettingArrayOutput) ToGetExchangeSettingArrayOutputWithContext added in v3.3.0 

func (o GetExchangeSettingArrayOutput) ToGetExchangeSettingArrayOutputWithContext(ctx context.Context) GetExchangeSettingArrayOutput

type GetExchangeSettingInput added in v3.3.0 

type GetExchangeSettingInput interface {
	pulumi.Input

	ToGetExchangeSettingOutput() GetExchangeSettingOutput
	ToGetExchangeSettingOutputWithContext(context.Context) GetExchangeSettingOutput
}

GetExchangeSettingInput is an input type that accepts GetExchangeSettingArgs and GetExchangeSettingOutput values. You can construct a concrete instance of `GetExchangeSettingInput` via: 

GetExchangeSettingArgs{...}

type GetExchangeSettingOutput added in v3.3.0 

type GetExchangeSettingOutput struct{ *pulumi.OutputState }

func (GetExchangeSettingOutput) Arguments added in v3.3.0 

func (o GetExchangeSettingOutput) Arguments() pulumi.MapOutput

func (GetExchangeSettingOutput) AutoDelete added in v3.3.0 

func (o GetExchangeSettingOutput) AutoDelete() pulumi.BoolPtrOutput

func (GetExchangeSettingOutput) Durable added in v3.3.0 

func (o GetExchangeSettingOutput) Durable() pulumi.BoolPtrOutput

func (GetExchangeSettingOutput) ElementType added in v3.3.0 

func (GetExchangeSettingOutput) ElementType() reflect.Type

func (GetExchangeSettingOutput) ToGetExchangeSettingOutput added in v3.3.0 

func (o GetExchangeSettingOutput) ToGetExchangeSettingOutput() GetExchangeSettingOutput

func (GetExchangeSettingOutput) ToGetExchangeSettingOutputWithContext added in v3.3.0 

func (o GetExchangeSettingOutput) ToGetExchangeSettingOutputWithContext(ctx context.Context) GetExchangeSettingOutput

func (GetExchangeSettingOutput) Type added in v3.3.0 

func (o GetExchangeSettingOutput) Type() pulumi.StringOutput

type LookupExchangeArgs added in v3.3.0 

type LookupExchangeArgs struct {
	Name  string  `pulumi:"name"`
	Vhost *string `pulumi:"vhost"`
}

A collection of arguments for invoking getExchange.

type LookupExchangeOutputArgs added in v3.3.0 

type LookupExchangeOutputArgs struct {
	Name  pulumi.StringInput    `pulumi:"name"`
	Vhost pulumi.StringPtrInput `pulumi:"vhost"`
}

A collection of arguments for invoking getExchange.

func (LookupExchangeOutputArgs) ElementType added in v3.3.0 

func (LookupExchangeOutputArgs) ElementType() reflect.Type

type LookupExchangeResult added in v3.3.0 

type LookupExchangeResult struct {
	Id       string               `pulumi:"id"`
	Name     string               `pulumi:"name"`
	Settings []GetExchangeSetting `pulumi:"settings"`
	Vhost    *string              `pulumi:"vhost"`
}

A collection of values returned by getExchange.

func LookupExchange added in v3.3.0 

func LookupExchange(ctx *pulumi.Context, args *LookupExchangeArgs, opts ...pulumi.InvokeOption) (*LookupExchangeResult, error)

type LookupExchangeResultOutput added in v3.3.0 

type LookupExchangeResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getExchange.

func LookupExchangeOutput added in v3.3.0 

func LookupExchangeOutput(ctx *pulumi.Context, args LookupExchangeOutputArgs, opts ...pulumi.InvokeOption) LookupExchangeResultOutput

func (LookupExchangeResultOutput) ElementType added in v3.3.0 

func (LookupExchangeResultOutput) ElementType() reflect.Type

func (LookupExchangeResultOutput) Id added in v3.3.0 

func (o LookupExchangeResultOutput) Id() pulumi.StringOutput

func (LookupExchangeResultOutput) Name added in v3.3.0 

func (o LookupExchangeResultOutput) Name() pulumi.StringOutput

func (LookupExchangeResultOutput) Settings added in v3.3.0 

func (o LookupExchangeResultOutput) Settings() GetExchangeSettingArrayOutput

func (LookupExchangeResultOutput) ToLookupExchangeResultOutput added in v3.3.0 

func (o LookupExchangeResultOutput) ToLookupExchangeResultOutput() LookupExchangeResultOutput

func (LookupExchangeResultOutput) ToLookupExchangeResultOutputWithContext added in v3.3.0 

func (o LookupExchangeResultOutput) ToLookupExchangeResultOutputWithContext(ctx context.Context) LookupExchangeResultOutput

func (LookupExchangeResultOutput) Vhost added in v3.3.0 

func (o LookupExchangeResultOutput) Vhost() pulumi.StringPtrOutput

type LookupUserArgs added in v3.3.0 

type LookupUserArgs struct {
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getUser.

type LookupUserOutputArgs added in v3.3.0 

type LookupUserOutputArgs struct {
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getUser.

func (LookupUserOutputArgs) ElementType added in v3.3.0 

func (LookupUserOutputArgs) ElementType() reflect.Type

type LookupUserResult added in v3.3.0 

type LookupUserResult struct {
	Id   string   `pulumi:"id"`
	Name string   `pulumi:"name"`
	Tags []string `pulumi:"tags"`
}

A collection of values returned by getUser.

func LookupUser added in v3.3.0 

func LookupUser(ctx *pulumi.Context, args *LookupUserArgs, opts ...pulumi.InvokeOption) (*LookupUserResult, error)

type LookupUserResultOutput added in v3.3.0 

type LookupUserResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getUser.

func LookupUserOutput added in v3.3.0 

func LookupUserOutput(ctx *pulumi.Context, args LookupUserOutputArgs, opts ...pulumi.InvokeOption) LookupUserResultOutput

func (LookupUserResultOutput) ElementType added in v3.3.0 

func (LookupUserResultOutput) ElementType() reflect.Type

func (LookupUserResultOutput) Id added in v3.3.0 

func (o LookupUserResultOutput) Id() pulumi.StringOutput

func (LookupUserResultOutput) Name added in v3.3.0 

func (o LookupUserResultOutput) Name() pulumi.StringOutput

func (LookupUserResultOutput) Tags added in v3.3.0 

func (o LookupUserResultOutput) Tags() pulumi.StringArrayOutput

func (LookupUserResultOutput) ToLookupUserResultOutput added in v3.3.0 

func (o LookupUserResultOutput) ToLookupUserResultOutput() LookupUserResultOutput

func (LookupUserResultOutput) ToLookupUserResultOutputWithContext added in v3.3.0 

func (o LookupUserResultOutput) ToLookupUserResultOutputWithContext(ctx context.Context) LookupUserResultOutput

type LookupVHostArgs added in v3.3.0 

type LookupVHostArgs struct {
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getVHost.

type LookupVHostOutputArgs added in v3.3.0 

type LookupVHostOutputArgs struct {
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getVHost.

func (LookupVHostOutputArgs) ElementType added in v3.3.0 

func (LookupVHostOutputArgs) ElementType() reflect.Type

type LookupVHostResult added in v3.3.0 

type LookupVHostResult struct {
	Id   string `pulumi:"id"`
	Name string `pulumi:"name"`
}

A collection of values returned by getVHost.

func LookupVHost added in v3.3.0 

func LookupVHost(ctx *pulumi.Context, args *LookupVHostArgs, opts ...pulumi.InvokeOption) (*LookupVHostResult, error)

type LookupVHostResultOutput added in v3.3.0 

type LookupVHostResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getVHost.

func LookupVHostOutput added in v3.3.0 

func LookupVHostOutput(ctx *pulumi.Context, args LookupVHostOutputArgs, opts ...pulumi.InvokeOption) LookupVHostResultOutput

func (LookupVHostResultOutput) ElementType added in v3.3.0 

func (LookupVHostResultOutput) ElementType() reflect.Type

func (LookupVHostResultOutput) Id added in v3.3.0 

func (o LookupVHostResultOutput) Id() pulumi.StringOutput

func (LookupVHostResultOutput) Name added in v3.3.0 

func (o LookupVHostResultOutput) Name() pulumi.StringOutput

func (LookupVHostResultOutput) ToLookupVHostResultOutput added in v3.3.0 

func (o LookupVHostResultOutput) ToLookupVHostResultOutput() LookupVHostResultOutput

func (LookupVHostResultOutput) ToLookupVHostResultOutputWithContext added in v3.3.0 

func (o LookupVHostResultOutput) ToLookupVHostResultOutputWithContext(ctx context.Context) LookupVHostResultOutput

type OperatorPolicy added in v3.3.0 

type OperatorPolicy struct {
	pulumi.CustomResourceState

	// The name of the operator policy.
	Name pulumi.StringOutput `pulumi:"name"`
	// The settings of the operator policy. The structure is
	// described below.
	Policy OperatorPolicyPolicyOutput `pulumi:"policy"`
	// The vhost to create the resource in.
	Vhost pulumi.StringOutput `pulumi:"vhost"`
}

The “OperatorPolicy“ resource creates and manages operator policies for queues.

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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.NewOperatorPolicy(ctx, "testOperatorPolicy", &rabbitmq.OperatorPolicyArgs{
			Policy: &rabbitmq.OperatorPolicyPolicyArgs{
				ApplyTo: pulumi.String("queues"),
				Definition: pulumi.Map{
					"expires":     pulumi.Any(1800000),
					"message-ttl": pulumi.Any(3600000),
				},
				Pattern:  pulumi.String(".*"),
				Priority: pulumi.Int(0),
			},
			Vhost: guest.Vhost,
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

## Import

Operator policies can be imported using the `id` which is composed of `name@vhost`.

E.g.

```sh $ pulumi import rabbitmq:index/operatorPolicy:OperatorPolicy test name@vhost ```

func GetOperatorPolicy added in v3.3.0 

func GetOperatorPolicy(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *OperatorPolicyState, opts ...pulumi.ResourceOption) (*OperatorPolicy, error)

GetOperatorPolicy gets an existing OperatorPolicy 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 NewOperatorPolicy added in v3.3.0 

func NewOperatorPolicy(ctx *pulumi.Context,
	name string, args *OperatorPolicyArgs, opts ...pulumi.ResourceOption) (*OperatorPolicy, error)

NewOperatorPolicy registers a new resource with the given unique name, arguments, and options.

func (*OperatorPolicy) ElementType added in v3.3.0 

func (*OperatorPolicy) ElementType() reflect.Type

func (*OperatorPolicy) ToOperatorPolicyOutput added in v3.3.0 

func (i *OperatorPolicy) ToOperatorPolicyOutput() OperatorPolicyOutput

func (*OperatorPolicy) ToOperatorPolicyOutputWithContext added in v3.3.0 

func (i *OperatorPolicy) ToOperatorPolicyOutputWithContext(ctx context.Context) OperatorPolicyOutput

type OperatorPolicyArgs added in v3.3.0 

type OperatorPolicyArgs struct {
	// The name of the operator policy.
	Name pulumi.StringPtrInput
	// The settings of the operator policy. The structure is
	// described below.
	Policy OperatorPolicyPolicyInput
	// The vhost to create the resource in.
	Vhost pulumi.StringInput
}

The set of arguments for constructing a OperatorPolicy resource.

func (OperatorPolicyArgs) ElementType added in v3.3.0 

func (OperatorPolicyArgs) ElementType() reflect.Type

type OperatorPolicyArray added in v3.3.0 

type OperatorPolicyArray []OperatorPolicyInput

func (OperatorPolicyArray) ElementType added in v3.3.0 

func (OperatorPolicyArray) ElementType() reflect.Type

func (OperatorPolicyArray) ToOperatorPolicyArrayOutput added in v3.3.0 

func (i OperatorPolicyArray) ToOperatorPolicyArrayOutput() OperatorPolicyArrayOutput

func (OperatorPolicyArray) ToOperatorPolicyArrayOutputWithContext added in v3.3.0 

func (i OperatorPolicyArray) ToOperatorPolicyArrayOutputWithContext(ctx context.Context) OperatorPolicyArrayOutput

type OperatorPolicyArrayInput added in v3.3.0 

type OperatorPolicyArrayInput interface {
	pulumi.Input

	ToOperatorPolicyArrayOutput() OperatorPolicyArrayOutput
	ToOperatorPolicyArrayOutputWithContext(context.Context) OperatorPolicyArrayOutput
}

OperatorPolicyArrayInput is an input type that accepts OperatorPolicyArray and OperatorPolicyArrayOutput values. You can construct a concrete instance of `OperatorPolicyArrayInput` via: 

OperatorPolicyArray{ OperatorPolicyArgs{...} }

type OperatorPolicyArrayOutput added in v3.3.0 

type OperatorPolicyArrayOutput struct{ *pulumi.OutputState }

func (OperatorPolicyArrayOutput) ElementType added in v3.3.0 

func (OperatorPolicyArrayOutput) ElementType() reflect.Type

func (OperatorPolicyArrayOutput) Index added in v3.3.0 

func (o OperatorPolicyArrayOutput) Index(i pulumi.IntInput) OperatorPolicyOutput

func (OperatorPolicyArrayOutput) ToOperatorPolicyArrayOutput added in v3.3.0 

func (o OperatorPolicyArrayOutput) ToOperatorPolicyArrayOutput() OperatorPolicyArrayOutput

func (OperatorPolicyArrayOutput) ToOperatorPolicyArrayOutputWithContext added in v3.3.0 

func (o OperatorPolicyArrayOutput) ToOperatorPolicyArrayOutputWithContext(ctx context.Context) OperatorPolicyArrayOutput

type OperatorPolicyInput added in v3.3.0 

type OperatorPolicyInput interface {
	pulumi.Input

	ToOperatorPolicyOutput() OperatorPolicyOutput
	ToOperatorPolicyOutputWithContext(ctx context.Context) OperatorPolicyOutput
}

type OperatorPolicyMap added in v3.3.0 

type OperatorPolicyMap map[string]OperatorPolicyInput

func (OperatorPolicyMap) ElementType added in v3.3.0 

func (OperatorPolicyMap) ElementType() reflect.Type

func (OperatorPolicyMap) ToOperatorPolicyMapOutput added in v3.3.0 

func (i OperatorPolicyMap) ToOperatorPolicyMapOutput() OperatorPolicyMapOutput

func (OperatorPolicyMap) ToOperatorPolicyMapOutputWithContext added in v3.3.0 

func (i OperatorPolicyMap) ToOperatorPolicyMapOutputWithContext(ctx context.Context) OperatorPolicyMapOutput

type OperatorPolicyMapInput added in v3.3.0 

type OperatorPolicyMapInput interface {
	pulumi.Input

	ToOperatorPolicyMapOutput() OperatorPolicyMapOutput
	ToOperatorPolicyMapOutputWithContext(context.Context) OperatorPolicyMapOutput
}

OperatorPolicyMapInput is an input type that accepts OperatorPolicyMap and OperatorPolicyMapOutput values. You can construct a concrete instance of `OperatorPolicyMapInput` via: 

OperatorPolicyMap{ "key": OperatorPolicyArgs{...} }

type OperatorPolicyMapOutput added in v3.3.0 

type OperatorPolicyMapOutput struct{ *pulumi.OutputState }

func (OperatorPolicyMapOutput) ElementType added in v3.3.0 

func (OperatorPolicyMapOutput) ElementType() reflect.Type

func (OperatorPolicyMapOutput) MapIndex added in v3.3.0 

func (o OperatorPolicyMapOutput) MapIndex(k pulumi.StringInput) OperatorPolicyOutput

func (OperatorPolicyMapOutput) ToOperatorPolicyMapOutput added in v3.3.0 

func (o OperatorPolicyMapOutput) ToOperatorPolicyMapOutput() OperatorPolicyMapOutput

func (OperatorPolicyMapOutput) ToOperatorPolicyMapOutputWithContext added in v3.3.0 

func (o OperatorPolicyMapOutput) ToOperatorPolicyMapOutputWithContext(ctx context.Context) OperatorPolicyMapOutput

type OperatorPolicyOutput added in v3.3.0 

type OperatorPolicyOutput struct{ *pulumi.OutputState }

func (OperatorPolicyOutput) ElementType added in v3.3.0 

func (OperatorPolicyOutput) ElementType() reflect.Type

func (OperatorPolicyOutput) Name added in v3.3.0 

func (o OperatorPolicyOutput) Name() pulumi.StringOutput

The name of the operator policy.

func (OperatorPolicyOutput) Policy added in v3.3.0 

func (o OperatorPolicyOutput) Policy() OperatorPolicyPolicyOutput

The settings of the operator policy. The structure is described below.

func (OperatorPolicyOutput) ToOperatorPolicyOutput added in v3.3.0 

func (o OperatorPolicyOutput) ToOperatorPolicyOutput() OperatorPolicyOutput

func (OperatorPolicyOutput) ToOperatorPolicyOutputWithContext added in v3.3.0 

func (o OperatorPolicyOutput) ToOperatorPolicyOutputWithContext(ctx context.Context) OperatorPolicyOutput

func (OperatorPolicyOutput) Vhost added in v3.3.0 

func (o OperatorPolicyOutput) Vhost() pulumi.StringOutput

The vhost to create the resource in.

type OperatorPolicyPolicy added in v3.3.0 

type OperatorPolicyPolicy struct {
	// Can be "queues".
	ApplyTo string `pulumi:"applyTo"`
	// Key/value pairs of the operator 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 OperatorPolicyPolicyArgs added in v3.3.0 

type OperatorPolicyPolicyArgs struct {
	// Can be "queues".
	ApplyTo pulumi.StringInput `pulumi:"applyTo"`
	// Key/value pairs of the operator 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 (OperatorPolicyPolicyArgs) ElementType added in v3.3.0 

func (OperatorPolicyPolicyArgs) ElementType() reflect.Type

func (OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyOutput added in v3.3.0 

func (i OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyOutput() OperatorPolicyPolicyOutput

func (OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyOutputWithContext added in v3.3.0 

func (i OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyOutputWithContext(ctx context.Context) OperatorPolicyPolicyOutput

func (OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyPtrOutput added in v3.3.0 

func (i OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyPtrOutput() OperatorPolicyPolicyPtrOutput

func (OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyPtrOutputWithContext added in v3.3.0 

func (i OperatorPolicyPolicyArgs) ToOperatorPolicyPolicyPtrOutputWithContext(ctx context.Context) OperatorPolicyPolicyPtrOutput

type OperatorPolicyPolicyInput added in v3.3.0 

type OperatorPolicyPolicyInput interface {
	pulumi.Input

	ToOperatorPolicyPolicyOutput() OperatorPolicyPolicyOutput
	ToOperatorPolicyPolicyOutputWithContext(context.Context) OperatorPolicyPolicyOutput
}

OperatorPolicyPolicyInput is an input type that accepts OperatorPolicyPolicyArgs and OperatorPolicyPolicyOutput values. You can construct a concrete instance of `OperatorPolicyPolicyInput` via: 

OperatorPolicyPolicyArgs{...}

type OperatorPolicyPolicyOutput added in v3.3.0 

type OperatorPolicyPolicyOutput struct{ *pulumi.OutputState }

func (OperatorPolicyPolicyOutput) ApplyTo added in v3.3.0 

func (o OperatorPolicyPolicyOutput) ApplyTo() pulumi.StringOutput

Can be "queues".

func (OperatorPolicyPolicyOutput) Definition added in v3.3.0 

func (o OperatorPolicyPolicyOutput) Definition() pulumi.MapOutput

Key/value pairs of the operator policy definition. See the RabbitMQ documentation for definition references and examples.

func (OperatorPolicyPolicyOutput) ElementType added in v3.3.0 

func (OperatorPolicyPolicyOutput) ElementType() reflect.Type

func (OperatorPolicyPolicyOutput) Pattern added in v3.3.0 

func (o OperatorPolicyPolicyOutput) Pattern() pulumi.StringOutput

A pattern to match an exchange or queue name.

func (OperatorPolicyPolicyOutput) Priority added in v3.3.0 

func (o OperatorPolicyPolicyOutput) Priority() pulumi.IntOutput

The policy with the greater priority is applied first.

func (OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyOutput added in v3.3.0 

func (o OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyOutput() OperatorPolicyPolicyOutput

func (OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyOutputWithContext added in v3.3.0 

func (o OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyOutputWithContext(ctx context.Context) OperatorPolicyPolicyOutput

func (OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyPtrOutput added in v3.3.0 

func (o OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyPtrOutput() OperatorPolicyPolicyPtrOutput

func (OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyPtrOutputWithContext added in v3.3.0 

func (o OperatorPolicyPolicyOutput) ToOperatorPolicyPolicyPtrOutputWithContext(ctx context.Context) OperatorPolicyPolicyPtrOutput

type OperatorPolicyPolicyPtrInput added in v3.3.0 

type OperatorPolicyPolicyPtrInput interface {
	pulumi.Input

	ToOperatorPolicyPolicyPtrOutput() OperatorPolicyPolicyPtrOutput
	ToOperatorPolicyPolicyPtrOutputWithContext(context.Context) OperatorPolicyPolicyPtrOutput
}

OperatorPolicyPolicyPtrInput is an input type that accepts OperatorPolicyPolicyArgs, OperatorPolicyPolicyPtr and OperatorPolicyPolicyPtrOutput values. You can construct a concrete instance of `OperatorPolicyPolicyPtrInput` via: 

        OperatorPolicyPolicyArgs{...}

or:

        nil

func OperatorPolicyPolicyPtr added in v3.3.0 

func OperatorPolicyPolicyPtr(v *OperatorPolicyPolicyArgs) OperatorPolicyPolicyPtrInput

type OperatorPolicyPolicyPtrOutput added in v3.3.0 

type OperatorPolicyPolicyPtrOutput struct{ *pulumi.OutputState }

func (OperatorPolicyPolicyPtrOutput) ApplyTo added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) ApplyTo() pulumi.StringPtrOutput

Can be "queues".

func (OperatorPolicyPolicyPtrOutput) Definition added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) Definition() pulumi.MapOutput

Key/value pairs of the operator policy definition. See the RabbitMQ documentation for definition references and examples.

func (OperatorPolicyPolicyPtrOutput) Elem added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) Elem() OperatorPolicyPolicyOutput

func (OperatorPolicyPolicyPtrOutput) ElementType added in v3.3.0 

func (OperatorPolicyPolicyPtrOutput) ElementType() reflect.Type

func (OperatorPolicyPolicyPtrOutput) Pattern added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) Pattern() pulumi.StringPtrOutput

A pattern to match an exchange or queue name.

func (OperatorPolicyPolicyPtrOutput) Priority added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) Priority() pulumi.IntPtrOutput

The policy with the greater priority is applied first.

func (OperatorPolicyPolicyPtrOutput) ToOperatorPolicyPolicyPtrOutput added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) ToOperatorPolicyPolicyPtrOutput() OperatorPolicyPolicyPtrOutput

func (OperatorPolicyPolicyPtrOutput) ToOperatorPolicyPolicyPtrOutputWithContext added in v3.3.0 

func (o OperatorPolicyPolicyPtrOutput) ToOperatorPolicyPolicyPtrOutputWithContext(ctx context.Context) OperatorPolicyPolicyPtrOutput

type OperatorPolicyState added in v3.3.0 

type OperatorPolicyState struct {
	// The name of the operator policy.
	Name pulumi.StringPtrInput
	// The settings of the operator policy. The structure is
	// described below.
	Policy OperatorPolicyPolicyPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

func (OperatorPolicyState) ElementType added in v3.3.0 

func (OperatorPolicyState) 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

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*Permissions) ElementType() reflect.Type

func (*Permissions) ToPermissionsOutput 

func (i *Permissions) ToPermissionsOutput() PermissionsOutput

func (*Permissions) ToPermissionsOutputWithContext 

func (i *Permissions) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput

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 

type PermissionsArray []PermissionsInput

func (PermissionsArray) ElementType 

func (PermissionsArray) ElementType() reflect.Type

func (PermissionsArray) ToPermissionsArrayOutput 

func (i PermissionsArray) ToPermissionsArrayOutput() PermissionsArrayOutput

func (PermissionsArray) ToPermissionsArrayOutputWithContext 

func (i PermissionsArray) ToPermissionsArrayOutputWithContext(ctx context.Context) PermissionsArrayOutput

type PermissionsArrayInput 

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 

type PermissionsArrayOutput struct{ *pulumi.OutputState }

func (PermissionsArrayOutput) ElementType 

func (PermissionsArrayOutput) ElementType() reflect.Type

func (PermissionsArrayOutput) Index 

func (o PermissionsArrayOutput) Index(i pulumi.IntInput) PermissionsOutput

func (PermissionsArrayOutput) ToPermissionsArrayOutput 

func (o PermissionsArrayOutput) ToPermissionsArrayOutput() PermissionsArrayOutput

func (PermissionsArrayOutput) ToPermissionsArrayOutputWithContext 

func (o PermissionsArrayOutput) ToPermissionsArrayOutputWithContext(ctx context.Context) PermissionsArrayOutput

type PermissionsInput 

type PermissionsInput interface {
	pulumi.Input

	ToPermissionsOutput() PermissionsOutput
	ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput
}

type PermissionsMap 

type PermissionsMap map[string]PermissionsInput

func (PermissionsMap) ElementType 

func (PermissionsMap) ElementType() reflect.Type

func (PermissionsMap) ToPermissionsMapOutput 

func (i PermissionsMap) ToPermissionsMapOutput() PermissionsMapOutput

func (PermissionsMap) ToPermissionsMapOutputWithContext 

func (i PermissionsMap) ToPermissionsMapOutputWithContext(ctx context.Context) PermissionsMapOutput

type PermissionsMapInput 

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 

type PermissionsMapOutput struct{ *pulumi.OutputState }

func (PermissionsMapOutput) ElementType 

func (PermissionsMapOutput) ElementType() reflect.Type

func (PermissionsMapOutput) MapIndex 

func (o PermissionsMapOutput) MapIndex(k pulumi.StringInput) PermissionsOutput

func (PermissionsMapOutput) ToPermissionsMapOutput 

func (o PermissionsMapOutput) ToPermissionsMapOutput() PermissionsMapOutput

func (PermissionsMapOutput) ToPermissionsMapOutputWithContext 

func (o PermissionsMapOutput) ToPermissionsMapOutputWithContext(ctx context.Context) PermissionsMapOutput

type PermissionsOutput 

type PermissionsOutput struct{ *pulumi.OutputState }

func (PermissionsOutput) ElementType 

func (PermissionsOutput) ElementType() reflect.Type

func (PermissionsOutput) Permissions added in v3.3.0 

func (o PermissionsOutput) Permissions() PermissionsPermissionsOutput

The settings of the permissions. The structure is described below.

func (PermissionsOutput) ToPermissionsOutput 

func (o PermissionsOutput) ToPermissionsOutput() PermissionsOutput

func (PermissionsOutput) ToPermissionsOutputWithContext 

func (o PermissionsOutput) ToPermissionsOutputWithContext(ctx context.Context) PermissionsOutput

func (PermissionsOutput) User added in v3.3.0 

func (o PermissionsOutput) User() pulumi.StringOutput

The user to apply the permissions to.

func (PermissionsOutput) Vhost added in v3.3.0 

func (o PermissionsOutput) Vhost() pulumi.StringPtrOutput

The vhost to create the resource in.

type PermissionsPermissions 

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

type PermissionsPermissionsArgs 

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

func (PermissionsPermissionsArgs) ElementType 

func (PermissionsPermissionsArgs) ElementType() reflect.Type

func (PermissionsPermissionsArgs) ToPermissionsPermissionsOutput 

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput

func (PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext 

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput

func (PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput 

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput

func (PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext 

func (i PermissionsPermissionsArgs) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput

type PermissionsPermissionsInput 

type PermissionsPermissionsInput interface {
	pulumi.Input

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

PermissionsPermissionsInput is an input type that accepts PermissionsPermissionsArgs and PermissionsPermissionsOutput values. You can construct a concrete instance of `PermissionsPermissionsInput` via: 

PermissionsPermissionsArgs{...}

type PermissionsPermissionsOutput 

type PermissionsPermissionsOutput struct{ *pulumi.OutputState }

func (PermissionsPermissionsOutput) Configure 

func (o PermissionsPermissionsOutput) Configure() pulumi.StringOutput

The "configure" ACL.

func (PermissionsPermissionsOutput) ElementType 

func (PermissionsPermissionsOutput) ElementType() reflect.Type

func (PermissionsPermissionsOutput) Read 

func (o PermissionsPermissionsOutput) Read() pulumi.StringOutput

The "read" ACL.

func (PermissionsPermissionsOutput) ToPermissionsPermissionsOutput 

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutput() PermissionsPermissionsOutput

func (PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext 

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsOutputWithContext(ctx context.Context) PermissionsPermissionsOutput

func (PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput 

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput

func (PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext 

func (o PermissionsPermissionsOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput

func (PermissionsPermissionsOutput) Write 

func (o PermissionsPermissionsOutput) Write() pulumi.StringOutput

The "write" ACL.

type PermissionsPermissionsPtrInput 

type PermissionsPermissionsPtrInput interface {
	pulumi.Input

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

PermissionsPermissionsPtrInput is an input type that accepts PermissionsPermissionsArgs, PermissionsPermissionsPtr and PermissionsPermissionsPtrOutput values. You can construct a concrete instance of `PermissionsPermissionsPtrInput` via: 

        PermissionsPermissionsArgs{...}

or:

        nil

func PermissionsPermissionsPtr 

func PermissionsPermissionsPtr(v *PermissionsPermissionsArgs) PermissionsPermissionsPtrInput

type PermissionsPermissionsPtrOutput 

type PermissionsPermissionsPtrOutput struct{ *pulumi.OutputState }

func (PermissionsPermissionsPtrOutput) Configure 

func (o PermissionsPermissionsPtrOutput) Configure() pulumi.StringPtrOutput

The "configure" ACL.

func (PermissionsPermissionsPtrOutput) Elem 

func (o PermissionsPermissionsPtrOutput) Elem() PermissionsPermissionsOutput

func (PermissionsPermissionsPtrOutput) ElementType 

func (PermissionsPermissionsPtrOutput) ElementType() reflect.Type

func (PermissionsPermissionsPtrOutput) Read 

func (o PermissionsPermissionsPtrOutput) Read() pulumi.StringPtrOutput

The "read" ACL.

func (PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput 

func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutput() PermissionsPermissionsPtrOutput

func (PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext 

func (o PermissionsPermissionsPtrOutput) ToPermissionsPermissionsPtrOutputWithContext(ctx context.Context) PermissionsPermissionsPtrOutput

func (PermissionsPermissionsPtrOutput) Write 

func (o PermissionsPermissionsPtrOutput) Write() pulumi.StringPtrOutput

The "write" ACL.

type PermissionsState 

type PermissionsState struct {
	// The settings of the permissions. The structure is
	// described below.
	Permissions PermissionsPermissionsPtrInput
	// The user to apply the permissions to.
	User pulumi.StringPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

func (PermissionsState) ElementType 

func (PermissionsState) ElementType() reflect.Type

type Policy 

type Policy struct {
	pulumi.CustomResourceState

	// The name of the policy.
	Name pulumi.StringOutput `pulumi:"name"`
	// The settings of the policy. The structure is
	// described below.
	Policy PolicyPolicyOutput `pulumi:"policy"`
	// The vhost to create the resource in.
	Vhost pulumi.StringOutput `pulumi:"vhost"`
}

The “Policy“ resource creates and manages policies for exchanges and queues.

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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.Map{
					"ha-mode": pulumi.Any("all"),
				},
				Pattern:  pulumi.String(".*"),
				Priority: pulumi.Int(0),
			},
			Vhost: guest.Vhost,
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*Policy) ElementType() reflect.Type

func (*Policy) ToPolicyOutput 

func (i *Policy) ToPolicyOutput() PolicyOutput

func (*Policy) ToPolicyOutputWithContext 

func (i *Policy) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput

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 

type PolicyArray []PolicyInput

func (PolicyArray) ElementType 

func (PolicyArray) ElementType() reflect.Type

func (PolicyArray) ToPolicyArrayOutput 

func (i PolicyArray) ToPolicyArrayOutput() PolicyArrayOutput

func (PolicyArray) ToPolicyArrayOutputWithContext 

func (i PolicyArray) ToPolicyArrayOutputWithContext(ctx context.Context) PolicyArrayOutput

type PolicyArrayInput 

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 

type PolicyArrayOutput struct{ *pulumi.OutputState }

func (PolicyArrayOutput) ElementType 

func (PolicyArrayOutput) ElementType() reflect.Type

func (PolicyArrayOutput) Index 

func (o PolicyArrayOutput) Index(i pulumi.IntInput) PolicyOutput

func (PolicyArrayOutput) ToPolicyArrayOutput 

func (o PolicyArrayOutput) ToPolicyArrayOutput() PolicyArrayOutput

func (PolicyArrayOutput) ToPolicyArrayOutputWithContext 

func (o PolicyArrayOutput) ToPolicyArrayOutputWithContext(ctx context.Context) PolicyArrayOutput

type PolicyInput 

type PolicyInput interface {
	pulumi.Input

	ToPolicyOutput() PolicyOutput
	ToPolicyOutputWithContext(ctx context.Context) PolicyOutput
}

type PolicyMap 

type PolicyMap map[string]PolicyInput

func (PolicyMap) ElementType 

func (PolicyMap) ElementType() reflect.Type

func (PolicyMap) ToPolicyMapOutput 

func (i PolicyMap) ToPolicyMapOutput() PolicyMapOutput

func (PolicyMap) ToPolicyMapOutputWithContext 

func (i PolicyMap) ToPolicyMapOutputWithContext(ctx context.Context) PolicyMapOutput

type PolicyMapInput 

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 

type PolicyMapOutput struct{ *pulumi.OutputState }

func (PolicyMapOutput) ElementType 

func (PolicyMapOutput) ElementType() reflect.Type

func (PolicyMapOutput) MapIndex 

func (o PolicyMapOutput) MapIndex(k pulumi.StringInput) PolicyOutput

func (PolicyMapOutput) ToPolicyMapOutput 

func (o PolicyMapOutput) ToPolicyMapOutput() PolicyMapOutput

func (PolicyMapOutput) ToPolicyMapOutputWithContext 

func (o PolicyMapOutput) ToPolicyMapOutputWithContext(ctx context.Context) PolicyMapOutput

type PolicyOutput 

type PolicyOutput struct{ *pulumi.OutputState }

func (PolicyOutput) ElementType 

func (PolicyOutput) ElementType() reflect.Type

func (PolicyOutput) Name added in v3.3.0 

func (o PolicyOutput) Name() pulumi.StringOutput

The name of the policy.

func (PolicyOutput) Policy added in v3.3.0 

func (o PolicyOutput) Policy() PolicyPolicyOutput

The settings of the policy. The structure is described below.

func (PolicyOutput) ToPolicyOutput 

func (o PolicyOutput) ToPolicyOutput() PolicyOutput

func (PolicyOutput) ToPolicyOutputWithContext 

func (o PolicyOutput) ToPolicyOutputWithContext(ctx context.Context) PolicyOutput

func (PolicyOutput) Vhost added in v3.3.0 

func (o PolicyOutput) Vhost() pulumi.StringOutput

The vhost to create the resource in.

type PolicyPolicy 

type PolicyPolicy struct {
	// Can either be "exchanges", "queues", or "all".
	ApplyTo string `pulumi:"applyTo"`
	// Key/value pairs of the policy definition. See the
	// RabbitMQ documentation for definition references and examples.
	Definition map[string]interface{} `pulumi:"definition"`
	// A pattern to match an exchange or queue name.
	Pattern string `pulumi:"pattern"`
	// The policy with the greater priority is applied first.
	Priority int `pulumi:"priority"`
}

type PolicyPolicyArgs 

type PolicyPolicyArgs struct {
	// Can either be "exchanges", "queues", or "all".
	ApplyTo pulumi.StringInput `pulumi:"applyTo"`
	// Key/value pairs of the policy definition. See the
	// RabbitMQ documentation for definition references and examples.
	Definition pulumi.MapInput `pulumi:"definition"`
	// A pattern to match an exchange or queue name.
	Pattern pulumi.StringInput `pulumi:"pattern"`
	// The policy with the greater priority is applied first.
	Priority pulumi.IntInput `pulumi:"priority"`
}

func (PolicyPolicyArgs) ElementType 

func (PolicyPolicyArgs) ElementType() reflect.Type

func (PolicyPolicyArgs) ToPolicyPolicyOutput 

func (i PolicyPolicyArgs) ToPolicyPolicyOutput() PolicyPolicyOutput

func (PolicyPolicyArgs) ToPolicyPolicyOutputWithContext 

func (i PolicyPolicyArgs) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput

func (PolicyPolicyArgs) ToPolicyPolicyPtrOutput 

func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput

func (PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext 

func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput

type PolicyPolicyInput 

type PolicyPolicyInput interface {
	pulumi.Input

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

PolicyPolicyInput is an input type that accepts PolicyPolicyArgs and PolicyPolicyOutput values. You can construct a concrete instance of `PolicyPolicyInput` via: 

PolicyPolicyArgs{...}

type PolicyPolicyOutput 

type PolicyPolicyOutput struct{ *pulumi.OutputState }

func (PolicyPolicyOutput) ApplyTo 

func (o PolicyPolicyOutput) ApplyTo() pulumi.StringOutput

Can either be "exchanges", "queues", or "all".

func (PolicyPolicyOutput) Definition 

func (o PolicyPolicyOutput) Definition() pulumi.MapOutput

Key/value pairs of the policy definition. See the RabbitMQ documentation for definition references and examples.

func (PolicyPolicyOutput) ElementType 

func (PolicyPolicyOutput) ElementType() reflect.Type

func (PolicyPolicyOutput) Pattern 

func (o PolicyPolicyOutput) Pattern() pulumi.StringOutput

A pattern to match an exchange or queue name.

func (PolicyPolicyOutput) Priority 

func (o PolicyPolicyOutput) Priority() pulumi.IntOutput

The policy with the greater priority is applied first.

func (PolicyPolicyOutput) ToPolicyPolicyOutput 

func (o PolicyPolicyOutput) ToPolicyPolicyOutput() PolicyPolicyOutput

func (PolicyPolicyOutput) ToPolicyPolicyOutputWithContext 

func (o PolicyPolicyOutput) ToPolicyPolicyOutputWithContext(ctx context.Context) PolicyPolicyOutput

func (PolicyPolicyOutput) ToPolicyPolicyPtrOutput 

func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput

func (PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext 

func (o PolicyPolicyOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput

type PolicyPolicyPtrInput 

type PolicyPolicyPtrInput interface {
	pulumi.Input

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

PolicyPolicyPtrInput is an input type that accepts PolicyPolicyArgs, PolicyPolicyPtr and PolicyPolicyPtrOutput values. You can construct a concrete instance of `PolicyPolicyPtrInput` via: 

        PolicyPolicyArgs{...}

or:

        nil

func PolicyPolicyPtr 

func PolicyPolicyPtr(v *PolicyPolicyArgs) PolicyPolicyPtrInput

type PolicyPolicyPtrOutput 

type PolicyPolicyPtrOutput struct{ *pulumi.OutputState }

func (PolicyPolicyPtrOutput) ApplyTo 

func (o PolicyPolicyPtrOutput) ApplyTo() pulumi.StringPtrOutput

Can either be "exchanges", "queues", or "all".

func (PolicyPolicyPtrOutput) Definition 

func (o PolicyPolicyPtrOutput) Definition() pulumi.MapOutput

Key/value pairs of the policy definition. See the RabbitMQ documentation for definition references and examples.

func (PolicyPolicyPtrOutput) Elem 

func (o PolicyPolicyPtrOutput) Elem() PolicyPolicyOutput

func (PolicyPolicyPtrOutput) ElementType 

func (PolicyPolicyPtrOutput) ElementType() reflect.Type

func (PolicyPolicyPtrOutput) Pattern 

func (o PolicyPolicyPtrOutput) Pattern() pulumi.StringPtrOutput

A pattern to match an exchange or queue name.

func (PolicyPolicyPtrOutput) Priority 

func (o PolicyPolicyPtrOutput) Priority() pulumi.IntPtrOutput

The policy with the greater priority is applied first.

func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput 

func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput

func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext 

func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext(ctx context.Context) PolicyPolicyPtrOutput

type PolicyState 

type PolicyState struct {
	// The name of the policy.
	Name pulumi.StringPtrInput
	// The settings of the policy. The structure is
	// described below.
	Policy PolicyPolicyPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

func (PolicyState) ElementType 

func (PolicyState) ElementType() reflect.Type

type Provider 

type Provider struct {
	pulumi.ProviderResourceState

	CacertFile     pulumi.StringPtrOutput `pulumi:"cacertFile"`
	ClientcertFile pulumi.StringPtrOutput `pulumi:"clientcertFile"`
	ClientkeyFile  pulumi.StringPtrOutput `pulumi:"clientkeyFile"`
	Endpoint       pulumi.StringOutput    `pulumi:"endpoint"`
	Password       pulumi.StringOutput    `pulumi:"password"`
	Proxy          pulumi.StringPtrOutput `pulumi:"proxy"`
	Username       pulumi.StringOutput    `pulumi:"username"`
}

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 

func (*Provider) ElementType() reflect.Type

func (*Provider) ToProviderOutput 

func (i *Provider) ToProviderOutput() ProviderOutput

func (*Provider) ToProviderOutputWithContext 

func (i *Provider) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

type ProviderArgs 

type ProviderArgs struct {
	CacertFile     pulumi.StringPtrInput
	ClientcertFile pulumi.StringPtrInput
	ClientkeyFile  pulumi.StringPtrInput
	Endpoint       pulumi.StringInput
	Insecure       pulumi.BoolPtrInput
	Password       pulumi.StringInput
	Proxy          pulumi.StringPtrInput
	Username       pulumi.StringInput
}

The set of arguments for constructing a Provider resource.

func (ProviderArgs) ElementType 

func (ProviderArgs) ElementType() reflect.Type

type ProviderInput 

type ProviderInput interface {
	pulumi.Input

	ToProviderOutput() ProviderOutput
	ToProviderOutputWithContext(ctx context.Context) ProviderOutput
}

type ProviderOutput 

type ProviderOutput struct{ *pulumi.OutputState }

func (ProviderOutput) CacertFile added in v3.3.0 

func (o ProviderOutput) CacertFile() pulumi.StringPtrOutput

func (ProviderOutput) ClientcertFile added in v3.3.0 

func (o ProviderOutput) ClientcertFile() pulumi.StringPtrOutput

func (ProviderOutput) ClientkeyFile added in v3.3.0 

func (o ProviderOutput) ClientkeyFile() pulumi.StringPtrOutput

func (ProviderOutput) ElementType 

func (ProviderOutput) ElementType() reflect.Type

func (ProviderOutput) Endpoint added in v3.3.0 

func (o ProviderOutput) Endpoint() pulumi.StringOutput

func (ProviderOutput) Password added in v3.3.0 

func (o ProviderOutput) Password() pulumi.StringOutput

func (ProviderOutput) Proxy added in v3.3.0 

func (o ProviderOutput) Proxy() pulumi.StringPtrOutput

func (ProviderOutput) ToProviderOutput 

func (o ProviderOutput) ToProviderOutput() ProviderOutput

func (ProviderOutput) ToProviderOutputWithContext 

func (o ProviderOutput) ToProviderOutputWithContext(ctx context.Context) ProviderOutput

func (ProviderOutput) Username added in v3.3.0 

func (o ProviderOutput) Username() pulumi.StringOutput

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

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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{
			User:  pulumi.String("guest"),
			Vhost: testVHost.Name,
			Permissions: &rabbitmq.PermissionsPermissionsArgs{
				Configure: pulumi.String(".*"),
				Write:     pulumi.String(".*"),
				Read:      pulumi.String(".*"),
			},
		})
		if err != nil {
			return err
		}
		_, err = rabbitmq.NewQueue(ctx, "testQueue", &rabbitmq.QueueArgs{
			Vhost: guest.Vhost,
			Settings: &rabbitmq.QueueSettingsArgs{
				Durable:    pulumi.Bool(false),
				AutoDelete: pulumi.Bool(true),
				Arguments: pulumi.Map{
					"x-queue-type": pulumi.Any("quorum"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

### Example With JSON Arguments

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		arguments := "{\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
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*Queue) ElementType() reflect.Type

func (*Queue) ToQueueOutput 

func (i *Queue) ToQueueOutput() QueueOutput

func (*Queue) ToQueueOutputWithContext 

func (i *Queue) ToQueueOutputWithContext(ctx context.Context) QueueOutput

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 

func (QueueArgs) ElementType() reflect.Type

type QueueArray 

type QueueArray []QueueInput

func (QueueArray) ElementType 

func (QueueArray) ElementType() reflect.Type

func (QueueArray) ToQueueArrayOutput 

func (i QueueArray) ToQueueArrayOutput() QueueArrayOutput

func (QueueArray) ToQueueArrayOutputWithContext 

func (i QueueArray) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput

type QueueArrayInput 

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 

type QueueArrayOutput struct{ *pulumi.OutputState }

func (QueueArrayOutput) ElementType 

func (QueueArrayOutput) ElementType() reflect.Type

func (QueueArrayOutput) Index 

func (o QueueArrayOutput) Index(i pulumi.IntInput) QueueOutput

func (QueueArrayOutput) ToQueueArrayOutput 

func (o QueueArrayOutput) ToQueueArrayOutput() QueueArrayOutput

func (QueueArrayOutput) ToQueueArrayOutputWithContext 

func (o QueueArrayOutput) ToQueueArrayOutputWithContext(ctx context.Context) QueueArrayOutput

type QueueInput 

type QueueInput interface {
	pulumi.Input

	ToQueueOutput() QueueOutput
	ToQueueOutputWithContext(ctx context.Context) QueueOutput
}

type QueueMap 

type QueueMap map[string]QueueInput

func (QueueMap) ElementType 

func (QueueMap) ElementType() reflect.Type

func (QueueMap) ToQueueMapOutput 

func (i QueueMap) ToQueueMapOutput() QueueMapOutput

func (QueueMap) ToQueueMapOutputWithContext 

func (i QueueMap) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput

type QueueMapInput 

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 

type QueueMapOutput struct{ *pulumi.OutputState }

func (QueueMapOutput) ElementType 

func (QueueMapOutput) ElementType() reflect.Type

func (QueueMapOutput) MapIndex 

func (o QueueMapOutput) MapIndex(k pulumi.StringInput) QueueOutput

func (QueueMapOutput) ToQueueMapOutput 

func (o QueueMapOutput) ToQueueMapOutput() QueueMapOutput

func (QueueMapOutput) ToQueueMapOutputWithContext 

func (o QueueMapOutput) ToQueueMapOutputWithContext(ctx context.Context) QueueMapOutput

type QueueOutput 

type QueueOutput struct{ *pulumi.OutputState }

func (QueueOutput) ElementType 

func (QueueOutput) ElementType() reflect.Type

func (QueueOutput) Name added in v3.3.0 

func (o QueueOutput) Name() pulumi.StringOutput

The name of the queue.

func (QueueOutput) Settings added in v3.3.0 

func (o QueueOutput) Settings() QueueSettingsOutput

The settings of the queue. The structure is described below.

func (QueueOutput) ToQueueOutput 

func (o QueueOutput) ToQueueOutput() QueueOutput

func (QueueOutput) ToQueueOutputWithContext 

func (o QueueOutput) ToQueueOutputWithContext(ctx context.Context) QueueOutput

func (QueueOutput) Vhost added in v3.3.0 

func (o QueueOutput) Vhost() pulumi.StringPtrOutput

The vhost to create the resource in.

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 

type Shovel struct {
	pulumi.CustomResourceState

	// The settings of the dynamic 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 dynamic shovel.

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## Import

Shovels can be imported using the `name` and `vhost`

E.g.

```sh $ pulumi import rabbitmq:index/shovel:Shovel test shovelTest@test ```

func GetShovel 

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 

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 

func (*Shovel) ElementType() reflect.Type

func (*Shovel) ToShovelOutput 

func (i *Shovel) ToShovelOutput() ShovelOutput

func (*Shovel) ToShovelOutputWithContext 

func (i *Shovel) ToShovelOutputWithContext(ctx context.Context) ShovelOutput

type ShovelArgs 

type ShovelArgs struct {
	// The settings of the dynamic 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 

func (ShovelArgs) ElementType() reflect.Type

type ShovelArray 

type ShovelArray []ShovelInput

func (ShovelArray) ElementType 

func (ShovelArray) ElementType() reflect.Type

func (ShovelArray) ToShovelArrayOutput 

func (i ShovelArray) ToShovelArrayOutput() ShovelArrayOutput

func (ShovelArray) ToShovelArrayOutputWithContext 

func (i ShovelArray) ToShovelArrayOutputWithContext(ctx context.Context) ShovelArrayOutput

type ShovelArrayInput 

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 

type ShovelArrayOutput struct{ *pulumi.OutputState }

func (ShovelArrayOutput) ElementType 

func (ShovelArrayOutput) ElementType() reflect.Type

func (ShovelArrayOutput) Index 

func (o ShovelArrayOutput) Index(i pulumi.IntInput) ShovelOutput

func (ShovelArrayOutput) ToShovelArrayOutput 

func (o ShovelArrayOutput) ToShovelArrayOutput() ShovelArrayOutput

func (ShovelArrayOutput) ToShovelArrayOutputWithContext 

func (o ShovelArrayOutput) ToShovelArrayOutputWithContext(ctx context.Context) ShovelArrayOutput

type ShovelInfo 

type ShovelInfo struct {
	// Determines how the shovel should acknowledge messages. Possible values are: `on-confirm`, `on-publish` and `no-ack`.
	// Defaults to `on-confirm`.
	AckMode *string `pulumi:"ackMode"`
	// Whether to add `x-shovelled` headers to shovelled messages.
	//
	// Deprecated: use destinationAddForwardHeaders instead
	AddForwardHeaders *bool `pulumi:"addForwardHeaders"`
	// Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.
	//
	// Deprecated: use sourceDeleteAfter instead
	DeleteAfter *string `pulumi:"deleteAfter"`
	// Whether to add `x-shovelled` headers to shovelled messages.
	DestinationAddForwardHeaders  *bool `pulumi:"destinationAddForwardHeaders"`
	DestinationAddTimestampHeader *bool `pulumi:"destinationAddTimestampHeader"`
	// The AMQP 1.0 destination link address.
	DestinationAddress *string `pulumi:"destinationAddress"`
	// Application properties to set when shovelling messages.
	DestinationApplicationProperties *string `pulumi:"destinationApplicationProperties"`
	// 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 `destinationExchange`.
	DestinationExchangeKey *string `pulumi:"destinationExchangeKey"`
	// Properties to overwrite when shovelling messages.
	//
	// For more details regarding dynamic shovel parameters please have a look at the official reference documentaion at [RabbitMQ: Configuring Dynamic Shovels](https://www.rabbitmq.com/shovel-dynamic.html).
	DestinationProperties *string `pulumi:"destinationProperties"`
	// The protocol (`amqp091` or `amqp10`) to use when connecting to the destination.
	// Defaults to `amqp091`.
	DestinationProtocol *string `pulumi:"destinationProtocol"`
	// A map of properties to overwrite when shovelling messages.
	DestinationPublishProperties *string `pulumi:"destinationPublishProperties"`
	// 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.
	//
	// Deprecated: use sourcePrefetchCount instead
	PrefetchCount *int `pulumi:"prefetchCount"`
	// The duration in seconds to reconnect to a broker after disconnected.
	// Defaults to `1`.
	ReconnectDelay *int `pulumi:"reconnectDelay"`
	// The AMQP 1.0 source link address.
	SourceAddress *string `pulumi:"sourceAddress"`
	// Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.
	SourceDeleteAfter *string `pulumi:"sourceDeleteAfter"`
	// 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 `sourceExchange`.
	SourceExchangeKey *string `pulumi:"sourceExchangeKey"`
	// The maximum number of unacknowledged messages copied over a shovel at any one time.
	SourcePrefetchCount *int `pulumi:"sourcePrefetchCount"`
	// The protocol (`amqp091` or `amqp10`) to use when connecting to the source.
	// Defaults to `amqp091`.
	SourceProtocol *string `pulumi:"sourceProtocol"`
	// 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 

type ShovelInfoArgs struct {
	// Determines how the shovel should acknowledge messages. Possible values are: `on-confirm`, `on-publish` and `no-ack`.
	// Defaults to `on-confirm`.
	AckMode pulumi.StringPtrInput `pulumi:"ackMode"`
	// Whether to add `x-shovelled` headers to shovelled messages.
	//
	// Deprecated: use destinationAddForwardHeaders instead
	AddForwardHeaders pulumi.BoolPtrInput `pulumi:"addForwardHeaders"`
	// Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.
	//
	// Deprecated: use sourceDeleteAfter instead
	DeleteAfter pulumi.StringPtrInput `pulumi:"deleteAfter"`
	// Whether to add `x-shovelled` headers to shovelled messages.
	DestinationAddForwardHeaders  pulumi.BoolPtrInput `pulumi:"destinationAddForwardHeaders"`
	DestinationAddTimestampHeader pulumi.BoolPtrInput `pulumi:"destinationAddTimestampHeader"`
	// The AMQP 1.0 destination link address.
	DestinationAddress pulumi.StringPtrInput `pulumi:"destinationAddress"`
	// Application properties to set when shovelling messages.
	DestinationApplicationProperties pulumi.StringPtrInput `pulumi:"destinationApplicationProperties"`
	// 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 `destinationExchange`.
	DestinationExchangeKey pulumi.StringPtrInput `pulumi:"destinationExchangeKey"`
	// Properties to overwrite when shovelling messages.
	//
	// For more details regarding dynamic shovel parameters please have a look at the official reference documentaion at [RabbitMQ: Configuring Dynamic Shovels](https://www.rabbitmq.com/shovel-dynamic.html).
	DestinationProperties pulumi.StringPtrInput `pulumi:"destinationProperties"`
	// The protocol (`amqp091` or `amqp10`) to use when connecting to the destination.
	// Defaults to `amqp091`.
	DestinationProtocol pulumi.StringPtrInput `pulumi:"destinationProtocol"`
	// A map of properties to overwrite when shovelling messages.
	DestinationPublishProperties pulumi.StringPtrInput `pulumi:"destinationPublishProperties"`
	// 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.
	//
	// Deprecated: use sourcePrefetchCount instead
	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 AMQP 1.0 source link address.
	SourceAddress pulumi.StringPtrInput `pulumi:"sourceAddress"`
	// Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.
	SourceDeleteAfter pulumi.StringPtrInput `pulumi:"sourceDeleteAfter"`
	// 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 `sourceExchange`.
	SourceExchangeKey pulumi.StringPtrInput `pulumi:"sourceExchangeKey"`
	// The maximum number of unacknowledged messages copied over a shovel at any one time.
	SourcePrefetchCount pulumi.IntPtrInput `pulumi:"sourcePrefetchCount"`
	// The protocol (`amqp091` or `amqp10`) to use when connecting to the source.
	// Defaults to `amqp091`.
	SourceProtocol pulumi.StringPtrInput `pulumi:"sourceProtocol"`
	// 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 

func (ShovelInfoArgs) ElementType() reflect.Type

func (ShovelInfoArgs) ToShovelInfoOutput 

func (i ShovelInfoArgs) ToShovelInfoOutput() ShovelInfoOutput

func (ShovelInfoArgs) ToShovelInfoOutputWithContext 

func (i ShovelInfoArgs) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput

func (ShovelInfoArgs) ToShovelInfoPtrOutput 

func (i ShovelInfoArgs) ToShovelInfoPtrOutput() ShovelInfoPtrOutput

func (ShovelInfoArgs) ToShovelInfoPtrOutputWithContext 

func (i ShovelInfoArgs) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput

type ShovelInfoInput 

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 

type ShovelInfoOutput struct{ *pulumi.OutputState }

func (ShovelInfoOutput) AckMode 

func (o ShovelInfoOutput) AckMode() pulumi.StringPtrOutput

Determines how the shovel should acknowledge messages. Possible values are: `on-confirm`, `on-publish` and `no-ack`. Defaults to `on-confirm`.

func (ShovelInfoOutput) AddForwardHeaders deprecated 

func (o ShovelInfoOutput) AddForwardHeaders() pulumi.BoolPtrOutput

Whether to add `x-shovelled` headers to shovelled messages.

Deprecated: use destinationAddForwardHeaders instead

func (ShovelInfoOutput) DeleteAfter deprecated 

func (o ShovelInfoOutput) DeleteAfter() pulumi.StringPtrOutput

Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.

Deprecated: use sourceDeleteAfter instead

func (ShovelInfoOutput) DestinationAddForwardHeaders added in v3.1.0 

func (o ShovelInfoOutput) DestinationAddForwardHeaders() pulumi.BoolPtrOutput

Whether to add `x-shovelled` headers to shovelled messages.

func (ShovelInfoOutput) DestinationAddTimestampHeader added in v3.1.0 

func (o ShovelInfoOutput) DestinationAddTimestampHeader() pulumi.BoolPtrOutput

func (ShovelInfoOutput) DestinationAddress added in v3.1.0 

func (o ShovelInfoOutput) DestinationAddress() pulumi.StringPtrOutput

The AMQP 1.0 destination link address.

func (ShovelInfoOutput) DestinationApplicationProperties added in v3.1.0 

func (o ShovelInfoOutput) DestinationApplicationProperties() pulumi.StringPtrOutput

Application properties to set when shovelling messages.

func (ShovelInfoOutput) DestinationExchange 

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 

func (o ShovelInfoOutput) DestinationExchangeKey() pulumi.StringPtrOutput

The routing key when using `destinationExchange`.

func (ShovelInfoOutput) DestinationProperties added in v3.1.0 

func (o ShovelInfoOutput) DestinationProperties() pulumi.StringPtrOutput

Properties to overwrite when shovelling messages.

For more details regarding dynamic shovel parameters please have a look at the official reference documentaion at [RabbitMQ: Configuring Dynamic Shovels](https://www.rabbitmq.com/shovel-dynamic.html).

func (ShovelInfoOutput) DestinationProtocol added in v3.1.0 

func (o ShovelInfoOutput) DestinationProtocol() pulumi.StringPtrOutput

The protocol (`amqp091` or `amqp10`) to use when connecting to the destination. Defaults to `amqp091`.

func (ShovelInfoOutput) DestinationPublishProperties added in v3.1.0 

func (o ShovelInfoOutput) DestinationPublishProperties() pulumi.StringPtrOutput

A map of properties to overwrite when shovelling messages.

func (ShovelInfoOutput) DestinationQueue 

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 

func (o ShovelInfoOutput) DestinationUri() pulumi.StringOutput

The amqp uri for the destination .

func (ShovelInfoOutput) ElementType 

func (ShovelInfoOutput) ElementType() reflect.Type

func (ShovelInfoOutput) PrefetchCount deprecated 

func (o ShovelInfoOutput) PrefetchCount() pulumi.IntPtrOutput

The maximum number of unacknowledged messages copied over a shovel at any one time.

Deprecated: use sourcePrefetchCount instead

func (ShovelInfoOutput) ReconnectDelay 

func (o ShovelInfoOutput) ReconnectDelay() pulumi.IntPtrOutput

The duration in seconds to reconnect to a broker after disconnected. Defaults to `1`.

func (ShovelInfoOutput) SourceAddress added in v3.1.0 

func (o ShovelInfoOutput) SourceAddress() pulumi.StringPtrOutput

The AMQP 1.0 source link address.

func (ShovelInfoOutput) SourceDeleteAfter added in v3.1.0 

func (o ShovelInfoOutput) SourceDeleteAfter() pulumi.StringPtrOutput

Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.

func (ShovelInfoOutput) SourceExchange 

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 

func (o ShovelInfoOutput) SourceExchangeKey() pulumi.StringPtrOutput

The routing key when using `sourceExchange`.

func (ShovelInfoOutput) SourcePrefetchCount added in v3.1.0 

func (o ShovelInfoOutput) SourcePrefetchCount() pulumi.IntPtrOutput

The maximum number of unacknowledged messages copied over a shovel at any one time.

func (ShovelInfoOutput) SourceProtocol added in v3.1.0 

func (o ShovelInfoOutput) SourceProtocol() pulumi.StringPtrOutput

The protocol (`amqp091` or `amqp10`) to use when connecting to the source. Defaults to `amqp091`.

func (ShovelInfoOutput) SourceQueue 

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 

func (o ShovelInfoOutput) SourceUri() pulumi.StringOutput

The amqp uri for the source.

func (ShovelInfoOutput) ToShovelInfoOutput 

func (o ShovelInfoOutput) ToShovelInfoOutput() ShovelInfoOutput

func (ShovelInfoOutput) ToShovelInfoOutputWithContext 

func (o ShovelInfoOutput) ToShovelInfoOutputWithContext(ctx context.Context) ShovelInfoOutput

func (ShovelInfoOutput) ToShovelInfoPtrOutput 

func (o ShovelInfoOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput

func (ShovelInfoOutput) ToShovelInfoPtrOutputWithContext 

func (o ShovelInfoOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput

type ShovelInfoPtrInput 

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 

func ShovelInfoPtr(v *ShovelInfoArgs) ShovelInfoPtrInput

type ShovelInfoPtrOutput 

type ShovelInfoPtrOutput struct{ *pulumi.OutputState }

func (ShovelInfoPtrOutput) AckMode 

func (o ShovelInfoPtrOutput) AckMode() pulumi.StringPtrOutput

Determines how the shovel should acknowledge messages. Possible values are: `on-confirm`, `on-publish` and `no-ack`. Defaults to `on-confirm`.

func (ShovelInfoPtrOutput) AddForwardHeaders deprecated 

func (o ShovelInfoPtrOutput) AddForwardHeaders() pulumi.BoolPtrOutput

Whether to add `x-shovelled` headers to shovelled messages.

Deprecated: use destinationAddForwardHeaders instead

func (ShovelInfoPtrOutput) DeleteAfter deprecated 

func (o ShovelInfoPtrOutput) DeleteAfter() pulumi.StringPtrOutput

Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.

Deprecated: use sourceDeleteAfter instead

func (ShovelInfoPtrOutput) DestinationAddForwardHeaders added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationAddForwardHeaders() pulumi.BoolPtrOutput

Whether to add `x-shovelled` headers to shovelled messages.

func (ShovelInfoPtrOutput) DestinationAddTimestampHeader added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationAddTimestampHeader() pulumi.BoolPtrOutput

func (ShovelInfoPtrOutput) DestinationAddress added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationAddress() pulumi.StringPtrOutput

The AMQP 1.0 destination link address.

func (ShovelInfoPtrOutput) DestinationApplicationProperties added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationApplicationProperties() pulumi.StringPtrOutput

Application properties to set when shovelling messages.

func (ShovelInfoPtrOutput) DestinationExchange 

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 

func (o ShovelInfoPtrOutput) DestinationExchangeKey() pulumi.StringPtrOutput

The routing key when using `destinationExchange`.

func (ShovelInfoPtrOutput) DestinationProperties added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationProperties() pulumi.StringPtrOutput

Properties to overwrite when shovelling messages.

For more details regarding dynamic shovel parameters please have a look at the official reference documentaion at [RabbitMQ: Configuring Dynamic Shovels](https://www.rabbitmq.com/shovel-dynamic.html).

func (ShovelInfoPtrOutput) DestinationProtocol added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationProtocol() pulumi.StringPtrOutput

The protocol (`amqp091` or `amqp10`) to use when connecting to the destination. Defaults to `amqp091`.

func (ShovelInfoPtrOutput) DestinationPublishProperties added in v3.1.0 

func (o ShovelInfoPtrOutput) DestinationPublishProperties() pulumi.StringPtrOutput

A map of properties to overwrite when shovelling messages.

func (ShovelInfoPtrOutput) DestinationQueue 

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 

func (o ShovelInfoPtrOutput) DestinationUri() pulumi.StringPtrOutput

The amqp uri for the destination .

func (ShovelInfoPtrOutput) Elem 

func (o ShovelInfoPtrOutput) Elem() ShovelInfoOutput

func (ShovelInfoPtrOutput) ElementType 

func (ShovelInfoPtrOutput) ElementType() reflect.Type

func (ShovelInfoPtrOutput) PrefetchCount deprecated 

func (o ShovelInfoPtrOutput) PrefetchCount() pulumi.IntPtrOutput

The maximum number of unacknowledged messages copied over a shovel at any one time.

Deprecated: use sourcePrefetchCount instead

func (ShovelInfoPtrOutput) ReconnectDelay 

func (o ShovelInfoPtrOutput) ReconnectDelay() pulumi.IntPtrOutput

The duration in seconds to reconnect to a broker after disconnected. Defaults to `1`.

func (ShovelInfoPtrOutput) SourceAddress added in v3.1.0 

func (o ShovelInfoPtrOutput) SourceAddress() pulumi.StringPtrOutput

The AMQP 1.0 source link address.

func (ShovelInfoPtrOutput) SourceDeleteAfter added in v3.1.0 

func (o ShovelInfoPtrOutput) SourceDeleteAfter() pulumi.StringPtrOutput

Determines when (if ever) the shovel should delete itself. Possible values are: `never`, `queue-length` or an integer.

func (ShovelInfoPtrOutput) SourceExchange 

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 

func (o ShovelInfoPtrOutput) SourceExchangeKey() pulumi.StringPtrOutput

The routing key when using `sourceExchange`.

func (ShovelInfoPtrOutput) SourcePrefetchCount added in v3.1.0 

func (o ShovelInfoPtrOutput) SourcePrefetchCount() pulumi.IntPtrOutput

The maximum number of unacknowledged messages copied over a shovel at any one time.

func (ShovelInfoPtrOutput) SourceProtocol added in v3.1.0 

func (o ShovelInfoPtrOutput) SourceProtocol() pulumi.StringPtrOutput

The protocol (`amqp091` or `amqp10`) to use when connecting to the source. Defaults to `amqp091`.

func (ShovelInfoPtrOutput) SourceQueue 

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 

func (o ShovelInfoPtrOutput) SourceUri() pulumi.StringPtrOutput

The amqp uri for the source.

func (ShovelInfoPtrOutput) ToShovelInfoPtrOutput 

func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutput() ShovelInfoPtrOutput

func (ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext 

func (o ShovelInfoPtrOutput) ToShovelInfoPtrOutputWithContext(ctx context.Context) ShovelInfoPtrOutput

type ShovelInput 

type ShovelInput interface {
	pulumi.Input

	ToShovelOutput() ShovelOutput
	ToShovelOutputWithContext(ctx context.Context) ShovelOutput
}

type ShovelMap 

type ShovelMap map[string]ShovelInput

func (ShovelMap) ElementType 

func (ShovelMap) ElementType() reflect.Type

func (ShovelMap) ToShovelMapOutput 

func (i ShovelMap) ToShovelMapOutput() ShovelMapOutput

func (ShovelMap) ToShovelMapOutputWithContext 

func (i ShovelMap) ToShovelMapOutputWithContext(ctx context.Context) ShovelMapOutput

type ShovelMapInput 

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 

type ShovelMapOutput struct{ *pulumi.OutputState }

func (ShovelMapOutput) ElementType 

func (ShovelMapOutput) ElementType() reflect.Type

func (ShovelMapOutput) MapIndex 

func (o ShovelMapOutput) MapIndex(k pulumi.StringInput) ShovelOutput

func (ShovelMapOutput) ToShovelMapOutput 

func (o ShovelMapOutput) ToShovelMapOutput() ShovelMapOutput

func (ShovelMapOutput) ToShovelMapOutputWithContext 

func (o ShovelMapOutput) ToShovelMapOutputWithContext(ctx context.Context) ShovelMapOutput

type ShovelOutput 

type ShovelOutput struct{ *pulumi.OutputState }

func (ShovelOutput) ElementType 

func (ShovelOutput) ElementType() reflect.Type

func (ShovelOutput) Info added in v3.3.0 

func (o ShovelOutput) Info() ShovelInfoOutput

The settings of the dynamic shovel. The structure is described below.

func (ShovelOutput) Name added in v3.3.0 

func (o ShovelOutput) Name() pulumi.StringOutput

The shovel name.

func (ShovelOutput) ToShovelOutput 

func (o ShovelOutput) ToShovelOutput() ShovelOutput

func (ShovelOutput) ToShovelOutputWithContext 

func (o ShovelOutput) ToShovelOutputWithContext(ctx context.Context) ShovelOutput

func (ShovelOutput) Vhost added in v3.3.0 

func (o ShovelOutput) Vhost() pulumi.StringOutput

The vhost to create the resource in.

type ShovelState 

type ShovelState struct {
	// The settings of the dynamic 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 

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

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*TopicPermissions) ElementType() reflect.Type

func (*TopicPermissions) ToTopicPermissionsOutput 

func (i *TopicPermissions) ToTopicPermissionsOutput() TopicPermissionsOutput

func (*TopicPermissions) ToTopicPermissionsOutputWithContext 

func (i *TopicPermissions) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput

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 

type TopicPermissionsArray []TopicPermissionsInput

func (TopicPermissionsArray) ElementType 

func (TopicPermissionsArray) ElementType() reflect.Type

func (TopicPermissionsArray) ToTopicPermissionsArrayOutput 

func (i TopicPermissionsArray) ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput

func (TopicPermissionsArray) ToTopicPermissionsArrayOutputWithContext 

func (i TopicPermissionsArray) ToTopicPermissionsArrayOutputWithContext(ctx context.Context) TopicPermissionsArrayOutput

type TopicPermissionsArrayInput 

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 

type TopicPermissionsArrayOutput struct{ *pulumi.OutputState }

func (TopicPermissionsArrayOutput) ElementType 

func (TopicPermissionsArrayOutput) ElementType() reflect.Type

func (TopicPermissionsArrayOutput) Index 

func (o TopicPermissionsArrayOutput) Index(i pulumi.IntInput) TopicPermissionsOutput

func (TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutput 

func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutput() TopicPermissionsArrayOutput

func (TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutputWithContext 

func (o TopicPermissionsArrayOutput) ToTopicPermissionsArrayOutputWithContext(ctx context.Context) TopicPermissionsArrayOutput

type TopicPermissionsInput 

type TopicPermissionsInput interface {
	pulumi.Input

	ToTopicPermissionsOutput() TopicPermissionsOutput
	ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput
}

type TopicPermissionsMap 

type TopicPermissionsMap map[string]TopicPermissionsInput

func (TopicPermissionsMap) ElementType 

func (TopicPermissionsMap) ElementType() reflect.Type

func (TopicPermissionsMap) ToTopicPermissionsMapOutput 

func (i TopicPermissionsMap) ToTopicPermissionsMapOutput() TopicPermissionsMapOutput

func (TopicPermissionsMap) ToTopicPermissionsMapOutputWithContext 

func (i TopicPermissionsMap) ToTopicPermissionsMapOutputWithContext(ctx context.Context) TopicPermissionsMapOutput

type TopicPermissionsMapInput 

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 

type TopicPermissionsMapOutput struct{ *pulumi.OutputState }

func (TopicPermissionsMapOutput) ElementType 

func (TopicPermissionsMapOutput) ElementType() reflect.Type

func (TopicPermissionsMapOutput) MapIndex 

func (o TopicPermissionsMapOutput) MapIndex(k pulumi.StringInput) TopicPermissionsOutput

func (TopicPermissionsMapOutput) ToTopicPermissionsMapOutput 

func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutput() TopicPermissionsMapOutput

func (TopicPermissionsMapOutput) ToTopicPermissionsMapOutputWithContext 

func (o TopicPermissionsMapOutput) ToTopicPermissionsMapOutputWithContext(ctx context.Context) TopicPermissionsMapOutput

type TopicPermissionsOutput 

type TopicPermissionsOutput struct{ *pulumi.OutputState }

func (TopicPermissionsOutput) ElementType 

func (TopicPermissionsOutput) ElementType() reflect.Type

func (TopicPermissionsOutput) Permissions added in v3.3.0 

func (o TopicPermissionsOutput) Permissions() TopicPermissionsPermissionArrayOutput

The settings of the permissions. The structure is described below.

func (TopicPermissionsOutput) ToTopicPermissionsOutput 

func (o TopicPermissionsOutput) ToTopicPermissionsOutput() TopicPermissionsOutput

func (TopicPermissionsOutput) ToTopicPermissionsOutputWithContext 

func (o TopicPermissionsOutput) ToTopicPermissionsOutputWithContext(ctx context.Context) TopicPermissionsOutput

func (TopicPermissionsOutput) User added in v3.3.0 

func (o TopicPermissionsOutput) User() pulumi.StringOutput

The user to apply the permissions to.

func (TopicPermissionsOutput) Vhost added in v3.3.0 

func (o TopicPermissionsOutput) Vhost() pulumi.StringPtrOutput

The vhost to create the resource in.

type TopicPermissionsPermission 

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

type TopicPermissionsPermissionArgs 

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

func (TopicPermissionsPermissionArgs) ElementType 

func (TopicPermissionsPermissionArgs) ElementType() reflect.Type

func (TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput 

func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput

func (TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext 

func (i TopicPermissionsPermissionArgs) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput

type TopicPermissionsPermissionArray 

type TopicPermissionsPermissionArray []TopicPermissionsPermissionInput

func (TopicPermissionsPermissionArray) ElementType 

func (TopicPermissionsPermissionArray) ElementType() reflect.Type

func (TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput 

func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput

func (TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext 

func (i TopicPermissionsPermissionArray) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput

type TopicPermissionsPermissionArrayInput 

type TopicPermissionsPermissionArrayInput interface {
	pulumi.Input

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

TopicPermissionsPermissionArrayInput is an input type that accepts TopicPermissionsPermissionArray and TopicPermissionsPermissionArrayOutput values. You can construct a concrete instance of `TopicPermissionsPermissionArrayInput` via: 

TopicPermissionsPermissionArray{ TopicPermissionsPermissionArgs{...} }

type TopicPermissionsPermissionArrayOutput 

type TopicPermissionsPermissionArrayOutput struct{ *pulumi.OutputState }

func (TopicPermissionsPermissionArrayOutput) ElementType 

func (TopicPermissionsPermissionArrayOutput) ElementType() reflect.Type

func (TopicPermissionsPermissionArrayOutput) Index 

func (o TopicPermissionsPermissionArrayOutput) Index(i pulumi.IntInput) TopicPermissionsPermissionOutput

func (TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput 

func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutput() TopicPermissionsPermissionArrayOutput

func (TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext 

func (o TopicPermissionsPermissionArrayOutput) ToTopicPermissionsPermissionArrayOutputWithContext(ctx context.Context) TopicPermissionsPermissionArrayOutput

type TopicPermissionsPermissionInput 

type TopicPermissionsPermissionInput interface {
	pulumi.Input

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

TopicPermissionsPermissionInput is an input type that accepts TopicPermissionsPermissionArgs and TopicPermissionsPermissionOutput values. You can construct a concrete instance of `TopicPermissionsPermissionInput` via: 

TopicPermissionsPermissionArgs{...}

type TopicPermissionsPermissionOutput 

type TopicPermissionsPermissionOutput struct{ *pulumi.OutputState }

func (TopicPermissionsPermissionOutput) ElementType 

func (TopicPermissionsPermissionOutput) ElementType() reflect.Type

func (TopicPermissionsPermissionOutput) Exchange 

func (o TopicPermissionsPermissionOutput) Exchange() pulumi.StringOutput

The exchange to set the permissions for.

func (TopicPermissionsPermissionOutput) Read 

func (o TopicPermissionsPermissionOutput) Read() pulumi.StringOutput

The "read" ACL.

func (TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput 

func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutput() TopicPermissionsPermissionOutput

func (TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext 

func (o TopicPermissionsPermissionOutput) ToTopicPermissionsPermissionOutputWithContext(ctx context.Context) TopicPermissionsPermissionOutput

func (TopicPermissionsPermissionOutput) Write 

func (o TopicPermissionsPermissionOutput) Write() pulumi.StringOutput

The "write" ACL.

type TopicPermissionsState 

type TopicPermissionsState struct {
	// The settings of the permissions. The structure is
	// described below.
	Permissions TopicPermissionsPermissionArrayInput
	// The user to apply the permissions to.
	User pulumi.StringPtrInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

func (TopicPermissionsState) ElementType 

func (TopicPermissionsState) ElementType() reflect.Type

type User 

type User struct {
	pulumi.CustomResourceState

	// The name of the user.
	Name pulumi.StringOutput `pulumi:"name"`
	// The password of the user. The value of this argument
	// is plain-text so make sure to secure where this is defined.
	Password pulumi.StringOutput `pulumi:"password"`
	// Which permission model to apply to the user. Valid
	// options are: management, policymaker, monitoring, and administrator.
	Tags pulumi.StringArrayOutput `pulumi:"tags"`
}

The “User“ resource creates and manages a user.

> **Note:** All arguments including username and password will be stored in the raw state as plain-text. [Read more about sensitive data in state](https://www.terraform.io/docs/state/sensitive-data.html).

## Example Usage

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/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
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*User) ElementType() reflect.Type

func (*User) ToUserOutput 

func (i *User) ToUserOutput() UserOutput

func (*User) ToUserOutputWithContext 

func (i *User) ToUserOutputWithContext(ctx context.Context) UserOutput

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 

func (UserArgs) ElementType() reflect.Type

type UserArray 

type UserArray []UserInput

func (UserArray) ElementType 

func (UserArray) ElementType() reflect.Type

func (UserArray) ToUserArrayOutput 

func (i UserArray) ToUserArrayOutput() UserArrayOutput

func (UserArray) ToUserArrayOutputWithContext 

func (i UserArray) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput

type UserArrayInput 

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 

type UserArrayOutput struct{ *pulumi.OutputState }

func (UserArrayOutput) ElementType 

func (UserArrayOutput) ElementType() reflect.Type

func (UserArrayOutput) Index 

func (o UserArrayOutput) Index(i pulumi.IntInput) UserOutput

func (UserArrayOutput) ToUserArrayOutput 

func (o UserArrayOutput) ToUserArrayOutput() UserArrayOutput

func (UserArrayOutput) ToUserArrayOutputWithContext 

func (o UserArrayOutput) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput

type UserInput 

type UserInput interface {
	pulumi.Input

	ToUserOutput() UserOutput
	ToUserOutputWithContext(ctx context.Context) UserOutput
}

type UserMap 

type UserMap map[string]UserInput

func (UserMap) ElementType 

func (UserMap) ElementType() reflect.Type

func (UserMap) ToUserMapOutput 

func (i UserMap) ToUserMapOutput() UserMapOutput

func (UserMap) ToUserMapOutputWithContext 

func (i UserMap) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput

type UserMapInput 

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 

type UserMapOutput struct{ *pulumi.OutputState }

func (UserMapOutput) ElementType 

func (UserMapOutput) ElementType() reflect.Type

func (UserMapOutput) MapIndex 

func (o UserMapOutput) MapIndex(k pulumi.StringInput) UserOutput

func (UserMapOutput) ToUserMapOutput 

func (o UserMapOutput) ToUserMapOutput() UserMapOutput

func (UserMapOutput) ToUserMapOutputWithContext 

func (o UserMapOutput) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput

type UserOutput 

type UserOutput struct{ *pulumi.OutputState }

func (UserOutput) ElementType 

func (UserOutput) ElementType() reflect.Type

func (UserOutput) Name added in v3.3.0 

func (o UserOutput) Name() pulumi.StringOutput

The name of the user.

func (UserOutput) Password added in v3.3.0 

func (o UserOutput) Password() pulumi.StringOutput

The password of the user. The value of this argument is plain-text so make sure to secure where this is defined.

func (UserOutput) Tags added in v3.3.0 

func (o UserOutput) Tags() pulumi.StringArrayOutput

Which permission model to apply to the user. Valid options are: management, policymaker, monitoring, and administrator.

func (UserOutput) ToUserOutput 

func (o UserOutput) ToUserOutput() UserOutput

func (UserOutput) ToUserOutputWithContext 

func (o UserOutput) ToUserOutputWithContext(ctx context.Context) UserOutput

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 

func (UserState) ElementType() reflect.Type

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

<!--Start PulumiCodeChooser --> ```go package main

import ( 

"github.com/pulumi/pulumi-rabbitmq/sdk/v3/go/rabbitmq"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := rabbitmq.NewVHost(ctx, "myVhost", nil)
		if err != nil {
			return err
		}
		return nil
	})
}

``` <!--End PulumiCodeChooser -->

## 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 

func (*VHost) ElementType() reflect.Type

func (*VHost) ToVHostOutput 

func (i *VHost) ToVHostOutput() VHostOutput

func (*VHost) ToVHostOutputWithContext 

func (i *VHost) ToVHostOutputWithContext(ctx context.Context) VHostOutput

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 

func (VHostArgs) ElementType() reflect.Type

type VHostArray 

type VHostArray []VHostInput

func (VHostArray) ElementType 

func (VHostArray) ElementType() reflect.Type

func (VHostArray) ToVHostArrayOutput 

func (i VHostArray) ToVHostArrayOutput() VHostArrayOutput

func (VHostArray) ToVHostArrayOutputWithContext 

func (i VHostArray) ToVHostArrayOutputWithContext(ctx context.Context) VHostArrayOutput

type VHostArrayInput 

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 

type VHostArrayOutput struct{ *pulumi.OutputState }

func (VHostArrayOutput) ElementType 

func (VHostArrayOutput) ElementType() reflect.Type

func (VHostArrayOutput) Index 

func (o VHostArrayOutput) Index(i pulumi.IntInput) VHostOutput

func (VHostArrayOutput) ToVHostArrayOutput 

func (o VHostArrayOutput) ToVHostArrayOutput() VHostArrayOutput

func (VHostArrayOutput) ToVHostArrayOutputWithContext 

func (o VHostArrayOutput) ToVHostArrayOutputWithContext(ctx context.Context) VHostArrayOutput

type VHostInput 

type VHostInput interface {
	pulumi.Input

	ToVHostOutput() VHostOutput
	ToVHostOutputWithContext(ctx context.Context) VHostOutput
}

type VHostMap 

type VHostMap map[string]VHostInput

func (VHostMap) ElementType 

func (VHostMap) ElementType() reflect.Type

func (VHostMap) ToVHostMapOutput 

func (i VHostMap) ToVHostMapOutput() VHostMapOutput

func (VHostMap) ToVHostMapOutputWithContext 

func (i VHostMap) ToVHostMapOutputWithContext(ctx context.Context) VHostMapOutput

type VHostMapInput 

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 

type VHostMapOutput struct{ *pulumi.OutputState }

func (VHostMapOutput) ElementType 

func (VHostMapOutput) ElementType() reflect.Type

func (VHostMapOutput) MapIndex 

func (o VHostMapOutput) MapIndex(k pulumi.StringInput) VHostOutput

func (VHostMapOutput) ToVHostMapOutput 

func (o VHostMapOutput) ToVHostMapOutput() VHostMapOutput

func (VHostMapOutput) ToVHostMapOutputWithContext 

func (o VHostMapOutput) ToVHostMapOutputWithContext(ctx context.Context) VHostMapOutput

type VHostOutput 

type VHostOutput struct{ *pulumi.OutputState }

func (VHostOutput) ElementType 

func (VHostOutput) ElementType() reflect.Type

func (VHostOutput) Name added in v3.3.0 

func (o VHostOutput) Name() pulumi.StringOutput

The name of the vhost.

func (VHostOutput) ToVHostOutput 

func (o VHostOutput) ToVHostOutput() VHostOutput

func (VHostOutput) ToVHostOutputWithContext 

func (o VHostOutput) ToVHostOutputWithContext(ctx context.Context) VHostOutput

type VHostState 

type VHostState struct {
	// The name of the vhost.
	Name pulumi.StringPtrInput
}

func (VHostState) ElementType 

func (VHostState) ElementType() reflect.Type

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.