Documentation
¶
Overview ¶
Package v1alpha1 contains API Schema definitions for the cloudtasks v1alpha1 API group. +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/pkg/apis/cloudtasks +k8s:defaulter-gen=TypeMeta +groupName=cloudtasks.cnrm.cloud.google.com
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // SchemeGroupVersion is the group version used to register these objects. SchemeGroupVersion = schema.GroupVersion{Group: "cloudtasks.cnrm.cloud.google.com", Version: "v1alpha1"} // SchemeBuilder is used to add go types to the GroupVersionKind scheme. SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion} // AddToScheme is a global function that registers this API group & version to a scheme AddToScheme = SchemeBuilder.AddToScheme CloudTasksQueueGVK = schema.GroupVersionKind{ Group: SchemeGroupVersion.Group, Version: SchemeGroupVersion.Version, Kind: reflect.TypeOf(CloudTasksQueue{}).Name(), } )
Functions ¶
This section is empty.
Types ¶
type CloudTasksQueue ¶
type CloudTasksQueue struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec CloudTasksQueueSpec `json:"spec,omitempty"`
Status CloudTasksQueueStatus `json:"status,omitempty"`
}
CloudTasksQueue is the Schema for the cloudtasks API +k8s:openapi-gen=true
func (*CloudTasksQueue) DeepCopy ¶
func (in *CloudTasksQueue) DeepCopy() *CloudTasksQueue
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudTasksQueue.
func (*CloudTasksQueue) DeepCopyInto ¶
func (in *CloudTasksQueue) DeepCopyInto(out *CloudTasksQueue)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CloudTasksQueue) DeepCopyObject ¶
func (in *CloudTasksQueue) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CloudTasksQueueList ¶
type CloudTasksQueueList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []CloudTasksQueue `json:"items"`
}
CloudTasksQueueList contains a list of CloudTasksQueue
func (*CloudTasksQueueList) DeepCopy ¶
func (in *CloudTasksQueueList) DeepCopy() *CloudTasksQueueList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudTasksQueueList.
func (*CloudTasksQueueList) DeepCopyInto ¶
func (in *CloudTasksQueueList) DeepCopyInto(out *CloudTasksQueueList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CloudTasksQueueList) DeepCopyObject ¶
func (in *CloudTasksQueueList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
type CloudTasksQueueSpec ¶
type CloudTasksQueueSpec struct {
/* Overrides for task-level appEngineRouting. These settings apply only
to App Engine tasks in this queue. */
// +optional
AppEngineRoutingOverride *QueueAppEngineRoutingOverride `json:"appEngineRoutingOverride,omitempty"`
/* Immutable. The location of the queue. */
Location string `json:"location"`
/* The project that this resource belongs to. */
ProjectRef v1alpha1.ResourceRef `json:"projectRef"`
/* 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. */
// +optional
RateLimits *QueueRateLimits `json:"rateLimits,omitempty"`
/* Immutable. Optional. The name of the resource. Used for creation and acquisition. When unset, the value of `metadata.name` is used as the default. */
// +optional
ResourceID *string `json:"resourceID,omitempty"`
/* Settings that determine the retry behavior. */
// +optional
RetryConfig *QueueRetryConfig `json:"retryConfig,omitempty"`
/* Configuration options for writing logs to Stackdriver Logging. */
// +optional
StackdriverLoggingConfig *QueueStackdriverLoggingConfig `json:"stackdriverLoggingConfig,omitempty"`
}
func (*CloudTasksQueueSpec) DeepCopy ¶
func (in *CloudTasksQueueSpec) DeepCopy() *CloudTasksQueueSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudTasksQueueSpec.
func (*CloudTasksQueueSpec) DeepCopyInto ¶
func (in *CloudTasksQueueSpec) DeepCopyInto(out *CloudTasksQueueSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudTasksQueueStatus ¶
type CloudTasksQueueStatus struct {
/* Conditions represent the latest available observations of the
CloudTasksQueue's current state. */
Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
/* ObservedGeneration is the generation of the resource that was most recently observed by the Config Connector controller. If this is equal to metadata.generation, then that means that the current reported status reflects the most recent desired state of the resource. */
// +optional
ObservedGeneration *int64 `json:"observedGeneration,omitempty"`
}
func (*CloudTasksQueueStatus) DeepCopy ¶
func (in *CloudTasksQueueStatus) DeepCopy() *CloudTasksQueueStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudTasksQueueStatus.
func (*CloudTasksQueueStatus) DeepCopyInto ¶
func (in *CloudTasksQueueStatus) DeepCopyInto(out *CloudTasksQueueStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueAppEngineRoutingOverride ¶
type QueueAppEngineRoutingOverride struct {
/* The host that the task is sent to. */
// +optional
Host *string `json:"host,omitempty"`
/* App instance.
By default, the task is sent to an instance which is available when the task is attempted. */
// +optional
Instance *string `json:"instance,omitempty"`
/* App service.
By default, the task is sent to the service which is the default service when the task is attempted. */
// +optional
Service *string `json:"service,omitempty"`
/* App version.
By default, the task is sent to the version which is the default version when the task is attempted. */
// +optional
Version *string `json:"version,omitempty"`
}
func (*QueueAppEngineRoutingOverride) DeepCopy ¶
func (in *QueueAppEngineRoutingOverride) DeepCopy() *QueueAppEngineRoutingOverride
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueAppEngineRoutingOverride.
func (*QueueAppEngineRoutingOverride) DeepCopyInto ¶
func (in *QueueAppEngineRoutingOverride) DeepCopyInto(out *QueueAppEngineRoutingOverride)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueRateLimits ¶
type QueueRateLimits 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. */
// +optional
MaxBurstSize *int64 `json:"maxBurstSize,omitempty"`
/* 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. */
// +optional
MaxConcurrentDispatches *int64 `json:"maxConcurrentDispatches,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. */
// +optional
MaxDispatchesPerSecond *float64 `json:"maxDispatchesPerSecond,omitempty"`
}
func (*QueueRateLimits) DeepCopy ¶
func (in *QueueRateLimits) DeepCopy() *QueueRateLimits
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRateLimits.
func (*QueueRateLimits) DeepCopyInto ¶
func (in *QueueRateLimits) DeepCopyInto(out *QueueRateLimits)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueRetryConfig ¶
type QueueRetryConfig 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. */
// +optional
MaxAttempts *int64 `json:"maxAttempts,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. */
// +optional
MaxBackoff *string `json:"maxBackoff,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. */
// +optional
MaxDoublings *int64 `json:"maxDoublings,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. */
// +optional
MaxRetryDuration *string `json:"maxRetryDuration,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. */
// +optional
MinBackoff *string `json:"minBackoff,omitempty"`
}
func (*QueueRetryConfig) DeepCopy ¶
func (in *QueueRetryConfig) DeepCopy() *QueueRetryConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueRetryConfig.
func (*QueueRetryConfig) DeepCopyInto ¶
func (in *QueueRetryConfig) DeepCopyInto(out *QueueRetryConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type QueueStackdriverLoggingConfig ¶
type QueueStackdriverLoggingConfig 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. */
SamplingRatio float64 `json:"samplingRatio"`
}
func (*QueueStackdriverLoggingConfig) DeepCopy ¶
func (in *QueueStackdriverLoggingConfig) DeepCopy() *QueueStackdriverLoggingConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new QueueStackdriverLoggingConfig.
func (*QueueStackdriverLoggingConfig) DeepCopyInto ¶
func (in *QueueStackdriverLoggingConfig) DeepCopyInto(out *QueueStackdriverLoggingConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files