v1beta1

package
v1.43.0 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Generate deepcopy object for dataflow/v1beta1 API group

Package v1beta1 contains API Schema definitions for the dataflow v1beta1 API group. +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:conversion-gen=github.com/GoogleCloudPlatform/k8s-config-connector/pkg/apis/dataflow +k8s:defaulter-gen=TypeMeta +groupName=dataflow.cnrm.cloud.google.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SchemeGroupVersion is the group version used to register these objects.
	SchemeGroupVersion = schema.GroupVersion{Group: "dataflow.cnrm.cloud.google.com", Version: "v1beta1"}

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

	DataflowFlexTemplateJobGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DataflowFlexTemplateJob{}).Name(),
	}

	DataflowJobGVK = schema.GroupVersionKind{
		Group:   SchemeGroupVersion.Group,
		Version: SchemeGroupVersion.Version,
		Kind:    reflect.TypeOf(DataflowJob{}).Name(),
	}
)

Functions

This section is empty.

Types

type DataflowFlexTemplateJob 

type DataflowFlexTemplateJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataflowFlexTemplateJobSpec   `json:"spec,omitempty"`
	Status DataflowFlexTemplateJobStatus `json:"status,omitempty"`
}

DataflowFlexTemplateJob is the Schema for the dataflow API +k8s:openapi-gen=true

func (*DataflowFlexTemplateJob) DeepCopy 

func (in *DataflowFlexTemplateJob) DeepCopy() *DataflowFlexTemplateJob

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

func (*DataflowFlexTemplateJob) DeepCopyInto 

func (in *DataflowFlexTemplateJob) DeepCopyInto(out *DataflowFlexTemplateJob)

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

func (*DataflowFlexTemplateJob) DeepCopyObject 

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

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

type DataflowFlexTemplateJobList 

type DataflowFlexTemplateJobList struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Items             []DataflowFlexTemplateJob `json:"items"`
}

DataflowFlexTemplateJobList contains a list of DataflowFlexTemplateJob

func (*DataflowFlexTemplateJobList) DeepCopy 

func (in *DataflowFlexTemplateJobList) DeepCopy() *DataflowFlexTemplateJobList

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

func (*DataflowFlexTemplateJobList) DeepCopyInto 

func (in *DataflowFlexTemplateJobList) DeepCopyInto(out *DataflowFlexTemplateJobList)

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

func (*DataflowFlexTemplateJobList) DeepCopyObject 

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

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

type DataflowFlexTemplateJobSpec 

type DataflowFlexTemplateJobSpec struct {
	/* Immutable. */
	ContainerSpecGcsPath string `json:"containerSpecGcsPath,omitempty"`
	/* Immutable. */
	Parameters DataflowflextemplatejobParameters `json:"parameters,omitempty"`
	/* Immutable. The region in which the created job should run. */
	Region string `json:"region,omitempty"`
}

func (*DataflowFlexTemplateJobSpec) DeepCopy 

func (in *DataflowFlexTemplateJobSpec) DeepCopy() *DataflowFlexTemplateJobSpec

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

func (*DataflowFlexTemplateJobSpec) DeepCopyInto 

func (in *DataflowFlexTemplateJobSpec) DeepCopyInto(out *DataflowFlexTemplateJobSpec)

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

type DataflowFlexTemplateJobStatus 

type DataflowFlexTemplateJobStatus struct {
	/* Conditions represents the latest available observations of the
	   DataflowFlexTemplateJob's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/*  */
	JobId string `json:"jobId,omitempty"`
	/*  */
	State string `json:"state,omitempty"`
}

func (*DataflowFlexTemplateJobStatus) DeepCopy 

func (in *DataflowFlexTemplateJobStatus) DeepCopy() *DataflowFlexTemplateJobStatus

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

func (*DataflowFlexTemplateJobStatus) DeepCopyInto 

func (in *DataflowFlexTemplateJobStatus) DeepCopyInto(out *DataflowFlexTemplateJobStatus)

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

type DataflowJob 

type DataflowJob struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataflowJobSpec   `json:"spec,omitempty"`
	Status DataflowJobStatus `json:"status,omitempty"`
}

DataflowJob is the Schema for the dataflow API +k8s:openapi-gen=true

func (*DataflowJob) DeepCopy 

func (in *DataflowJob) DeepCopy() *DataflowJob

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

func (*DataflowJob) DeepCopyInto 

func (in *DataflowJob) DeepCopyInto(out *DataflowJob)

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

func (*DataflowJob) DeepCopyObject 

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

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

type DataflowJobList 

type DataflowJobList struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Items             []DataflowJob `json:"items"`
}

