rabbitmq

package
v2.0.0-beta.1 Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2020 License: Apache-2.0 Imports: 6 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"`
	// 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.

func GetBinding

func GetBinding(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *BindingState, opts ...pulumi.ResourceOption) (*Binding, error)

GetBinding gets an existing Binding resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewBinding

func NewBinding(ctx *pulumi.Context,
	name string, args *BindingArgs, opts ...pulumi.ResourceOption) (*Binding, error)

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

type BindingArgs

type BindingArgs struct {
	// Additional key/value arguments for the binding.
	Arguments pulumi.MapInput
	// The destination queue or exchange.
	Destination pulumi.StringInput
	// The type of destination (queue or exchange).
	DestinationType pulumi.StringInput
	// A routing key for the binding.
	RoutingKey pulumi.StringPtrInput
	// The source exchange.
	Source pulumi.StringInput
	// The vhost to create the resource in.
	Vhost pulumi.StringInput
}

The set of arguments for constructing a Binding resource.

func (BindingArgs) ElementType

func (BindingArgs) ElementType() reflect.Type

type BindingState

type BindingState struct {
	// Additional key/value arguments for the binding.
	Arguments pulumi.MapInput
	// 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.

func GetExchange

func GetExchange(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ExchangeState, opts ...pulumi.ResourceOption) (*Exchange, error)

GetExchange gets an existing Exchange resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewExchange

func NewExchange(ctx *pulumi.Context,
	name string, args *ExchangeArgs, opts ...pulumi.ResourceOption) (*Exchange, error)

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

type ExchangeArgs

type ExchangeArgs struct {
	// The name of the exchange.
	Name pulumi.StringPtrInput
	// The settings of the exchange. The structure is
	// described below.
	Settings ExchangeSettingsInput
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrInput
}

The set of arguments for constructing a Exchange resource.

func (ExchangeArgs) ElementType

func (ExchangeArgs) ElementType() reflect.Type

type ExchangeSettings

type ExchangeSettings struct {
	// Additional key/value settings for the exchange.
	Arguments map[string]interface{} `pulumi:"arguments"`
	// Whether the exchange will self-delete when all
	// queues have finished using it.
	AutoDelete *bool `pulumi:"autoDelete"`
	// Whether the exchange survives server restarts.
	// Defaults to `false`.
	Durable *bool `pulumi:"durable"`
	// The type of exchange.
	Type string `pulumi:"type"`
}

type ExchangeSettingsArgs

type ExchangeSettingsArgs struct {
	// Additional key/value settings for the exchange.
	Arguments pulumi.MapInput `pulumi:"arguments"`
	// Whether the exchange will self-delete when all
	// queues have finished using it.
	AutoDelete pulumi.BoolPtrInput `pulumi:"autoDelete"`
	// Whether the exchange survives server restarts.
	// Defaults to `false`.
	Durable pulumi.BoolPtrInput `pulumi:"durable"`
	// The type of exchange.
	Type pulumi.StringInput `pulumi:"type"`
}

func (ExchangeSettingsArgs) ElementType

func (ExchangeSettingsArgs) ElementType() reflect.Type

func (ExchangeSettingsArgs) ToExchangeSettingsOutput

func (i ExchangeSettingsArgs) ToExchangeSettingsOutput() ExchangeSettingsOutput

func (ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext

func (i ExchangeSettingsArgs) ToExchangeSettingsOutputWithContext(ctx context.Context) ExchangeSettingsOutput

func (ExchangeSettingsArgs) ToExchangeSettingsPtrOutput

func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutput() ExchangeSettingsPtrOutput

func (ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext

func (i ExchangeSettingsArgs) ToExchangeSettingsPtrOutputWithContext(ctx context.Context) ExchangeSettingsPtrOutput

type ExchangeSettingsInput

type ExchangeSettingsInput interface {
	pulumi.Input

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

ExchangeSettingsInput is an input type that accepts ExchangeSettingsArgs and ExchangeSettingsOutput values. You can construct a concrete instance of `ExchangeSettingsInput` via:

ExchangeSettingsArgs{...}

type ExchangeSettingsOutput

type ExchangeSettingsOutput struct{ *pulumi.OutputState }

func (ExchangeSettingsOutput) Arguments

func (o ExchangeSettingsOutput) Arguments() pulumi.MapOutput

Additional key/value settings for the exchange.

func (ExchangeSettingsOutput) AutoDelete

Whether the exchange will self-delete when all queues have finished using it.

func (ExchangeSettingsOutput) Durable

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

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

type ExchangeSettingsPtrOutput

type ExchangeSettingsPtrOutput struct{ *pulumi.OutputState }

func (ExchangeSettingsPtrOutput) Arguments

Additional key/value settings for the exchange.

func (ExchangeSettingsPtrOutput) AutoDelete

Whether the exchange will self-delete when all queues have finished using it.

func (ExchangeSettingsPtrOutput) Durable

Whether the exchange survives server restarts. Defaults to `false`.

func (ExchangeSettingsPtrOutput) Elem

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

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

func GetPermissions

func GetPermissions(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *PermissionsState, opts ...pulumi.ResourceOption) (*Permissions, error)

GetPermissions gets an existing Permissions resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewPermissions

func NewPermissions(ctx *pulumi.Context,
	name string, args *PermissionsArgs, opts ...pulumi.ResourceOption) (*Permissions, error)

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

type PermissionsArgs

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

The set of arguments for constructing a Permissions resource.

func (PermissionsArgs) ElementType

func (PermissionsArgs) ElementType() reflect.Type

type PermissionsPermissions

type 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

The "configure" ACL.

func (PermissionsPermissionsOutput) ElementType

func (PermissionsPermissionsOutput) Read

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

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

type PermissionsPermissionsPtrOutput

type PermissionsPermissionsPtrOutput struct{ *pulumi.OutputState }

func (PermissionsPermissionsPtrOutput) Configure

The "configure" ACL.

func (PermissionsPermissionsPtrOutput) Elem

func (PermissionsPermissionsPtrOutput) ElementType

func (PermissionsPermissionsPtrOutput) Read

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

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.

func GetPolicy

func GetPolicy(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *PolicyState, opts ...pulumi.ResourceOption) (*Policy, error)

GetPolicy gets an existing Policy resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewPolicy

func NewPolicy(ctx *pulumi.Context,
	name string, args *PolicyArgs, opts ...pulumi.ResourceOption) (*Policy, error)

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

type PolicyArgs

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

The set of arguments for constructing a Policy resource.

func (PolicyArgs) ElementType

func (PolicyArgs) ElementType() reflect.Type

type PolicyPolicy

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

type PolicyPolicyArgs

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

func (PolicyPolicyArgs) ElementType

func (PolicyPolicyArgs) ElementType() reflect.Type

func (PolicyPolicyArgs) ToPolicyPolicyOutput

func (i PolicyPolicyArgs) ToPolicyPolicyOutput() PolicyPolicyOutput

func (PolicyPolicyArgs) ToPolicyPolicyOutputWithContext

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

func (PolicyPolicyArgs) ToPolicyPolicyPtrOutput

func (i PolicyPolicyArgs) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput

func (PolicyPolicyArgs) ToPolicyPolicyPtrOutputWithContext

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

type PolicyPolicyInput

type PolicyPolicyInput interface {
	pulumi.Input

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

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

PolicyPolicyArgs{...}

type PolicyPolicyOutput

type PolicyPolicyOutput struct{ *pulumi.OutputState }

func (PolicyPolicyOutput) ApplyTo

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

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

type PolicyPolicyPtrOutput

type PolicyPolicyPtrOutput struct{ *pulumi.OutputState }

func (PolicyPolicyPtrOutput) ApplyTo

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 (PolicyPolicyPtrOutput) ElementType

func (PolicyPolicyPtrOutput) ElementType() reflect.Type

func (PolicyPolicyPtrOutput) Pattern

A pattern to match an exchange or queue name.

func (PolicyPolicyPtrOutput) Priority

func (o PolicyPolicyPtrOutput) Priority() pulumi.IntOutput

The policy with the greater priority is applied first.

func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput

func (o PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutput() PolicyPolicyPtrOutput

func (PolicyPolicyPtrOutput) ToPolicyPolicyPtrOutputWithContext

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

type PolicyState

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

func (PolicyState) ElementType

func (PolicyState) ElementType() reflect.Type

type Provider

type Provider struct {
	pulumi.ProviderResourceState
}

The provider type for the rabbitmq package. By default, resources use package-wide configuration settings, however an explicit `Provider` instance may be created and passed during resource construction to achieve fine-grained programmatic control over provider settings. See the [documentation](https://www.pulumi.com/docs/reference/programming-model/#providers) for more information.

func NewProvider

func NewProvider(ctx *pulumi.Context,
	name string, args *ProviderArgs, opts ...pulumi.ResourceOption) (*Provider, error)

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

type ProviderArgs

type ProviderArgs struct {
	CacertFile pulumi.StringPtrInput
	Endpoint   pulumi.StringPtrInput
	Insecure   pulumi.BoolPtrInput
	Password   pulumi.StringPtrInput
	Username   pulumi.StringPtrInput
}

The set of arguments for constructing a Provider resource.

func (ProviderArgs) ElementType

func (ProviderArgs) ElementType() reflect.Type

type Queue

type Queue struct {
	pulumi.CustomResourceState

	// The name of the queue.
	Name pulumi.StringOutput `pulumi:"name"`
	// The settings of the queue. The structure is
	// described below.
	Settings QueueSettingsOutput `pulumi:"settings"`
	// The vhost to create the resource in.
	Vhost pulumi.StringPtrOutput `pulumi:"vhost"`
}

The “.Queue“ resource creates and manages a queue.

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.

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

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

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

Whether the queue will self-delete when all consumers have unsubscribed.

func (QueueSettingsPtrOutput) Durable

Whether the queue survives server restarts. Defaults to `false`.

func (QueueSettingsPtrOutput) Elem

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

func GetTopicPermissions

func GetTopicPermissions(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *TopicPermissionsState, opts ...pulumi.ResourceOption) (*TopicPermissions, error)

GetTopicPermissions gets an existing TopicPermissions resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewTopicPermissions

func NewTopicPermissions(ctx *pulumi.Context,
	name string, args *TopicPermissionsArgs, opts ...pulumi.ResourceOption) (*TopicPermissions, error)

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

type TopicPermissionsArgs

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

The set of arguments for constructing a TopicPermissions resource.

func (TopicPermissionsArgs) ElementType

func (TopicPermissionsArgs) ElementType() reflect.Type

type 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) 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) 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) Index

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) Exchange

The exchange to set the permissions for.

func (TopicPermissionsPermissionOutput) Read

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

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).

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.

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

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.

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 VHostState

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

func (VHostState) ElementType

func (VHostState) ElementType() reflect.Type

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL