cloudtasks

package
v3.0.1 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Queue 

type Queue struct {
	pulumi.CustomResourceState

	// Overrides for task-level appEngineRouting. These settings apply only to App Engine tasks in this queue
	AppEngineRoutingOverride QueueAppEngineRoutingOverridePtrOutput `pulumi:"appEngineRoutingOverride"`
	// The location of the queue
	Location pulumi.StringOutput `pulumi:"location"`
	// The queue name.
	Name pulumi.StringOutput `pulumi:"name"`
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringOutput `pulumi:"project"`
	// Rate limits for task dispatches. The queue's actual dispatch rate is the result of: * Number of tasks in the queue *
	// User-specified throttling: rateLimits, retryConfig, and the queue's state. * System throttling due to 429 (Too Many
	// Requests) or 503 (Service Unavailable) responses from the worker, high error rates, or to smooth sudden large traffic
	// spikes.
	RateLimits QueueRateLimitsOutput `pulumi:"rateLimits"`
	// Settings that determine the retry behavior.
	RetryConfig QueueRetryConfigOutput `pulumi:"retryConfig"`
}

A named resource to which messages are sent by publishers.

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 QueueAppEngineRoutingOverride 

type QueueAppEngineRoutingOverride struct {
	Host     *string `pulumi:"host"`
	Instance *string `pulumi:"instance"`
	Service  *string `pulumi:"service"`
	Version  *string `pulumi:"version"`
}

type QueueAppEngineRoutingOverrideArgs 

type QueueAppEngineRoutingOverrideArgs struct {
	Host     pulumi.StringPtrInput `pulumi:"host"`
	Instance pulumi.StringPtrInput `pulumi:"instance"`
	Service  pulumi.StringPtrInput `pulumi:"service"`
	Version  pulumi.StringPtrInput `pulumi:"version"`
}

func (QueueAppEngineRoutingOverrideArgs) ElementType 

func (QueueAppEngineRoutingOverrideArgs) ElementType() reflect.Type

