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 ¶
- Variables
- type DataflowFlexTemplateJob
- type DataflowFlexTemplateJobList
- type DataflowFlexTemplateJobSpec
- type DataflowFlexTemplateJobStatus
- type DataflowJob
- type DataflowJobList
- type DataflowJobSpec
- type DataflowJobStatus
- type FlextemplatejobParameters
- type JobParameters
- type JobTransformNameMapping
Constants ¶
This section is empty.
Variables ¶
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.ListMeta `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 FlextemplatejobParameters `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 represent 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.ListMeta `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"` /* Indicates if the job should use the streaming engine feature. */ EnableStreamingEngine bool `json:"enableStreamingEngine,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 JobParameters `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 JobTransformNameMapping `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 represent 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 FlextemplatejobParameters ¶ added in v1.45.0
type FlextemplatejobParameters struct { }
func (*FlextemplatejobParameters) DeepCopy ¶ added in v1.45.0
func (in *FlextemplatejobParameters) DeepCopy() *FlextemplatejobParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FlextemplatejobParameters.
func (*FlextemplatejobParameters) DeepCopyInto ¶ added in v1.45.0
func (in *FlextemplatejobParameters) DeepCopyInto(out *FlextemplatejobParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobParameters ¶ added in v1.45.0
type JobParameters struct { }
func (*JobParameters) DeepCopy ¶ added in v1.45.0
func (in *JobParameters) DeepCopy() *JobParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobParameters.
func (*JobParameters) DeepCopyInto ¶ added in v1.45.0
func (in *JobParameters) DeepCopyInto(out *JobParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JobTransformNameMapping ¶ added in v1.45.0
type JobTransformNameMapping struct { }
func (*JobTransformNameMapping) DeepCopy ¶ added in v1.45.0
func (in *JobTransformNameMapping) DeepCopy() *JobTransformNameMapping
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JobTransformNameMapping.
func (*JobTransformNameMapping) DeepCopyInto ¶ added in v1.45.0
func (in *JobTransformNameMapping) DeepCopyInto(out *JobTransformNameMapping)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.