v1beta1

package
v0.30.0 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Overview

+kubebuilder:object:generate=true +groupName=cloudtasks.gcp.upbound.io +versionName=v1beta1

Index

Constants

View Source 
const (
	CRDGroup   = "cloudtasks.gcp.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

View Source 
var (
	// CRDGroupVersion is the API Group Version used to register the objects
	CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var (
	Queue_Kind             = "Queue"
	Queue_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Queue_Kind}.String()
	Queue_KindAPIVersion   = Queue_Kind + "." + CRDGroupVersion.String()
	Queue_GroupVersionKind = CRDGroupVersion.WithKind(Queue_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type AppEngineRoutingOverrideObservation 

type AppEngineRoutingOverrideObservation struct {

	// The host that the task is sent to.
	Host *string `json:"host,omitempty" tf:"host,omitempty"`
}

func (*AppEngineRoutingOverrideObservation) DeepCopy 

func (in *AppEngineRoutingOverrideObservation) DeepCopy() *AppEngineRoutingOverrideObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AppEngineRoutingOverrideObservation.

func (*AppEngineRoutingOverrideObservation) DeepCopyInto 

func (in *AppEngineRoutingOverrideObservation) DeepCopyInto(out *AppEngineRoutingOverrideObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type AppEngineRoutingOverrideParameters 

type AppEngineRoutingOverrideParameters struct {

	// App instance.
	// By default, the task is sent to an instance which is available when the task is attempted.
	// +kubebuilder:validation:Optional
	Instance *string `json:"instance,omitempty" tf:"instance,omitempty"`

	// App service.
	// By default, the task is sent to the service which is the default service when the task is attempted.
	// +kubebuilder:validation:Optional
	Service *string `json:"service,omitempty" tf:"service,omitempty"`

	// App version.
	// By default, the task is sent to the version which is the default version when the task is attempted.
	// +kubebuilder:validation:Optional
	Version *string `json:"version,omitempty" tf:"version,omitempty"`
}

func (*AppEngineRoutingOverrideParameters) DeepCopy 

func (in *AppEngineRoutingOverrideParameters) DeepCopy() *AppEngineRoutingOverrideParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AppEngineRoutingOverrideParameters.

func (*AppEngineRoutingOverrideParameters) DeepCopyInto 

func (in *AppEngineRoutingOverrideParameters) DeepCopyInto(out *AppEngineRoutingOverrideParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Queue 

type Queue struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              QueueSpec   `json:"spec"`
	Status            QueueStatus `json:"status,omitempty"`
}

Queue is the Schema for the Queues API. A named resource to which messages are sent by publishers. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,gcp}

func (*Queue) DeepCopy 

func (in *Queue) DeepCopy() *Queue

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Queue.

func (*Queue) DeepCopyInto 

func (in *Queue) DeepCopyInto(out *Queue)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Queue) DeepCopyObject 

func (in *Queue) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Queue) GetCondition 

func (mg *Queue) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Queue.

func (*Queue) GetConnectionDetailsMapping 

func (tr *Queue) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Queue

func (*Queue) GetDeletionPolicy 

func (mg *Queue) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Queue.

func (*Queue) GetID 

func (tr *Queue) GetID() string

GetID returns ID of underlying Terraform resource of this Queue

func (*Queue) GetObservation 

func (tr *Queue) GetObservation() (map[string]any, error)

GetObservation of this Queue

func (*Queue) GetParameters 

func (tr *Queue) GetParameters() (map[string]any, error)

GetParameters of this Queue

func (*Queue) GetProviderConfigReference 

func (mg *Queue) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Queue.

func (*Queue) GetProviderReference 

func (mg *Queue) GetProviderReference() *xpv1.Reference

GetProviderReference of this Queue. Deprecated: Use GetProviderConfigReference.

func (*Queue) GetPublishConnectionDetailsTo 

func (mg *Queue) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Queue.

func (*Queue) GetTerraformResourceType 

func (mg *Queue) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Queue

func (*Queue) GetTerraformSchemaVersion 

func (tr *Queue) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Queue) GetWriteConnectionSecretToReference 

func (mg *Queue) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Queue.

func (*Queue) LateInitialize 

func (tr *Queue) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Queue using its observed tfState. returns True if there are any spec changes for the resource.

func (*Queue) ResolveReferences 

func (mg *Queue) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Queue.

func (*Queue) SetConditions 

func (mg *Queue) SetConditions(c ...xpv1.Condition)

SetConditions of this Queue.

func (*Queue) SetDeletionPolicy 

func (mg *Queue) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Queue.

func (*Queue) SetObservation 

func (tr *Queue) SetObservation(obs map[string]any) error

SetObservation for this Queue

func (*Queue) SetParameters 

func (tr *Queue) SetParameters(params map[string]any) error

SetParameters for this Queue

func (*Queue) SetProviderConfigReference 

func (mg *Queue) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Queue.

func (*Queue) SetProviderReference 

func (mg *Queue) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Queue. Deprecated: Use SetProviderConfigReference.

func (*Queue) SetPublishConnectionDetailsTo 

func (mg *Queue) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Queue.

