-
Notifications
You must be signed in to change notification settings - Fork 210
/
dataflowflextemplatejob_types.go
159 lines (124 loc) · 5.96 KB
/
dataflowflextemplatejob_types.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
// Copyright 2020 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// ----------------------------------------------------------------------------
//
// *** AUTO GENERATED CODE *** AUTO GENERATED CODE ***
//
// ----------------------------------------------------------------------------
//
// This file is automatically generated by Config Connector and manual
// changes will be clobbered when the file is regenerated.
//
// ----------------------------------------------------------------------------
// *** DISCLAIMER ***
// Config Connector's go-client for CRDs is currently in ALPHA, which means
// that future versions of the go-client may include breaking changes.
// Please try it out and give us feedback!
package v1beta1
import (
"github.com/GoogleCloudPlatform/k8s-config-connector/pkg/clients/generated/apis/k8s/v1alpha1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
type FlextemplatejobParameters struct {
}
type FlextemplatejobTransformNameMapping struct {
}
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"`
}
// +genclient
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// DataflowFlexTemplateJob is the Schema for the dataflow API
// +k8s:openapi-gen=true
type DataflowFlexTemplateJob struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
Spec DataflowFlexTemplateJobSpec `json:"spec,omitempty"`
Status DataflowFlexTemplateJobStatus `json:"status,omitempty"`
}
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
// DataflowFlexTemplateJobList contains a list of DataflowFlexTemplateJob
type DataflowFlexTemplateJobList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []DataflowFlexTemplateJob `json:"items"`
}
func init() {
SchemeBuilder.Register(&DataflowFlexTemplateJob{}, &DataflowFlexTemplateJobList{})
}