func (QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverrideOutput 

func (i QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverrideOutput() QueueAppEngineRoutingOverrideOutput

func (QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverrideOutputWithContext 

func (i QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverrideOutputWithContext(ctx context.Context) QueueAppEngineRoutingOverrideOutput

func (QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverridePtrOutput 

func (i QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverridePtrOutput() QueueAppEngineRoutingOverridePtrOutput

func (QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverridePtrOutputWithContext 

func (i QueueAppEngineRoutingOverrideArgs) ToQueueAppEngineRoutingOverridePtrOutputWithContext(ctx context.Context) QueueAppEngineRoutingOverridePtrOutput

type QueueAppEngineRoutingOverrideInput 

type QueueAppEngineRoutingOverrideInput interface {
	pulumi.Input

	ToQueueAppEngineRoutingOverrideOutput() QueueAppEngineRoutingOverrideOutput
	ToQueueAppEngineRoutingOverrideOutputWithContext(context.Context) QueueAppEngineRoutingOverrideOutput
}

QueueAppEngineRoutingOverrideInput is an input type that accepts QueueAppEngineRoutingOverrideArgs and QueueAppEngineRoutingOverrideOutput values. You can construct a concrete instance of `QueueAppEngineRoutingOverrideInput` via: 

QueueAppEngineRoutingOverrideArgs{...}

type QueueAppEngineRoutingOverrideOutput 

type QueueAppEngineRoutingOverrideOutput struct{ *pulumi.OutputState }

func (QueueAppEngineRoutingOverrideOutput) ElementType 

func (QueueAppEngineRoutingOverrideOutput) ElementType() reflect.Type

func (QueueAppEngineRoutingOverrideOutput) Host 

func (o QueueAppEngineRoutingOverrideOutput) Host() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverrideOutput) Instance 

func (o QueueAppEngineRoutingOverrideOutput) Instance() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverrideOutput) Service 

func (o QueueAppEngineRoutingOverrideOutput) Service() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverrideOutput 

func (o QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverrideOutput() QueueAppEngineRoutingOverrideOutput

func (QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverrideOutputWithContext 

func (o QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverrideOutputWithContext(ctx context.Context) QueueAppEngineRoutingOverrideOutput

func (QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverridePtrOutput 

func (o QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverridePtrOutput() QueueAppEngineRoutingOverridePtrOutput

func (QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverridePtrOutputWithContext 

func (o QueueAppEngineRoutingOverrideOutput) ToQueueAppEngineRoutingOverridePtrOutputWithContext(ctx context.Context) QueueAppEngineRoutingOverridePtrOutput

func (QueueAppEngineRoutingOverrideOutput) Version 

func (o QueueAppEngineRoutingOverrideOutput) Version() pulumi.StringPtrOutput

type QueueAppEngineRoutingOverridePtrInput 

type QueueAppEngineRoutingOverridePtrInput interface {
	pulumi.Input

	ToQueueAppEngineRoutingOverridePtrOutput() QueueAppEngineRoutingOverridePtrOutput
	ToQueueAppEngineRoutingOverridePtrOutputWithContext(context.Context) QueueAppEngineRoutingOverridePtrOutput
}

QueueAppEngineRoutingOverridePtrInput is an input type that accepts QueueAppEngineRoutingOverrideArgs, QueueAppEngineRoutingOverridePtr and QueueAppEngineRoutingOverridePtrOutput values. You can construct a concrete instance of `QueueAppEngineRoutingOverridePtrInput` via: 

		 QueueAppEngineRoutingOverrideArgs{...}

 or:

		 nil

func QueueAppEngineRoutingOverridePtr 

func QueueAppEngineRoutingOverridePtr(v *QueueAppEngineRoutingOverrideArgs) QueueAppEngineRoutingOverridePtrInput

type QueueAppEngineRoutingOverridePtrOutput 

type QueueAppEngineRoutingOverridePtrOutput struct{ *pulumi.OutputState }

func (QueueAppEngineRoutingOverridePtrOutput) Elem 

func (o QueueAppEngineRoutingOverridePtrOutput) Elem() QueueAppEngineRoutingOverrideOutput

func (QueueAppEngineRoutingOverridePtrOutput) ElementType 

func (QueueAppEngineRoutingOverridePtrOutput) ElementType() reflect.Type

func (QueueAppEngineRoutingOverridePtrOutput) Host 

func (o QueueAppEngineRoutingOverridePtrOutput) Host() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverridePtrOutput) Instance 

func (o QueueAppEngineRoutingOverridePtrOutput) Instance() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverridePtrOutput) Service 

func (o QueueAppEngineRoutingOverridePtrOutput) Service() pulumi.StringPtrOutput

func (QueueAppEngineRoutingOverridePtrOutput) ToQueueAppEngineRoutingOverridePtrOutput 

func (o QueueAppEngineRoutingOverridePtrOutput) ToQueueAppEngineRoutingOverridePtrOutput() QueueAppEngineRoutingOverridePtrOutput

func (QueueAppEngineRoutingOverridePtrOutput) ToQueueAppEngineRoutingOverridePtrOutputWithContext 

func (o QueueAppEngineRoutingOverridePtrOutput) ToQueueAppEngineRoutingOverridePtrOutputWithContext(ctx context.Context) QueueAppEngineRoutingOverridePtrOutput

func (QueueAppEngineRoutingOverridePtrOutput) Version 

func (o QueueAppEngineRoutingOverridePtrOutput) Version() pulumi.StringPtrOutput

type QueueArgs 

type QueueArgs struct {
	// Overrides for task-level appEngineRouting. These settings apply only to App Engine tasks in this queue
	AppEngineRoutingOverride QueueAppEngineRoutingOverridePtrInput
	// The location of the queue
	Location pulumi.StringInput
	// The queue name.
	Name pulumi.StringPtrInput
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringPtrInput
	// Rate limits for task dispatches. The queue's actual dispatch rate is the result of: * Number of tasks in the queue *
	// User-specified throttling: rateLimits, retryConfig, and the queue's state. * System throttling due to 429 (Too Many
	// Requests) or 503 (Service Unavailable) responses from the worker, high error rates, or to smooth sudden large traffic
	// spikes.
	RateLimits QueueRateLimitsPtrInput
	// Settings that determine the retry behavior.
	RetryConfig QueueRetryConfigPtrInput
}

The set of arguments for constructing a Queue resource.

func (QueueArgs) ElementType 

func (QueueArgs) ElementType() reflect.Type

type QueueRateLimits 

type QueueRateLimits struct {
	MaxBurstSize            *int     `pulumi:"maxBurstSize"`
	MaxConcurrentDispatches *int     `pulumi:"maxConcurrentDispatches"`
	MaxDispatchesPerSecond  *float64 `pulumi:"maxDispatchesPerSecond"`
}

type QueueRateLimitsArgs 

type QueueRateLimitsArgs struct {
	MaxBurstSize            pulumi.IntPtrInput     `pulumi:"maxBurstSize"`
	MaxConcurrentDispatches pulumi.IntPtrInput     `pulumi:"maxConcurrentDispatches"`
	MaxDispatchesPerSecond  pulumi.Float64PtrInput `pulumi:"maxDispatchesPerSecond"`
}

func (QueueRateLimitsArgs) ElementType 

func (QueueRateLimitsArgs) ElementType() reflect.Type

func (QueueRateLimitsArgs) ToQueueRateLimitsOutput 

func (i QueueRateLimitsArgs) ToQueueRateLimitsOutput() QueueRateLimitsOutput

func (QueueRateLimitsArgs) ToQueueRateLimitsOutputWithContext 

func (i QueueRateLimitsArgs) ToQueueRateLimitsOutputWithContext(ctx context.Context) QueueRateLimitsOutput

func (QueueRateLimitsArgs) ToQueueRateLimitsPtrOutput 

func (i QueueRateLimitsArgs) ToQueueRateLimitsPtrOutput() QueueRateLimitsPtrOutput

func (QueueRateLimitsArgs) ToQueueRateLimitsPtrOutputWithContext 

func (i QueueRateLimitsArgs) ToQueueRateLimitsPtrOutputWithContext(ctx context.Context) QueueRateLimitsPtrOutput

type QueueRateLimitsInput 

type QueueRateLimitsInput interface {
	pulumi.Input

	ToQueueRateLimitsOutput() QueueRateLimitsOutput
	ToQueueRateLimitsOutputWithContext(context.Context) QueueRateLimitsOutput
}

QueueRateLimitsInput is an input type that accepts QueueRateLimitsArgs and QueueRateLimitsOutput values. You can construct a concrete instance of `QueueRateLimitsInput` via: 

QueueRateLimitsArgs{...}

type QueueRateLimitsOutput 

type QueueRateLimitsOutput struct{ *pulumi.OutputState }

func (QueueRateLimitsOutput) ElementType 

func (QueueRateLimitsOutput) ElementType() reflect.Type

func (QueueRateLimitsOutput) MaxBurstSize 

func (o QueueRateLimitsOutput) MaxBurstSize() pulumi.IntPtrOutput

func (QueueRateLimitsOutput) MaxConcurrentDispatches 

func (o QueueRateLimitsOutput) MaxConcurrentDispatches() pulumi.IntPtrOutput

func (QueueRateLimitsOutput) MaxDispatchesPerSecond 

func (o QueueRateLimitsOutput) MaxDispatchesPerSecond() pulumi.Float64PtrOutput

func (QueueRateLimitsOutput) ToQueueRateLimitsOutput 

func (o QueueRateLimitsOutput) ToQueueRateLimitsOutput() QueueRateLimitsOutput

func (QueueRateLimitsOutput) ToQueueRateLimitsOutputWithContext 

func (o QueueRateLimitsOutput) ToQueueRateLimitsOutputWithContext(ctx context.Context) QueueRateLimitsOutput

func (QueueRateLimitsOutput) ToQueueRateLimitsPtrOutput 

func (o QueueRateLimitsOutput) ToQueueRateLimitsPtrOutput() QueueRateLimitsPtrOutput

func (QueueRateLimitsOutput) ToQueueRateLimitsPtrOutputWithContext 

func (o QueueRateLimitsOutput) ToQueueRateLimitsPtrOutputWithContext(ctx context.Context) QueueRateLimitsPtrOutput

type QueueRateLimitsPtrInput 

type QueueRateLimitsPtrInput interface {
	pulumi.Input

	ToQueueRateLimitsPtrOutput() QueueRateLimitsPtrOutput
	ToQueueRateLimitsPtrOutputWithContext(context.Context) QueueRateLimitsPtrOutput
}

QueueRateLimitsPtrInput is an input type that accepts QueueRateLimitsArgs, QueueRateLimitsPtr and QueueRateLimitsPtrOutput values. You can construct a concrete instance of `QueueRateLimitsPtrInput` via: 

		 QueueRateLimitsArgs{...}

 or:

		 nil

func QueueRateLimitsPtr 

func QueueRateLimitsPtr(v *QueueRateLimitsArgs) QueueRateLimitsPtrInput

type QueueRateLimitsPtrOutput 

type QueueRateLimitsPtrOutput struct{ *pulumi.OutputState }

func (QueueRateLimitsPtrOutput) Elem 

func (o QueueRateLimitsPtrOutput) Elem() QueueRateLimitsOutput

func (QueueRateLimitsPtrOutput) ElementType 

func (QueueRateLimitsPtrOutput) ElementType() reflect.Type

func (QueueRateLimitsPtrOutput) MaxBurstSize 

func (o QueueRateLimitsPtrOutput) MaxBurstSize() pulumi.IntPtrOutput

func (QueueRateLimitsPtrOutput) MaxConcurrentDispatches 

func (o QueueRateLimitsPtrOutput) MaxConcurrentDispatches() pulumi.IntPtrOutput

func (QueueRateLimitsPtrOutput) MaxDispatchesPerSecond 

func (o QueueRateLimitsPtrOutput) MaxDispatchesPerSecond() pulumi.Float64PtrOutput

func (QueueRateLimitsPtrOutput) ToQueueRateLimitsPtrOutput 

func (o QueueRateLimitsPtrOutput) ToQueueRateLimitsPtrOutput() QueueRateLimitsPtrOutput

func (QueueRateLimitsPtrOutput) ToQueueRateLimitsPtrOutputWithContext 

func (o QueueRateLimitsPtrOutput) ToQueueRateLimitsPtrOutputWithContext(ctx context.Context) QueueRateLimitsPtrOutput

type QueueRetryConfig 

type QueueRetryConfig struct {
	MaxAttempts      *int    `pulumi:"maxAttempts"`
	MaxBackoff       *string `pulumi:"maxBackoff"`
	MaxDoublings     *int    `pulumi:"maxDoublings"`
	MaxRetryDuration *string `pulumi:"maxRetryDuration"`
	MinBackoff       *string `pulumi:"minBackoff"`
}

type QueueRetryConfigArgs 

type QueueRetryConfigArgs struct {
	MaxAttempts      pulumi.IntPtrInput    `pulumi:"maxAttempts"`
	MaxBackoff       pulumi.StringPtrInput `pulumi:"maxBackoff"`
	MaxDoublings     pulumi.IntPtrInput    `pulumi:"maxDoublings"`
	MaxRetryDuration pulumi.StringPtrInput `pulumi:"maxRetryDuration"`
	MinBackoff       pulumi.StringPtrInput `pulumi:"minBackoff"`
}

func (QueueRetryConfigArgs) ElementType 

func (QueueRetryConfigArgs) ElementType() reflect.Type

func (QueueRetryConfigArgs) ToQueueRetryConfigOutput 

func (i QueueRetryConfigArgs) ToQueueRetryConfigOutput() QueueRetryConfigOutput

func (QueueRetryConfigArgs) ToQueueRetryConfigOutputWithContext 

func (i QueueRetryConfigArgs) ToQueueRetryConfigOutputWithContext(ctx context.Context) QueueRetryConfigOutput

func (QueueRetryConfigArgs) ToQueueRetryConfigPtrOutput 

func (i QueueRetryConfigArgs) ToQueueRetryConfigPtrOutput() QueueRetryConfigPtrOutput

func (QueueRetryConfigArgs) ToQueueRetryConfigPtrOutputWithContext 

func (i QueueRetryConfigArgs) ToQueueRetryConfigPtrOutputWithContext(ctx context.Context) QueueRetryConfigPtrOutput

type QueueRetryConfigInput 

type QueueRetryConfigInput interface {
	pulumi.Input

	ToQueueRetryConfigOutput() QueueRetryConfigOutput
	ToQueueRetryConfigOutputWithContext(context.Context) QueueRetryConfigOutput
}

QueueRetryConfigInput is an input type that accepts QueueRetryConfigArgs and QueueRetryConfigOutput values. You can construct a concrete instance of `QueueRetryConfigInput` via: 

QueueRetryConfigArgs{...}

type QueueRetryConfigOutput 

type QueueRetryConfigOutput struct{ *pulumi.OutputState }

func (QueueRetryConfigOutput) ElementType 

func (QueueRetryConfigOutput) ElementType() reflect.Type

func (QueueRetryConfigOutput) MaxAttempts 

func (o QueueRetryConfigOutput) MaxAttempts() pulumi.IntPtrOutput

func (QueueRetryConfigOutput) MaxBackoff 

func (o QueueRetryConfigOutput) MaxBackoff() pulumi.StringPtrOutput

func (QueueRetryConfigOutput) MaxDoublings 

func (o QueueRetryConfigOutput) MaxDoublings() pulumi.IntPtrOutput

func (QueueRetryConfigOutput) MaxRetryDuration 

func (o QueueRetryConfigOutput) MaxRetryDuration() pulumi.StringPtrOutput

func (QueueRetryConfigOutput) MinBackoff 

func (o QueueRetryConfigOutput) MinBackoff() pulumi.StringPtrOutput

func (QueueRetryConfigOutput) ToQueueRetryConfigOutput 

func (o QueueRetryConfigOutput) ToQueueRetryConfigOutput() QueueRetryConfigOutput

func (QueueRetryConfigOutput) ToQueueRetryConfigOutputWithContext 

func (o QueueRetryConfigOutput) ToQueueRetryConfigOutputWithContext(ctx context.Context) QueueRetryConfigOutput

func (QueueRetryConfigOutput) ToQueueRetryConfigPtrOutput 

func (o QueueRetryConfigOutput) ToQueueRetryConfigPtrOutput() QueueRetryConfigPtrOutput

func (QueueRetryConfigOutput) ToQueueRetryConfigPtrOutputWithContext 

func (o QueueRetryConfigOutput) ToQueueRetryConfigPtrOutputWithContext(ctx context.Context) QueueRetryConfigPtrOutput

type QueueRetryConfigPtrInput 

type QueueRetryConfigPtrInput interface {
	pulumi.Input

	ToQueueRetryConfigPtrOutput() QueueRetryConfigPtrOutput
	ToQueueRetryConfigPtrOutputWithContext(context.Context) QueueRetryConfigPtrOutput
}

QueueRetryConfigPtrInput is an input type that accepts QueueRetryConfigArgs, QueueRetryConfigPtr and QueueRetryConfigPtrOutput values. You can construct a concrete instance of `QueueRetryConfigPtrInput` via: 

		 QueueRetryConfigArgs{...}

 or:

		 nil

func QueueRetryConfigPtr 

func QueueRetryConfigPtr(v *QueueRetryConfigArgs) QueueRetryConfigPtrInput

type QueueRetryConfigPtrOutput 

type QueueRetryConfigPtrOutput struct{ *pulumi.OutputState }

func (QueueRetryConfigPtrOutput) Elem 

func (o QueueRetryConfigPtrOutput) Elem() QueueRetryConfigOutput

func (QueueRetryConfigPtrOutput) ElementType 

func (QueueRetryConfigPtrOutput) ElementType() reflect.Type

func (QueueRetryConfigPtrOutput) MaxAttempts 

func (o QueueRetryConfigPtrOutput) MaxAttempts() pulumi.IntPtrOutput

func (QueueRetryConfigPtrOutput) MaxBackoff 

func (o QueueRetryConfigPtrOutput) MaxBackoff() pulumi.StringPtrOutput

func (QueueRetryConfigPtrOutput) MaxDoublings 

func (o QueueRetryConfigPtrOutput) MaxDoublings() pulumi.IntPtrOutput

func (QueueRetryConfigPtrOutput) MaxRetryDuration 

func (o QueueRetryConfigPtrOutput) MaxRetryDuration() pulumi.StringPtrOutput

func (QueueRetryConfigPtrOutput) MinBackoff 

func (o QueueRetryConfigPtrOutput) MinBackoff() pulumi.StringPtrOutput

func (QueueRetryConfigPtrOutput) ToQueueRetryConfigPtrOutput 

func (o QueueRetryConfigPtrOutput) ToQueueRetryConfigPtrOutput() QueueRetryConfigPtrOutput

func (QueueRetryConfigPtrOutput) ToQueueRetryConfigPtrOutputWithContext 

func (o QueueRetryConfigPtrOutput) ToQueueRetryConfigPtrOutputWithContext(ctx context.Context) QueueRetryConfigPtrOutput

type QueueState 

type QueueState struct {
	// Overrides for task-level appEngineRouting. These settings apply only to App Engine tasks in this queue
	AppEngineRoutingOverride QueueAppEngineRoutingOverridePtrInput
	// The location of the queue
	Location pulumi.StringPtrInput
	// The queue name.
	Name pulumi.StringPtrInput
	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	Project pulumi.StringPtrInput
	// Rate limits for task dispatches. The queue's actual dispatch rate is the result of: * Number of tasks in the queue *
	// User-specified throttling: rateLimits, retryConfig, and the queue's state. * System throttling due to 429 (Too Many
	// Requests) or 503 (Service Unavailable) responses from the worker, high error rates, or to smooth sudden large traffic
	// spikes.
	RateLimits QueueRateLimitsPtrInput
	// Settings that determine the retry behavior.
	RetryConfig QueueRetryConfigPtrInput
}

func (QueueState) ElementType 

func (QueueState) ElementType() reflect.Type

Source Files

View all Source files

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.