func (*Queue) SetWriteConnectionSecretToReference 

func (mg *Queue) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Queue.

type QueueList 

type QueueList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Queue `json:"items"`
}

QueueList contains a list of Queues

func (*QueueList) DeepCopy 

func (in *QueueList) DeepCopy() *QueueList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueList.

func (*QueueList) DeepCopyInto 

func (in *QueueList) DeepCopyInto(out *QueueList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*QueueList) DeepCopyObject 

func (in *QueueList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*QueueList) GetItems 

func (l *QueueList) GetItems() []resource.Managed

GetItems of this QueueList.

type QueueObservation 

type QueueObservation struct {

	// Overrides for task-level appEngineRouting. These settings apply only
	// to App Engine tasks in this queue
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AppEngineRoutingOverride []AppEngineRoutingOverrideObservation `json:"appEngineRoutingOverride,omitempty" tf:"app_engine_routing_override,omitempty"`

	// an identifier for the resource with format projects/{{project}}/locations/{{location}}/queues/{{name}}
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Rate limits for task dispatches.
	// The queue's actual dispatch rate is the result of:
	// +kubebuilder:validation:Optional
	RateLimits []RateLimitsObservation `json:"rateLimits,omitempty" tf:"rate_limits,omitempty"`
}

func (*QueueObservation) DeepCopy 

func (in *QueueObservation) DeepCopy() *QueueObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueObservation.

func (*QueueObservation) DeepCopyInto 