DataflowJobList contains a list of DataflowJob

func (*DataflowJobList) DeepCopy 

func (in *DataflowJobList) DeepCopy() *DataflowJobList

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

func (*DataflowJobList) DeepCopyInto 

func (in *DataflowJobList) DeepCopyInto(out *DataflowJobList)

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

func (*DataflowJobList) DeepCopyObject 

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

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

type DataflowJobSpec 

type DataflowJobSpec struct {
	/* List of experiments that should be used by the job. An example value is ["enable_stackdriver_agent_metrics"]. */
	AdditionalExperiments []string `json:"additionalExperiments,omitempty"`
	/* The configuration for VM IPs. Options are "WORKER_IP_PUBLIC" or "WORKER_IP_PRIVATE". */
	IpConfiguration string `json:"ipConfiguration,omitempty"`
	/* The name for the Cloud KMS key for the job. */
	KmsKeyRef v1alpha1.ResourceRef `json:"kmsKeyRef,omitempty"`
	/* The machine type to use for the job. */
	MachineType string `json:"machineType,omitempty"`
	/* Immutable. The number of workers permitted to work on the job. More workers may improve processing speed at additional cost. */
	MaxWorkers int `json:"maxWorkers,omitempty"`
	/*  */
	NetworkRef v1alpha1.ResourceRef `json:"networkRef,omitempty"`
	/* Key/Value pairs to be passed to the Dataflow job (as used in the template). */
	Parameters Parameters `json:"parameters,omitempty"`
	/* Immutable. The region in which the created job should run. */
	Region string `json:"region,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. */
	ResourceID string `json:"resourceID,omitempty"`
	/*  */
	ServiceAccountRef v1alpha1.ResourceRef `json:"serviceAccountRef,omitempty"`
	/*  */
	SubnetworkRef v1alpha1.ResourceRef `json:"subnetworkRef,omitempty"`
	/* A writeable location on Google Cloud Storage for the Dataflow job to dump its temporary data. */
	TempGcsLocation string `json:"tempGcsLocation,omitempty"`
	/* The Google Cloud Storage path to the Dataflow job template. */
	TemplateGcsPath string `json:"templateGcsPath,omitempty"`
	/* Only applicable when updating a pipeline. Map of transform name prefixes of the job to be replaced with the corresponding name prefixes of the new job. */
	TransformNameMapping TransformNameMapping `json:"transformNameMapping,omitempty"`
	/* Immutable. The zone in which the created job should run. If it is not provided, the provider zone is used. */
	Zone string `json:"zone,omitempty"`
}

func (*DataflowJobSpec) DeepCopy 

func (in *DataflowJobSpec) DeepCopy() *DataflowJobSpec

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

func (*DataflowJobSpec) DeepCopyInto 

func (in *DataflowJobSpec) DeepCopyInto(out *DataflowJobSpec)

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

type DataflowJobStatus 

type DataflowJobStatus struct {
	/* Conditions represents the latest available observations of the
	   DataflowJob's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	/* The unique ID of this job. */
	JobId string `json:"jobId,omitempty"`
	/* The current state of the resource, selected from the JobState enum. */
	State string `json:"state,omitempty"`
	/* The type of this job, selected from the JobType enum. */
	Type string `json:"type,omitempty"`
}

func (*DataflowJobStatus) DeepCopy 

func (in *DataflowJobStatus) DeepCopy() *DataflowJobStatus

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

func (*DataflowJobStatus) DeepCopyInto 

func (in *DataflowJobStatus) DeepCopyInto(out *DataflowJobStatus)

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

type DataflowflextemplatejobParameters 

type DataflowflextemplatejobParameters struct {
}

func (*DataflowflextemplatejobParameters) DeepCopy 

func (in *DataflowflextemplatejobParameters) DeepCopy() *DataflowflextemplatejobParameters

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

func (*DataflowflextemplatejobParameters) DeepCopyInto 

func (in *DataflowflextemplatejobParameters) DeepCopyInto(out *DataflowflextemplatejobParameters)

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

type Parameters 

type Parameters struct {
}

func (*Parameters) DeepCopy 

func (in *Parameters) DeepCopy() *Parameters

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

func (*Parameters) DeepCopyInto 

func (in *Parameters) DeepCopyInto(out *Parameters)

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

type TransformNameMapping 

type TransformNameMapping struct {
}

func (*TransformNameMapping) DeepCopy 

func (in *TransformNameMapping) DeepCopy() *TransformNameMapping

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

func (*TransformNameMapping) DeepCopyInto 

func (in *TransformNameMapping) DeepCopyInto(out *TransformNameMapping)

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.