v1beta1

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

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

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

type DataflowFlexTemplateJobSpec struct {
	/* List of experiments that should be used by the job. An example value is ["enable_stackdriver_agent_metrics"]. */
	// +optional
	AdditionalExperiments []string `json:"additionalExperiments,omitempty"`

	/* The algorithm to use for autoscaling. */
	// +optional
	AutoscalingAlgorithm *string `json:"autoscalingAlgorithm,omitempty"`

	ContainerSpecGcsPath string `json:"containerSpecGcsPath"`

	/* Immutable. Indicates if the job should use the streaming engine feature. */
	// +optional
	EnableStreamingEngine *bool `json:"enableStreamingEngine,omitempty"`

	/* The configuration for VM IPs. Options are "WORKER_IP_PUBLIC" or "WORKER_IP_PRIVATE". */
	// +optional
	IpConfiguration *string `json:"ipConfiguration,omitempty"`

	/* The name for the Cloud KMS key for the job. */
	// +optional
	KmsKeyNameRef *v1alpha1.ResourceRef `json:"kmsKeyNameRef,omitempty"`

	/* The machine type to use for launching the job. The default is n1-standard-1. */
	// +optional
	LauncherMachineType *string `json:"launcherMachineType,omitempty"`

	/* The machine type to use for the job. */
	// +optional
	MachineType *string `json:"machineType,omitempty"`

	/* Immutable. The maximum number of Google Compute Engine instances to be made available to your pipeline during execution, from 1 to 1000. */
	// +optional
	MaxWorkers *int `json:"maxWorkers,omitempty"`

	// +optional
	NetworkRef *v1alpha1.ResourceRef `json:"networkRef,omitempty"`

	/* Immutable. The initial number of Google Compute Engine instances for the job. */
	// +optional
	NumWorkers *int `json:"numWorkers,omitempty"`

	// +optional
	Parameters *FlextemplatejobParameters `json:"parameters,omitempty"`

	/* Immutable. The region in which the created job should run. */
	// +optional
	Region *string `json:"region,omitempty"`

	/* Docker registry location of container image to use for the 'worker harness. Default is the container for the version of the SDK. Note this field is only valid for portable pipelines. */
	// +optional
	SdkContainerImage *string `json:"sdkContainerImage,omitempty"`

	// +optional
	ServiceAccountEmailRef *v1alpha1.ResourceRef `json:"serviceAccountEmailRef,omitempty"`

	/* The Cloud Storage path to use for staging files. Must be a valid Cloud Storage URL, beginning with gs://. */
	// +optional
	StagingLocation *string `json:"stagingLocation,omitempty"`

	// +optional
	SubnetworkRef *v1alpha1.ResourceRef `json:"subnetworkRef,omitempty"`

	/* The Cloud Storage path to use for temporary files. Must be a valid Cloud Storage URL, beginning with gs://. */
	// +optional
	TempLocation *string `json:"tempLocation,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. */
	// +optional
	TransformNameMapping *FlextemplatejobTransformNameMapping `json:"transformNameMapping,omitempty"`
}

type DataflowFlexTemplateJobStatus struct {
	/* Conditions represent the latest available observations of the
	   DataflowFlexTemplateJob's current state. */
	Conditions []v1alpha1.Condition `json:"conditions,omitempty"`
	// +optional
	JobId *string `json:"jobId,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 *int `json:"observedGeneration,omitempty"`

	// +optional
	State *string `json:"state,omitempty"`

	/* The type of this job, selected from the JobType enum. */
	// +optional
	Type *string `json:"type,omitempty"`
}

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

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

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

type DataflowJobSpec struct {
	/* List of experiments that should be used by the job. An example value is ["enable_stackdriver_agent_metrics"]. */
	// +optional
	AdditionalExperiments []string `json:"additionalExperiments,omitempty"`

	/* Indicates if the job should use the streaming engine feature. */
	// +optional
	EnableStreamingEngine *bool `json:"enableStreamingEngine,omitempty"`

	/* The configuration for VM IPs. Options are "WORKER_IP_PUBLIC" or "WORKER_IP_PRIVATE". */
	// +optional
	IpConfiguration *string `json:"ipConfiguration,omitempty"`

	/* The name for the Cloud KMS key for the job. */
	// +optional
	KmsKeyRef *v1alpha1.ResourceRef `json:"kmsKeyRef,omitempty"`

	/* The machine type to use for the job. */
	// +optional
	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. */
	// +optional
	MaxWorkers *int `json:"maxWorkers,omitempty"`

	// +optional
	NetworkRef *v1alpha1.ResourceRef `json:"networkRef,omitempty"`

	/* Key/Value pairs to be passed to the Dataflow job (as used in the template). */
	// +optional
	Parameters *JobParameters `json:"parameters,omitempty"`

	/* Immutable. The region in which the created job should run. */
	// +optional
	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. */
	// +optional
	ResourceID *string `json:"resourceID,omitempty"`

	// +optional
	ServiceAccountRef *v1alpha1.ResourceRef `json:"serviceAccountRef,omitempty"`

	// +optional
	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"`

	/* The Google Cloud Storage path to the Dataflow job template. */
	TemplateGcsPath string `json:"templateGcsPath"`

	/* 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. */
	// +optional
	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. */
	// +optional
	Zone *string `json:"zone,omitempty"`
}

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. */
	// +optional
	JobId *string `json:"jobId,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 *int `json:"observedGeneration,omitempty"`

	/* The current state of the resource, selected from the JobState enum. */
	// +optional
	State *string `json:"state,omitempty"`

	/* The type of this job, selected from the JobType enum. */
	// +optional
	Type *string `json:"type,omitempty"`
}

type FlextemplatejobParameters struct {
}

type FlextemplatejobTransformNameMapping struct {
}

type JobParameters struct {
}

type JobTransformNameMapping struct {
}