func (in *QueueObservation) DeepCopyInto(out *QueueObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueParameters 

type QueueParameters struct {

	// Overrides for task-level appEngineRouting. These settings apply only
	// to App Engine tasks in this queue
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	AppEngineRoutingOverride []AppEngineRoutingOverrideParameters `json:"appEngineRoutingOverride,omitempty" tf:"app_engine_routing_override,omitempty"`

	// The location of the queue
	// +kubebuilder:validation:Required
	Location *string `json:"location" tf:"location,omitempty"`

	// The ID of the project in which the resource belongs.
	// If it is not provided, the provider project is used.
	// +crossplane:generate:reference:type=github.com/upbound/provider-gcp/apis/cloudplatform/v1beta1.Project
	// +kubebuilder:validation:Optional
	Project *string `json:"project,omitempty" tf:"project,omitempty"`

	// Reference to a Project in cloudplatform to populate project.
	// +kubebuilder:validation:Optional
	ProjectRef *v1.Reference `json:"projectRef,omitempty" tf:"-"`

	// Selector for a Project in cloudplatform to populate project.
	// +kubebuilder:validation:Optional
	ProjectSelector *v1.Selector `json:"projectSelector,omitempty" tf:"-"`

	// Rate limits for task dispatches.
	// The queue's actual dispatch rate is the result of:
	// +kubebuilder:validation:Optional
	RateLimits []RateLimitsParameters `json:"rateLimits,omitempty" tf:"rate_limits,omitempty"`

	// Settings that determine the retry behavior.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	RetryConfig []RetryConfigParameters `json:"retryConfig,omitempty" tf:"retry_config,omitempty"`

	// Configuration options for writing logs to Stackdriver Logging.
	// Structure is documented below.
	// +kubebuilder:validation:Optional
	StackdriverLoggingConfig []StackdriverLoggingConfigParameters `json:"stackdriverLoggingConfig,omitempty" tf:"stackdriver_logging_config,omitempty"`
}

func (*QueueParameters) DeepCopy 

func (in *QueueParameters) DeepCopy() *QueueParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueParameters.

func (*QueueParameters) DeepCopyInto 

func (in *QueueParameters) DeepCopyInto(out *QueueParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueSpec 

type QueueSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     QueueParameters `json:"forProvider"`
}

QueueSpec defines the desired state of Queue

func (*QueueSpec) DeepCopy 

func (in *QueueSpec) DeepCopy() *QueueSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueSpec.

func (*QueueSpec) DeepCopyInto 

func (in *QueueSpec) DeepCopyInto(out *QueueSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type QueueStatus 

type QueueStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        QueueObservation `json:"atProvider,omitempty"`
}

QueueStatus defines the observed state of Queue.

func (*QueueStatus) DeepCopy 

func (in *QueueStatus) DeepCopy() *QueueStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueStatus.

func (*QueueStatus) DeepCopyInto 

func (in *QueueStatus) DeepCopyInto(out *QueueStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RateLimitsObservation 

type RateLimitsObservation struct {

	// The max burst size.
	// Max burst size limits how fast tasks in queue are processed when many tasks are
	// in the queue and the rate is high. This field allows the queue to have a high
	// rate so processing starts shortly after a task is enqueued, but still limits
	// resource usage when many tasks are enqueued in a short period of time.
	MaxBurstSize *float64 `json:"maxBurstSize,omitempty" tf:"max_burst_size,omitempty"`
}

func (*RateLimitsObservation) DeepCopy 

func (in *RateLimitsObservation) DeepCopy() *RateLimitsObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitsObservation.

func (*RateLimitsObservation) DeepCopyInto 

func (in *RateLimitsObservation) DeepCopyInto(out *RateLimitsObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RateLimitsParameters 

type RateLimitsParameters struct {

	// The maximum number of concurrent tasks that Cloud Tasks allows to
	// be dispatched for this queue. After this threshold has been
	// reached, Cloud Tasks stops dispatching tasks until the number of
	// concurrent requests decreases.
	// +kubebuilder:validation:Optional
	MaxConcurrentDispatches *float64 `json:"maxConcurrentDispatches,omitempty" tf:"max_concurrent_dispatches,omitempty"`

	// The maximum rate at which tasks are dispatched from this queue.
	// If unspecified when the queue is created, Cloud Tasks will pick the default.
	// +kubebuilder:validation:Optional
	MaxDispatchesPerSecond *float64 `json:"maxDispatchesPerSecond,omitempty" tf:"max_dispatches_per_second,omitempty"`
}

func (*RateLimitsParameters) DeepCopy 

func (in *RateLimitsParameters) DeepCopy() *RateLimitsParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RateLimitsParameters.

func (*RateLimitsParameters) DeepCopyInto 

func (in *RateLimitsParameters) DeepCopyInto(out *RateLimitsParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryConfigObservation 

type RetryConfigObservation struct {
}

func (*RetryConfigObservation) DeepCopy 

func (in *RetryConfigObservation) DeepCopy() *RetryConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryConfigObservation.

func (*RetryConfigObservation) DeepCopyInto 

func (in *RetryConfigObservation) DeepCopyInto(out *RetryConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type RetryConfigParameters 

type RetryConfigParameters struct {

	// Number of attempts per task.
	// Cloud Tasks will attempt the task maxAttempts times (that is, if
	// the first attempt fails, then there will be maxAttempts - 1
	// retries). Must be >= -1.
	// If unspecified when the queue is created, Cloud Tasks will pick
	// the default.
	// -1 indicates unlimited attempts.
	// +kubebuilder:validation:Optional
	MaxAttempts *float64 `json:"maxAttempts,omitempty" tf:"max_attempts,omitempty"`

	// A task will be scheduled for retry between minBackoff and
	// maxBackoff duration after it fails, if the queue's RetryConfig
	// specifies that the task should be retried.
	// +kubebuilder:validation:Optional
	MaxBackoff *string `json:"maxBackoff,omitempty" tf:"max_backoff,omitempty"`

	// The time between retries will double maxDoublings times.
	// A task's retry interval starts at minBackoff, then doubles maxDoublings times,
	// then increases linearly, and finally retries retries at intervals of maxBackoff
	// up to maxAttempts times.
	// +kubebuilder:validation:Optional
	MaxDoublings *float64 `json:"maxDoublings,omitempty" tf:"max_doublings,omitempty"`

	// If positive, maxRetryDuration specifies the time limit for
	// retrying a failed task, measured from when the task was first
	// attempted. Once maxRetryDuration time has passed and the task has
	// been attempted maxAttempts times, no further attempts will be
	// made and the task will be deleted.
	// If zero, then the task age is unlimited.
	// +kubebuilder:validation:Optional
	MaxRetryDuration *string `json:"maxRetryDuration,omitempty" tf:"max_retry_duration,omitempty"`

	// A task will be scheduled for retry between minBackoff and
	// maxBackoff duration after it fails, if the queue's RetryConfig
	// specifies that the task should be retried.
	// +kubebuilder:validation:Optional
	MinBackoff *string `json:"minBackoff,omitempty" tf:"min_backoff,omitempty"`
}

func (*RetryConfigParameters) DeepCopy 

func (in *RetryConfigParameters) DeepCopy() *RetryConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RetryConfigParameters.

func (*RetryConfigParameters) DeepCopyInto 

func (in *RetryConfigParameters) DeepCopyInto(out *RetryConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StackdriverLoggingConfigObservation 

type StackdriverLoggingConfigObservation struct {
}

func (*StackdriverLoggingConfigObservation) DeepCopy 

func (in *StackdriverLoggingConfigObservation) DeepCopy() *StackdriverLoggingConfigObservation

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StackdriverLoggingConfigObservation.

func (*StackdriverLoggingConfigObservation) DeepCopyInto 

func (in *StackdriverLoggingConfigObservation) DeepCopyInto(out *StackdriverLoggingConfigObservation)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type StackdriverLoggingConfigParameters 

type StackdriverLoggingConfigParameters struct {

	// Specifies the fraction of operations to write to Stackdriver Logging.
	// This field may contain any value between 0.0 and 1.0, inclusive. 0.0 is the
	// default and means that no operations are logged.
	// +kubebuilder:validation:Required
	SamplingRatio *float64 `json:"samplingRatio" tf:"sampling_ratio,omitempty"`
}

func (*StackdriverLoggingConfigParameters) DeepCopy 

func (in *StackdriverLoggingConfigParameters) DeepCopy() *StackdriverLoggingConfigParameters

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StackdriverLoggingConfigParameters.

func (*StackdriverLoggingConfigParameters) DeepCopyInto 

func (in *StackdriverLoggingConfigParameters) DeepCopyInto(out *StackdriverLoggingConfigParameters)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

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.